Dubbo官网实战使用技巧

Posted Java实验室

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Dubbo官网实战使用技巧相关的知识，希望对你有一定的参考价值。


1、启动时检查：

我们检查依赖的服务是否启动，可利用下面三个属性，优先级从左到右逐渐降低。
如果服务不是强依赖，或者说服务之间可能存在死循环依赖，我们应该将 check 置为 false。

检查判断优先级：
dubbo.reference.check > dubbo.consumer.check > dubbo.registry.check

2、只订阅：

一般在开发环境时，我们新开发的接口都还不能发布出去，所以我们本地的服务不能往注册中心注册；
而且，如果我们将本地服务注册上去，会影响别的服务的联调，所以我们会利用下面属性，将服务设置为只订阅，不往注册中心注册。

dubbo.registry.register=false
dubbo.registry.subscribe=true

3、集群容错：

集群容错模式可利用 dubbo.reference.cluster、dubbo.consumer.cluster 和 dubbo.service.cluster、dubbo.provider.cluster 等属性配置。

集群容错中主要有几个角色：

Directory：代表多个 Invoker ，可以把它看成是 List，但是与 List 不同的是，它的值可能是动态变化的，比如注册中心推送变更。

Cluster：将 Directory 中的多个 Invoker 伪装成一个 Invoker，对上层透明，伪装过程包含了容错逻辑，调用失败后，重试另一个。

Router：负责从多个 Invoker 中按路由规则选出子集，比如读写分离，应用隔离等。

LoadBalance：负责从多个 Invoker 中选出具体的一个用于本次调用，选的过程包含了负载均衡算法，调用失败后，需要重选

dubbo 提供的集群容错模式：

Failover Cluster：失败自动切换，当出现失败，重试其它服务器。通常用于读操作，但重试会带来更长延迟。可通过 retries=“2” 来设置重试次数(不含第一次)。

Failfast Cluster：快速失败，即只发起一次调用，失败立即报错。通常用于非幂等性的写操作。

Failsafe Cluster：失败安全，出现异常时直接忽略掉。通常用于写入审计日志等不重要的操作。

Failback Cluster：失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。

Forking Cluster：并行调用多个服务器，只要一个成功就返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。可通过 forks=“2” 来设置最大并行数。

Broadcast Cluster：广播调用所有提供者，逐个调用，任意一台报错则报错。通常用于通知所有提供者更新缓存或日志等本地资源信息。

4、负载均衡：

在集群负载均衡时，Dubbo 提供了多种均衡策略，缺省为 random 随机调用。

Random LoadBalance：

  • 随机，按权重设置随机概率。

  • 在一个截面上碰撞的概率高，但调用量越大分布越均匀，而且按概率使用权重后也比较均匀，有利于动态调整提供者权重。

RoundRobin LoadBalance：

  • 轮询，按公约后的权重设置轮询比率。

  • 存在慢的提供者累积请求的问题，比如：第二台机器很慢，但没挂，当请求调到第二台时就卡在那，久而久之，所有请求都卡在调到第二台上。

LeastActive LoadBalance：

  • 最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差。

  • 使慢的提供者收到更少请求，因为越慢的提供者的调用前后计数差会越大。

ConsistentHash LoadBalance：

  • 一致性 Hash，相同参数的请求总是发到同一提供者。

  • 当某一台提供者挂时，原本发往该提供者的请求，基于虚拟节点，平摊到其它提供者，不会引起剧烈变动。

  • 算法参见：http://en.wikipedia.org/wiki/Consistent_hashing

  • 缺省只对第一个参数 Hash，如果要修改，请配置
    缺省用 160 份虚拟节点，如果要修改，请配置

可在服务端服务级别、客户端服务级别、服务端方法级别和客户端方法级别设置。

服务端服务级别&客户端服务级别配置：

dubbo.provider.loadbalance=leastactive
dubbo.consumer.loadbalance=leastactive

服务端方法级别和客户端方法级别配置:

@DubboService(interfaceClass = DubboServiceOne.class,loadbalance = "random",
                methods = {
                    @Method(name="sayHello",loadbalance = "leastActive")
                })
public class DubboServiceOneImpl implements DubboServiceOne {}

@DubboReference(loadbalance = "random",
                    methods = {
                        @Method(name="sayHello",loadbalance = "leastactive")
                    })
private DubboServiceOne DubboServiceOne;

5、直连提供者

在开发及测试环境下，经常需要绕过注册中心，只测试指定服务提供者，这时候可能需要点对点直连，点对点直连方式，将以服务接口为单位，忽略注册中心的提供者列表，A 接口配置点对点，不影响 B 接口从注册中心获取列表。

java -D com.alibaba.xxx.XxxService=dubbo://localhost:20890

