Dubbo負(fù)載均衡策略介紹
1、負(fù)載均衡基本配置
負(fù)載均衡(Load Balance), 其實(shí)就是將請(qǐng)求分?jǐn)偟蕉鄠€(gè)操作單元上進(jìn)行執(zhí)行,從而共同完成工作任務(wù)。
負(fù)載均衡策略主要用于客戶端存在多個(gè)提供者時(shí)進(jìn)行選擇某個(gè)提供者。
在集群負(fù)載均衡時(shí),Dubbo 提供了多種均衡策略(包括隨機(jī)、輪詢、最少活躍調(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)建名稱為dubbo-spi-loadbalance的Maven模塊,并創(chuàng)建負(fù)載均衡器
OnlyFirstLoadbalancer。這里功能只是簡(jiǎn)單的選取所有機(jī)器中的第一個(gè)(按照字母排序 + 端口排序)。
導(dǎo)入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 { // 所有的服務(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)前類的全名寫(xiě)入
onlyFirst=包名.負(fù)載均衡器 (onlyFirst:只是一個(gè)標(biāo)識(shí),配置自定義負(fù)載均衡是引用的名稱)
onlyFirst=com.lagou.loadbalance.OnlyFirstLoadbalancer
(3)在服務(wù)提供者工程實(shí)現(xiàn)類中編寫(xiě)用于測(cè)試負(fù)載均衡效果的方法,啟動(dòng)不同端口時(shí),方法返回的信息不同
(4)啟動(dòng)多個(gè)服務(wù),要求他們使用同一個(gè)接口注冊(cè)到同一個(gè)注冊(cè)中心,但是他們的dubbo通信端口不同
(5)在服務(wù)消費(fèi)方指定自定義負(fù)載均衡器 onlyFirst
(6)測(cè)試自定義負(fù)載均衡的效果
到此這篇關(guān)于Dubbo負(fù)載均衡策略介紹的文章就介紹到這了,更多相關(guān)Dubbo負(fù)載均衡 內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
java之StringBuffer常見(jiàn)使用方法解析
這篇文章主要介紹了java之StringBuffer常見(jiàn)使用方法解析,具有一定參考價(jià)值,需要的朋友可以了解下。2017-11-11完美解決在Servlet中出現(xiàn)一個(gè)輸出中文亂碼的問(wèn)題
下面小編就為大家?guī)?lái)一篇完美解決在Servlet中出現(xiàn)一個(gè)輸出中文亂碼的問(wèn)題。小編覺(jué)得挺不錯(cuò)的現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-01-01Java 8 中的 10 個(gè)特性總結(jié)及詳解
本主要介紹Java 8中的新特性,這里整理了相關(guān)資料并整理了10個(gè)特性,逐一介紹說(shuō)明,有興趣的朋友可以參考下2016-09-09Java實(shí)現(xiàn)PDF轉(zhuǎn)為Word文檔的示例代碼
眾所周知,PDF文檔除了具有較強(qiáng)穩(wěn)定性和兼容性外,?還具有較強(qiáng)的安全性,在工作中可以有效避免別人無(wú)意中對(duì)文檔內(nèi)容進(jìn)行修改。本文將分為以下兩部分介紹如何在保持布局的情況下將PDF轉(zhuǎn)為Word文檔,希望對(duì)大家有所幫助2023-01-01java實(shí)現(xiàn)二維碼生成的幾個(gè)方法(推薦)
本篇文章主要介紹了java實(shí)現(xiàn)二維碼生成的幾個(gè)方法(推薦),具有一定的參考價(jià)值,有興趣的可以了解一下。2016-12-12mybatis主表與明細(xì)表一對(duì)多的同時(shí)插入操作方法
對(duì)主表(采購(gòu)申請(qǐng)表)和明細(xì)表(申請(qǐng)物資表)同時(shí)進(jìn)行插入操作insert,怎么實(shí)現(xiàn)呢,下面給大家分享mybatis主表與明細(xì)表一對(duì)多的同時(shí)插入操作方法,感興趣的朋友一起看看吧2023-02-02