Java-77 深入浅出 RPC Dubbo 负载均衡全解析：策略、配置与自定义实现实战

点一下关注吧！！！非常感谢！！持续更新！！！

🚀 AI篇持续更新中！（长期更新）

AI炼丹日志-30-新发布【1T 万亿】参数量大模型！Kimi‑K2开源大模型解读与实践，持续打造实用AI工具指南！📐🤖

💻 Java篇正式开启！（300篇）

目前2025年07月16日更新到：
Java-74 深入浅出 RPC Dubbo Admin可视化管理 安装使用 源码编译、Docker启动
MyBatis 已完结，Spring 已完结，Nginx已完结，Tomcat已完结，分布式服务正在更新！深入浅出助你打牢基础！

📊 大数据板块已完成多项干货更新（300篇）：

包括 Hadoop、Hive、Kafka、Flink、ClickHouse、Elasticsearch 等二十余项核心组件，覆盖离线+实时数仓全栈！
大数据-278 Spark MLib - 基础介绍 机器学习算法 梯度提升树 GBDT案例 详解

负载均衡

基本概念与原理

负载均衡（Load Balancing）是一种将工作负载或网络流量分配到多个计算资源（如服务器、网络链路、CPU等）的技术。其核心目标是通过合理分配请求，优化资源使用，最大化吞吐量，最小化响应时间，同时避免单个资源过载。

在实际应用中，负载均衡主要解决以下问题：

1. 提高系统可用性和可靠性
2. 提升系统处理能力
3. 实现系统的水平扩展
4. 提供故障转移能力

基本配置方式

1. 负载均衡策略类型

在分布式系统中，特别是使用Dubbo框架时，主要提供以下几种负载均衡策略：

(1) 随机策略（Random）

• 默认策略
• 实现原理：从可用的服务提供者中随机选择一个
• 特点：简单高效，但无法考虑各节点实际负载情况
• 适用场景：各提供者性能相近，调用压力不大的场景

(2) 轮询策略（Round Robin）

• 实现原理：按固定的顺序依次调用每个服务提供者
• 特点：公平分配请求，但无法考虑响应时间差异
• 示例：有3个提供者A、B、C，调用顺序为A→B→C→A→B→C…
• 适用场景：各提供者性能相近，且处理能力相当

(3) 最少活跃调用数策略（Least Active）

• 实现原理：优先选择当前正在处理的请求数最少的提供者
• 特点：动态感知提供者负载情况，更智能
• 实现方式：统计每个提供者的活跃调用数，选择数值最小的
• 适用场景：各提供者处理能力差异较大的情况

(4) 一致性Hash策略（Consistent Hash）

• 实现原理：相同参数的请求总是发到同一提供者
• 特点：可以利用本地缓存，避免频繁切换提供者
• 适用场景：需要保持会话状态的场景，如缓存、Session保持

2. 配置方法示例

在Dubbo中，可以通过以下方式配置负载均衡策略：

<!-- 服务提供方配置 -->
<dubbo:service interface="..." loadbalance="roundrobin"/>

<!-- 服务消费方配置 -->
<dubbo:reference interface="..." loadbalance="leastactive"/>

也可以在注解中指定：

@Service(loadbalance = "random")
public class DemoServiceImpl implements DemoService {}

3. 负载均衡的实现层次

在实际应用中，负载均衡可以在不同层次实现：

1. DNS层负载均衡：通过DNS解析将请求分配到不同IP
2. 硬件负载均衡：如F5等专用设备
3. 软件负载均衡：如Nginx、LVS等
4. 客户端负载均衡：如Dubbo、Ribbon等框架内置的负载均衡

高级配置与优化

1. 权重配置：可以为不同服务提供者设置权重，负载均衡时会根据权重分配请求

   <dubbo:provider weight="100"/>
   <dubbo:provider weight="200"/>
   

2. 动态调整：一些高级负载均衡器支持动态调整策略，根据实时性能指标自动优化

3. 健康检查：结合健康检查机制，自动剔除不健康的节点

4. 区域感知：优先选择同机房或同区域的提供者，减少网络延迟

实际应用场景

1. 电商系统：大促期间，通过负载均衡将流量均匀分配到各服务器
2. 微服务架构：服务消费者从多个提供者中选择最优节点
3. API网关：对外API接口的流量分配
4. 数据库访问：读写分离场景下的读请求分配

代码测试

配置负载均衡策略，既可以在服务提供者一方配置，也可以在服务消费者一方配置，如下：

package icu.wzk.consumer;

import icu.wzk.service.WzkHelloService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Component;

@Component
public class ConsumerComponent {
    @Reference(check = false,loadbalance = "random")
    private WzkHelloService wzkHelloService;
    
    public String sayHello(String name) {
        return wzkHelloService.sayHello(name);
    }
}

我们在 WzkHelloServiceImpl：

package icu.wzk.service.impl;

import icu.wzk.service.WzkHelloService;
import org.apache.dubbo.common.URL;
import org.apache.dubbo.config.annotation.Service;


@Service(loadbalance = "random")
public class WzkHelloServiceImpl implements WzkHelloService {

    @Override
    public String sayHello(String name) {
        return "hello ? " + name;
    }

    @Override
    public String sayHello(URL url) {
        return "";
    }
}

自定义均衡器

负载均衡器介绍

Dubbo 框架中的负载均衡器通过 SPI（Service Provider Interface）机制实现可扩展性。核心接口 org.apache.dubbo.rpc.cluster.LoadBalance 定义了负载均衡的基本行为，开发者可以通过实现此接口来自定义负载均衡策略。

实现自定义负载均衡器

1. 创建项目结构
   在上一节的案例基础上：

   • 创建名为 dubbo-spi-loadbalance 的 Maven 模块
   • 添加 Dubbo 依赖：

     <dependency>
         <groupId>org.apache.dubbo</groupId>
         <artifactId>dubbo</artifactId>
         <version>${dubbo.version}</version>
     </dependency>
     

2. 实现自定义负载均衡器
   创建 WzkLoadBalance 类：

   package com.example.loadbalance;
   
   import org.apache.dubbo.common.URL;
   import org.apache.dubbo.rpc.Invoker;
   import org.apache.dubbo.rpc.RpcException;
   import org.apache.dubbo.rpc.cluster.LoadBalance;
   
   import java.util.List;
   
   public class WzkLoadBalance implements LoadBalance {
       @Override
       public <T> Invoker<T> select(List<Invoker<T>> invokers, URL url, 
                                   RpcException invocation) throws RpcException {
           // 实现自定义负载均衡逻辑
           // 示例：简单轮询算法
           int index = (int) (System.currentTimeMillis() % invokers.size());
           return invokers.get(index);
       }
   }
   

3. SPI 配置
   在项目中创建 SPI 配置文件：

   • 路径：src/main/resources/META-INF/dubbo/org.apache.dubbo.rpc.cluster.LoadBalance
   • 内容：

     wzk=com.example.loadbalance.WzkLoadBalance
     

4. 使用自定义负载均衡器
   在服务消费者配置中指定：

   <dubbo:reference interface="com.example.DemoService" 
                   loadbalance="wzk" />
   

   或通过注解方式：

   @Reference(loadbalance = "wzk")
   private DemoService demoService;
   

注意事项

1. 确保 SPI 文件使用 UTF-8 编码
2. 自定义负载均衡器需要实现完整的负载均衡逻辑
3. 在分布式环境下要考虑线程安全问题
4. 可以通过继承 AbstractLoadBalance 来简化实现

应用场景

• 需要特定路由策略的场景
• 基于权重的动态负载均衡
• 需要结合业务指标（如CPU负载、响应时间）的智能路由
• 多机房流量调度

代码测试

在 dubbo-spi-loadbalance 工程的 META-INF/dubbo 目录下新建 org.apache.dubbo.rpc.cluster.LoadBalancer 文件，并将当前类的全名写入：

我们需要的配置是：

wzkLoadBalance=包名.负载均衡器

我们写入的内容如下：

wzkLoadBalance=icu.wzk.loadbalance.WzkLoadBalance

对应的文件如下所示：

测试使用

如果要使用的话，我们需要在消费者上进行配置：

@DubboReference(loadbalance = "myload")

对应的代码是这样的：

package icu.wzk.consumer;

import icu.wzk.service.WzkHelloService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Component;

@Component
public class ConsumerComponent {   
    // @Reference(check = false,loadbalance = "random")
    @Reference(loadbalance = "wzkLoadBalance")
    private WzkHelloService wzkHelloService;

    public String sayHello(String name) {
        return wzkHelloService.sayHello(name);
    }
}

对应的截图如下所示：