簡介
Spring Cloud Ribbon 是 Netflix Ribbon 實(shí)現(xiàn)的一套客戶端 負(fù)載均衡工具

簡單的說，Ribbon 是 Netflix 發(fā)布的開源項(xiàng)目，主要功能是提供 客戶端的復(fù)雜均衡算法和服務(wù)調(diào)用。 Ribbon 客戶端組件提供一系列完善的配置項(xiàng)如超時(shí)、重試等。簡單的說，就是配置文件中列出 load Balancer （簡稱 LB）后面所有的機(jī)器，Ribbon 會(huì)自動(dòng)的幫助你基于某種規(guī)則（如簡單輪詢，隨機(jī)鏈接等）去鏈接這些機(jī)器。我們很容易使用 Ribbon 自定義的負(fù)載均衡算法。

Ribbon官網(wǎng)：https://github.com/Netflix/ribbon

狀態(tài) - 停更進(jìn)維
替代方案 - Spring Cloud Loadbalancer
功能
LB 負(fù)載均衡（Load Balance）是什么
簡單的說就是將用戶的請求平攤的分配到多個(gè)服務(wù)上，從而達(dá)到系統(tǒng)的HA（高可用）

Ribbon 本地負(fù)載均衡客戶端 VS Nginx 服務(wù)端負(fù)載均衡區(qū)別
Nginx 是服務(wù)器負(fù)載均衡，客戶端所有請求都會(huì)交給nginx， 然后 nginx 實(shí)現(xiàn)轉(zhuǎn)發(fā)請求。即負(fù)載均衡是由服務(wù)端實(shí)現(xiàn)的。

Ribbon 本地負(fù)載均衡，在調(diào)用微服務(wù)接口的時(shí)候，會(huì)在注冊中心上獲取注冊信息服務(wù)列表后緩存到JVM 本地，從而在本地實(shí)現(xiàn)RPC遠(yuǎn)程 服務(wù)調(diào)用技術(shù)。

LB 實(shí)現(xiàn)方式
1、集中式
即在服務(wù)的消費(fèi)方和提供方之間使用獨(dú)立的LB 設(shè)施（可以是硬件，如F5, 也可以是軟件如 Nginx ）, 由該設(shè)置負(fù)責(zé)把訪問請求通過某種策略轉(zhuǎn)發(fā)至服務(wù)的提供方

2、進(jìn)程內(nèi) LB
將 LB 邏輯集成到消費(fèi)方，消費(fèi)方從服務(wù)注冊中心獲取有哪些地址可用，然后自己再從這些地址中選擇一個(gè)適合的服務(wù)器。
Ribbon 就屬于進(jìn)程內(nèi)LB，它只是一個(gè)類庫，集成于消費(fèi)方進(jìn)程，消費(fèi)方通過它阿萊獲取服務(wù)提供方的地址。

總結(jié)：
Ribbon 其實(shí)就是一個(gè)軟負(fù)載均衡的客戶端組件，他可以和其他所需請求的客戶端結(jié)合使用，和eureka結(jié)合只是其中的一個(gè)實(shí)例
HA (高可用)

Ribbon 在工作時(shí)分為兩步：
第一步先選擇 Server , 它優(yōu)先選擇在同一個(gè)區(qū)域呢負(fù)載較少的Server

第二步在根據(jù)用戶執(zhí)行的策略，在從server 取到的服務(wù)注冊列表中選擇一個(gè)地址。

其中 Ribbon 提供了多種策略：比如輪詢、隨機(jī)和根據(jù)響應(yīng)時(shí)間加權(quán)。

(測試使用Eureka做服務(wù)注冊 ) 不需要額外導(dǎo)入依賴 ,在 spring-cloud-starter-netflix-eureka-client 自帶 spring-cloud-starter-ribbon

使用方式：@LoadBalance + RestTemplate
@Bean
@LoadBalanced
public RestTemplate getRestTemplate(){
? ? return ?new RestTemplate() ;
}
1
2
3
4
5
賦予RestTemplate 有負(fù)載均衡的能力 也是使用的 ribbon

指定負(fù)載均衡的方式
Ribbon 核心組件IRule : com.netflix.loadbalancer.IRule
相關(guān)的負(fù)載均衡算法 ， 均在 com.netflix.loadbalancer 包下

