负载均衡策略与配置细节

Dubbo 支持的消费端负载均衡策略及其使用方法

Dubbo 内置了 client-based 负载均衡机制，如下是当前支持的负载均衡算法，结合上文提到的自动服务发现机制，消费端会自动使用 Weighted Random LoadBalance 加权随机负载均衡策略 选址调用。

如果要调整负载均衡算法，以下是 Dubbo 框架内置的负载均衡策略：

算法特性备注配置值
Weighted Random LoadBalance加权随机默认算法，默认权重相同random (默认)
RoundRobin LoadBalance加权轮询借鉴于 Nginx 的平滑加权轮询算法，默认权重相同roundrobin
LeastActive LoadBalance最少活跃优先 + 加权随机背后是能者多劳的思想leastactive
Shortest-Response LoadBalance最短响应优先 + 加权随机更加关注响应速度shortestresponse
ConsistentHash LoadBalance一致性哈希确定的入参，确定的提供者，适用于有状态请求consistenthash
P2C LoadBalancePower of Two Choice随机选择两个节点后，继续选择“连接数”较小的那个节点。p2c
Adaptive LoadBalance自适应负载均衡在 P2C 算法基础上，选择二者中 load 最小的那个节点adaptive

全局配置

Dubbo 框架的默认策略是 random 加权随机负载均衡。如果要调整策略，只需要设置 loadbalance 相应取值即可，每种负载均衡策略取值请参见文档最上方表格。

为所有服务调用指定全局配置：

  1. dubbo:
  2.   consumer:
  3.     loadbalance: roundrobin

接口级配置

可以为每个服务指定不同的负载均衡策略。

在 provider 端设置，作为 consumer 侧默认值

  1. @DubboService(loadbalance = "roundrobin")
  2. public class DemoServiceImpl implements DemoService {}

在 consumer 端设置，具备更高优先级

  1. @DubboReference(loadbalance = "roundrobin")
  2. private DemoService demoService;

方法级配置

也可以指定方法(method)级别的负载均衡策略。

在 Spring Boot 开发模式下，配置 method 级别参数有以下几种方式：

JavaConfig

  1. @Configuration
  2. public class DubboConfiguration {
  3.     @Bean
  4.     public ServiceBean demoService() {
  5.         MethodConfig method = new MethodConfig();
  6.         method.setName("sayHello");
  7.         method.setLoadbalance("roundrobin");
  9.         ServiceBean service = new ServiceBean();
  10.         service.setInterface(DemoService.class);
  11.         service.setRef(new DemoServiceImpl());
  12.         service.addMethod(method)
  13.         return service;
  14.     }
  15. }
  1. @Autowire
  2. private DemoService demoService;
  4. @Configuration
  5. public class DubboConfiguration {
  6.     @Bean
  7.     public ReferenceBean demoService() {
  8.         MethodConfig method = new MethodConfig();
  9.         method.setName("sayHello");
  10.         method.setLoadbalance("roundrobin");
  12.         ReferenceBean<DemoService> reference = new ReferenceBean<>();
  13.         reference.setInterface(DemoService.class);
  14.         reference.addMethod(method);
  15.         return reference;
  16.     }
  17. }

dubbo.properties

  1. dubbo.reference.org.apache.dubbo.samples.api.DemoService.sayHello.loadbalance=roundrobin

一致性哈希配置

默认采用第一个参数作为哈希 key，如果需要切换参数，可以指定 hash.arguments 属性

  1. ReferenceConfig<DemoService> referenceConfig = new ReferenceConfig<DemoService>();
  2. // ... init
  3. Map<String, String> parameters = new HashMap<String, String>();
  4. parameters.put("hash.arguments", "1");
  5. parameters.put("sayHello.hash.arguments", "0,1");
  6. referenceConfig.setParameters(parameters);
  7. referenceConfig.setLoadBalance("consistenthash");
  8. referenceConfig.get();

自适应负载均衡配置

只需要在 consumer 或 provider 端将 loadbalance 设置为 p2c 或者 adaptive 即可，可在此查看 工作原理

最后修改 September 13, 2024: Refactor website structure (#2860) (1a4b998f54b)