关于java:RPC实现原理之Dubbo与SpringCloud集成实践

48次阅读

共计 3261 个字符，预计需要花费 9 分钟才能阅读完成。

具体调用过程：

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

集成搭建配置

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>

Dubbo Rpc 调用演示
- 启动服务端：rpc-dubbo-provider
- 启动客户端：rpc-dubbo-consumer
- 拜访测试接口：http://127.0.0.1:18080/placeOrder

限流熔断测试：
启动 sentinel 服务，启动命令

java -Dserver.port=8090 -Dcsp.sentinel.dashboard.server=localhost:8090  -jar D:/TestCode/sentinel-dashboard-1.6.3.jar

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 即可。
限流测试
批改限流规定，将并发数改为 2。拜访接口：http://127.0.0.1:18080/placeOrder?userName=test

触发限流：
降级测试：
复原限流规定，将并发数改为 20；批改降级配置，将异样比例改为 0.2（百分二十）。

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

疾速屡次拜访后，会触发降级：