全類名?? ?說明
RoundRobinRule?? ?輪詢
RandomRule?? ?隨機(jī)
RetryRule?? ?先按照RoundRobinRule的策略獲取服務(wù)，如果獲取服務(wù)失敗則在指定時(shí)間內(nèi)會(huì)進(jìn)行重試，獲取可用的服務(wù)
WeightedResponseTimeRule?? ?對RoundRobinRule 的拓展，響應(yīng)速度越快的實(shí)例選擇權(quán)重越大，越容易被選擇
BestAvailableRule?? ?會(huì)先過濾掉由于多次訪問故障而處斷路器跳閘狀態(tài)的服務(wù)，然后選擇一個(gè)并發(fā)量最小的服務(wù)
AvailabilityFilteringRule?? ?先過濾掉故障實(shí)例，在選擇并發(fā)較小的實(shí)例
ZoneAvoidanceRule?? ?默認(rèn)規(guī)則，符合判斷Server 所在區(qū)域的性能和 Server 的可用性選擇服務(wù)器
指定負(fù)載均衡(在全局Main方法外面建立一個(gè)包寫 ， 不能讓springboot掃描 , 不然會(huì)全局使用該方法)
@Configuration
public class MySelfRule {
? ?@Bean
? ?public IRule myRule(){
? ? ? ?return new RandomRule() ; ?
? ?}
}
1
2
3
4
5
6
7
@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "CLOUD-PAYMENT-SERVICE",configuration = MySelfRule.class)?
// 訪問指定服務(wù)，使用指定的負(fù)載均衡算法
public class OrderMain80 {
? ?public static void main(String[] args){
? ? ? ?SpringApplication.run(OrderMain80.class,args) ;
? ?}
}
1
2
3
4
5
6
7
8
9
自定義負(fù)載均衡
負(fù)載均衡算法：rest 接口第幾次請求數(shù) % 服務(wù)器集群總數(shù)量 = 時(shí)機(jī)調(diào)用服務(wù)器位置下標(biāo)，每次服務(wù)重啟后rest 接口技術(shù)求從1開始。

List<ServiceInstance> instances = discoverClient.getInstances("PAYMENT-SERVICE");

如： ?List[0] instances = 127.0.0.1:8002
? ? ? ? ? List[1] instances = 127.0.0.1:8001

8001 + 8002 組合為集群，他們共計(jì)2臺服務(wù)器，集群總數(shù)為2 ， 按照輪詢算法原理：

當(dāng)請求總數(shù)為1 ?時(shí)：1%2 = 1, 對應(yīng)下標(biāo)位置為1， 則獲得服務(wù)地址為 127.0.0.1：8001
當(dāng)請求總數(shù)為2 時(shí)：2%2 = 0, 對應(yīng)下標(biāo)位置為1， 則獲得服務(wù)地址為 127.0.0.1：8002
當(dāng)請求總數(shù)為3 時(shí)：2%2 = 1, 對應(yīng)下標(biāo)位置為1， 則獲得服務(wù)地址為 127.0.0.1：8001

依次類推 。。。。
1
2
3
4
5
6
7
8
9
10
11
12
1、接口
public interface LandBalance {
? ? ServiceInstance instance(List<ServiceInstance> serviceInstances) ;
}
1
2
3
2、實(shí)現(xiàn)
@Component
public class MyLb implements LandBalance {
? ? // 原子類
? ? private AtomicInteger atomicInteger = new AtomicInteger(0) ;
? ? public final int getAndIncrement(){
// ? ? ? ?自旋鎖
? ? ? ? int current ;
? ? ? ? int next ;
? ? ? ? do {
? ? ? ? ? ? current = this.atomicInteger.get() ;
? ? ? ? ? ? next = current >= 2147483647 ? 0 : current + 1 ;
? ? ? ? }while (!this.atomicInteger.compareAndSet(current ,next )) ;
? ? ? ? System.out.println("****訪問次數(shù) next: "+ next );
? ? ? ? return next ;
? ? }
? ? @Override
? ? public ServiceInstance instance(List<ServiceInstance> serviceInstances) {
? ? ? ? int index = ?getAndIncrement() % serviceInstances.size() ;
? ? ? ? return serviceInstances.get(index) ;
? ? }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
3、使用 (restTemplate 上不能有 LoadBalance注解)
@Autowired
private LandBalance landBalance ;
@Autowired
DiscoveryClient discoveryClient ;
? ??
@GetMapping("/consumer/payment/lb")
public String getPaymentLb(){
? ? List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
? ? if (instances == null || instances.size() <= 0 ){
? ? ? ? return ?null ;
? ? }
? ? ServiceInstance instance = landBalance.instance(instances);
? ? URI uri = instance.getUri();
? ?return restTemplate.getForObject(uri+"/payment/lb",String.class) ;
}
————————————————
版權(quán)聲明：本文為CSDN博主「千鈞~」的原創(chuàng)文章，遵循CC 4.0 BY-SA版權(quán)協(xié)議，轉(zhuǎn)載請附上原文出處鏈接及本聲明。
原文鏈接：https://blog.csdn.net/getchar97/article/details/105083324

與50位技術(shù)專家面對面20年技術(shù)見證，附贈(zèng)技術(shù)全景圖

總結(jié)

以上是生活随笔為你收集整理的springcloud----负载均衡--Ribbon与LoadBalance的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。