快捷導(dǎo)航

Dubbo負(fù)載均衡策略介紹

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

負(fù)載均衡改善了跨多個(gè)計(jì)算資源（例如計(jì)算機(jī)，計(jì)算機(jī)集群，網(wǎng)絡(luò)鏈接，中央處理單元或磁盤(pán)驅(qū)動(dòng)的的工作負(fù)載分布。負(fù)載平衡旨在優(yōu)化資源使用，最大化吞吐量，最小化響應(yīng)時(shí)間，并避免任何單個(gè)資源的過(guò)載

1、負(fù)載均衡基本配置

負(fù)載均衡（Load Balance）, 其實(shí)就是將請(qǐng)求分?jǐn)偟蕉鄠€(gè)操作單元上進(jìn)行執(zhí)行，從而共同完成工作任務(wù)。

負(fù)載均衡策略主要用于客戶(hù)端存在多個(gè)提供者時(shí)進(jìn)行選擇某個(gè)提供者。

在集群負(fù)載均衡時(shí)，Dubbo 提供了多種均衡策略（包括隨機(jī)、輪詢(xún)、最少活躍調(diào)用數(shù)、一致性Hash），缺省為random隨機(jī)調(diào)用。

這塊兒主要是來(lái)自于官方文檔，已經(jīng)寫(xiě)得很詳細(xì)了

配置負(fù)載均衡策略，既可以在服務(wù)提供者一方配置，也可以在服務(wù)消費(fèi)者一方配置，如下：

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

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

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

2、自定義負(fù)載均衡器

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

（1）自定義負(fù)載均衡器

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

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

導(dǎo)入dubbo依賴(lài)

        <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 {
        // 所有的服務(wù)提供者 按照 ip + 端口 排序，選擇第一個(gè)
        // List<Invoker<T>> list 包含了所有服務(wù)提供者的信息
      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）配置負(fù)載均衡器

在dubbo-spi-loadbalance工程的META-INF/dubbo 目錄下新建org.apache.dubbo.rpc.cluster.LoadBalance 文件，并將當(dāng)前類(lèi)的全名寫(xiě)入