1. RPC调用流程

具体调用过程:

  1. 服务消费者(client客户端)通过本地调用的形式调用服务。
  2. 客户端存根(client stub)接管到申请后负责将办法、入参等信息序列化(组装)成可能进行网络传输的音讯体。
  3. 客户端存根(client stub)找到近程的服务地址,并且将音讯通过网络发送给服务端。
  4. 服务端存根(server stub)收到音讯后进行解码(反序列化操作)。
  5. 服务端存根(server stub)依据解码后果调用本地的服务进行相干解决。
  6. 本地服务执行具体业务逻辑并将处理结果返回给服务端存根(server stub)。
  7. 服务端存根(server stub)将返回后果从新打包成音讯(序列化)并通过网络发送至生产方。
  8. 客户端存根(client stub)接管到音讯,并进行解码(反序列化)。
  9. 服务生产方失去最终后果。

2. Dubbo与Spring Cloud集成演示

  1. 集成搭建配置

    POM依赖:
    <parent>    <!-- Spring Boot 父级依赖 -->    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-parent</artifactId>    <version>2.1.8.RELEASE</version>    <relativePath/></parent><name>rpc-dubbo</name><description>rpc-dubbo</description><packaging>pom</packaging><modules>    <module>rpc-dubbo-api</module>    <module>rpc-dubbo-consumer</module>    <module>rpc-dubbo-provider</module></modules><!-- 专用版本属性配置 --><properties>    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>    <java.version>1.8</java.version>    <spring-cloud.version>Greenwich.SR2</spring-cloud.version>    <spring-cloud-alibaba.version>2.1.0.RELEASE</spring-cloud-alibaba.version></properties><!-- Spring Cloud组件依赖治理 --><dependencyManagement>    <dependencies>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-dependencies</artifactId>            <version>${spring-cloud.version}</version>            <type>pom</type>            <scope>import</scope>        </dependency>        <dependency>            <groupId>com.alibaba.cloud</groupId>            <artifactId>spring-cloud-alibaba-dependencies</artifactId>            <version>${spring-cloud-alibaba.version}</version>            <type>pom</type>            <scope>import</scope>        </dependency>    </dependencies></dependencyManagement><!-- 外围组件依赖 --><dependencies>    <!-- Spring Boot 依赖 -->    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-actuator</artifactId>    </dependency>    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-web</artifactId>    </dependency>    <!-- Dubbo Spring Cloud 集成依赖组件 -->    <dependency>        <groupId>com.alibaba.cloud</groupId>        <artifactId>spring-cloud-starter-dubbo</artifactId>    </dependency>    <!-- Spring Cloud Nacos 服务依赖 -->    <dependency>        <groupId>com.alibaba.cloud</groupId>        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>    </dependency>    <!-- lombok 代码插件 -->    <dependency>        <groupId>org.projectlombok</groupId>        <artifactId>lombok</artifactId>        <optional>true</optional>    </dependency></dependencies>
  2. Dubbo Rpc调用演示

    • 启动服务端:rpc-dubbo-provider
    • 启动客户端:rpc-dubbo-consumer
    • 拜访测试接口: http://127.0.0.1:18080/placeOrder
  3. 限流熔断测试:
    启动sentinel服务,启动命令

    java -Dserver.port=8090 -Dcsp.sentinel.dashboard.server=localhost:8090  -jar D:/TestCode/sentinel-dashboard-1.6.3.jar
  4. Nacos Sentinel配置:

    • 降级配置:

       sentinel-degrade为降级配置策略, 内容:
      [  {    "resource": "placeOrder",    "count": 0.2,    "grade": 1,        "timeWindow": 4  }]
      resource: 为资源名称。
      count: 为百分比[0-1], 这里代表20%
      grade: 为降级策略, 0: 代表响应工夫, 1: 代表异样比例, 2: 代表异样数量, 这里采纳的是异样比。
      timeWindow:为工夫窗, 单位为秒。
    • 限流配置:

    sentinel-flow为限流配置策略,内容:

    [   {    "resource": "placeOrder",    "controlBehavior": 0,    "count": 2,    "grade": 1,    "limitApp": "default",    "strategy": 0  }]
    resource: 为资源名称。
    controlBehavior:流量整形的管制成果,目前反对疾速失败和匀速排队两种模式,默认是0, 疾速失败。
    count: 线程数量。
    grade:限流配置策略, 0:代表线程数量, 1:代表QPS并发数。
    limitApp: 限流针对的起源, 填写default即可。
  5. 限流测试

    批改限流规定, 将并发数改为2。 拜访接口:http://127.0.0.1:18080/placeOrder?userName=test

    触发限流:

  6. 降级测试:

    复原限流规定, 将并发数改为20;批改降级配置, 将异样比例改为0.2(百分二十)。

    拜访异样接口地址:http://127.0.0.1:18080/placeOrder?userName=error

    疾速屡次拜访后, 会触发降级: