Dubbo負載均衡策略介紹

更新時間：2022年09月02日 10:43:59 作者：悠然予夏

負載均衡改善了跨多個計算資源（例如計算機，計算機集群，網絡鏈接，中央處理單元或磁盤驅動的的工作負載分布。負載平衡旨在優(yōu)化資源使用，最大化吞吐量，最小化響應時間，并避免任何單個資源的過載

1、負載均衡基本配置

負載均衡（Load Balance）, 其實就是將請求分攤到多個操作單元上進行執(zhí)行，從而共同完成工作任務。

負載均衡策略主要用于客戶端存在多個提供者時進行選擇某個提供者。

在集群負載均衡時，Dubbo 提供了多種均衡策略（包括隨機、輪詢、最少活躍調用數、一致性Hash），缺省為random隨機調用。

這塊兒主要是來自于官方文檔，已經寫得很詳細了

配置負載均衡策略，既可以在服務提供者一方配置，也可以在服務消費者一方配置，如下：

（注：這里只介紹了基于注解的配置方式，其他方式參考官方文檔）

//在服務消費者一方配置負載均衡策略
@Reference(check = false,loadbalance = "random")

//在服務提供者一方配置負載均衡
@Service(loadbalance = "random")
public class HelloServiceImpl implements HelloService {
    public String sayHello(String name) {
        return "hello " + name;
    }
}

2、自定義負載均衡器

負載均衡器在Dubbo中的SPI接口是org.apache.dubbo.rpc.cluster.LoadBalance , 可以通過實現(xiàn)這個接口來實現(xiàn)自定義的負載均衡規(guī)則。

（1）自定義負載均衡器

在上一節(jié)的案例基礎上創(chuàng)建名稱為dubbo-spi-loadbalance的Maven模塊，并創(chuàng)建負載均衡器

OnlyFirstLoadbalancer。這里功能只是簡單的選取所有機器中的第一個(按照字母排序 + 端口排序)。

導入dubbo依賴

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.5</version>
        </dependency>

package com.lagou.loadbalance;
import org.apache.dubbo.common.URL;
import org.apache.dubbo.rpc.Invocation;
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 OnlyFirstLoadbalancer implements LoadBalance {
    @Override
    public <T> Invoker<T> select(List<Invoker<T>> list, URL url, Invocation invocation) throws RpcException {
        // 所有的服務提供者 按照 ip + 端口 排序，選擇第一個
        // List<Invoker<T>> list 包含了所有服務提供者的信息
      return  list.stream().sorted((i1, i2) -> {
            final int ipCompare = i1.getUrl().getIp().compareTo(i2.getUrl().getIp());
            if (ipCompare == 0) {
                return Integer.compare(i1.getUrl().getPort(), i2.getUrl().getPort());
            }
            return ipCompare;
        }).findFirst().get();
    }
}

（2）配置負載均衡器

在dubbo-spi-loadbalance工程的META-INF/dubbo 目錄下新建org.apache.dubbo.rpc.cluster.LoadBalance 文件，并將當前類的全名寫入