在 标签或者@DubboResource注解中增加 url 属性。

<debbo.reference url="dubbo://localhost:20890" interfaceClass=""/>

@DubboReference(url="dubbo://localhost:20890")
private DubboServiceOne DubboServiceOne;

6、本地调用

本地调用使用了 injvm 协议，是一个伪协议，它不开启端口，不发起远程调用，只在 JVM 内直接关联，但执行 Dubbo 的 Filter 链。

protocol、provider、consumer、service、reference 都可以设置。

7、本地存根

远程服务后，客户端通常只剩下接口，而实现全在服务器端，但提供方有些时候想在客户端也执行部分逻辑，比如：做 ThreadLocal 缓存，提前验证参数，调用失败后伪造容错数据等等，此时就需要在 API 中带上 Stub，客户端生成 Proxy 实例，会把 Proxy 通过构造函数传给 Stub ，然后把 Stub 暴露给用户，Stub 可以决定要不要去调 Proxy。

Sub 利用 dubbo.service.sub 属性设置。

例子：

假设服务提供者提供了一个接口，DubboServiceOne，然后服务消费者要做本地存根，只需要在自己的项目中，增加一个 DubboServiceOne 接口的实现类，然后在 @DubboReference 注解或者   标签增加 stub 属性即可。

实现类：

/**
 * DubboServiceOne 本地存根
 * @author winfun
 * @date 2021/2/1 9:59 上午
 **/
@Slf4j
public class DubboServiceOneStub implements DubboServiceOne {

    private final DubboServiceOne dubboServiceOne;

    public DubboServiceOneStub(DubboServiceOne dubboServiceOne){
        this.dubboServiceOne = dubboServiceOne;
    }

    /***
     *  say hello
     * @author winfun
     * @param name name
     * @return {@link ApiResult   }
     **/
    @Override
    public ApiResult  sayHello(String name) {
        try {
            ApiResult  result = this.dubboServiceOne.sayHello(name);
             if (ApiContants.SUCCESS.equals(result.getCode())){
                 return ApiResult.fail(ApiContants.FAIL, "业务异常",result.getData());
            }
        }catch (Exception e){
            log.error( "call DubboServiceOne throw exception!message is {}",e.getMessage());
             return ApiResult.fail( "调用失败");
        }
         return null;
    }
}


使用：

/**
 * 测试本地存根
 * @author winfun
 * @date 2021/2/1 10:26 上午
 **/
@RestController
public class TestStubController {

    @DubboReference(lazy = true,check = false,stub = "com.winfun.demo.stub.DubboServiceOneStub")
    private DubboServiceOne dubboServiceOne;

    @GetMapping("/stub/{name}")
    public ApiResult  testStub(@PathVariable( "name") String name){
         return this.dubboServiceOne.sayHello(name);
    }
}

8、本地伪装

本地伪装通常用于服务降级，比如某验权服务，当服务提供方全部挂掉后，客户端不抛出异常，而是通过 mock 数据返回授权失败。

mock 是 sub 的一个子集，mock是发生了错误，也就是抛出 RpcException 异常时会触发；而使用 sub，那么就需要在程序捕获异常，然后进行处理。

mock 机制可利用 标签或者@DubboReference的mock属性设置。

详细可看我自己写的文章：https://blog.csdn.net/Howinfun/article/details/113439208

9、服务延迟暴露

Dubbo 2.6.5 之后，所有服务都将在 Spring 初始化完成后进行暴露，如果你不需要延迟暴露服务，无需配置 delay。

可使用 dubbo.service.delay 属性来设置延迟多少秒暴露服务。delay 的时间单位为毫秒。

10、并发控制

并发控制都是在服务提供者端设置的。

首先，可通过 dubbo.service.executes 属性限制服务端每个方法的并发量（占用线程池线程数）、通过 dubbo.method.executes（服务端） 属性直接将并发限制具体到接口的某个方法。

还可以通过 dubbo.service.actives/dubbo.reference.actives 属性控制接口每个方法每个客户端的并发执行数；
通过 dubbo.method.actives（两端） 属性直接将并发执行控制到接口的某个方法。


版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。

本文链接：

https://blog.csdn.net/Howinfun/article/details/113584534


以上是关于Dubbo官网实战使用技巧的主要内容，如果未能解决你的问题，请参考以下文章

实战Dubbo常用参数与服务治理参数配置

Dubbo 系列（07-5）集群容错 - Mock

Dubbo + ZK + SpringBoot 分布式实战

聊聊Dubbo - Dubbo可扩展机制实战

十三：Sentinel整合RestTemplate&openFegin&Dubbo实战

基于Dubbo的分布式系统架构实战