熔断降级

Dubbo 分类

Dubbo当前常用的有2个分支版本，一个是apache dubbo（GroupID是org.apache.dubbo）, 一个是dubbox （GroupID是com.alibaba）。两个分支的dubbo，对应不同的接入插件，大家接入之前可以先通过GroupID判断下当前项目依赖的是哪个分支的dubbo。

Apache Dubbo 接入

支持版本

  • dubbo 2.x 版本的接入，最新版本为 0.2.2
  • dubbo 3.x 版本的接入，最新版本请参考: release

引入依赖

首先，熔断降级需要依赖以下2个插件，需要将2个插件引入POM中，插件版本建议使用最新版本。

<!-- 北极星注册发现插件 -->
<dependency>
      <groupId>com.tencent.polaris</groupId>
      <artifactId>dubbo-registry-polaris</artifactId>
      <version>${revision}<version>
</dependency>
<!-- 北极星熔断功能插件 -->
<dependency>
    <groupId>com.tencent.polaris</groupId>
    <artifactId>dubbo-circuitbreaker-polaris</artifactId>
    <version>${revision}</version>
</dependency>

启用北极星熔断降级插件

<dubbo:reference filter="polaris_circuitbreaker">


dubbo.consumer.filter=polaris_circuitbreaker

配置北极星注册中心地址

接下来，需要添加北极星registry的配置，指定北极星的地址及相关配置信息，可以通过配置文件及代码的方式进行指定：

配置文件方式添加：

<dubbo:registry address="polaris://127.0.0.1:8091"/>


dubbo.registry.address=polaris://127.0.0.1:8091

使用服务熔断

结果验证

➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
org.apache.dubbo.rpc.RpcException: Failed to invoke the method sayHi in the service com.tencent.polaris.dubbo.example.
api.GreetingService. Tried 3 times of the providers [192.168.31.119:20880] (1/1) from the registry 127.0.0.1:8091 on 
the consumer 192.168.255.10 using the dubbo version 3.2.6. Last error is: com.tencent.polaris.circuitbreak.client.
exception.CallAbortedException: ERR-1020(CLIENT_CIRCUIT_BREAKING): rule application_rule, fallbackInfo null%

使用接口熔断

结果验证

➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
org.apache.dubbo.rpc.RpcException: java.util.concurrent.ExecutionException: org.apache.dubbo.rpc.RpcException: I'm bad sayHi provider%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
org.apache.dubbo.rpc.RpcException: java.util.concurrent.ExecutionException: org.apache.dubbo.rpc.RpcException: I'm bad sayHi provider%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
circuitbreaker downgrade info%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
circuitbreaker downgrade info%

使用节点熔断

节点熔断可以根据RPC调用的连续错误数、失败率等统计指标，对异常节点进行剔除，保障请求只会路由到健康的节点上去。

当前支持针对RPC调用的服务名和接口进行设置熔断规则。

规则中，设置针对该服务下节点的调用，出现连续5次的失败， 则熔断该节点。

为了测试熔断效果，服务调用的时候，可以针对服务进行多次调用。

结果验证

➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
org.apache.dubbo.rpc.RpcException: java.util.concurrent.ExecutionException: org.apache.dubbo.rpc.RpcException: I'm bad sayHi provider%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
[provider by polaris] hi, 123, source from 2.2.2.2%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
[provider by polaris] hi, 123, source from 2.2.2.2%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
[provider by polaris] hi, 123, source from 2.2.2.2%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123
[provider by polaris] hi, 123, source from 2.2.2.2%
➜  ~ curl http://127.0.0.1:15800/echo\?method\=sayHi\&value\=123

样例

熔断样例包括2个工程，代表的是2个服务之间调用，调用链路为：consumer->provider（ok/nok）。

provider 通过环境变量来控制是否返回回包失败，启动的时候设置环境变量 EXCEPTION=true，则该provider进程固定会返回回包异常。

可以启动2个 provider 进程，一个进程启动的时候，不设置 EXCEPTION 变量，代表正常进程；另外一个进程设置 EXCEPTION 变量，代表不正常，用于测试熔断。

环境变量设置

export CONFIG_CENTER_ADDR=127.0.0.1:8093
export METADATA_REPORT_ADDR=127.0.0.1:8091
export POLARIS_DISCOVERY_ADDR=127.0.0.1:8091
export REGISTER_MODE=all
export POD_IP={IP}