前言

該技術(shù)博客是關(guān)于黑馬視頻教程的筆記總結(jié)！

服務(wù)消費(fèi)者需要通過(guò)RestTemplate調(diào)用注冊(cè)中心（Eureka）的服務(wù)提供者，但當(dāng)同一服務(wù)名稱(chēng)的服務(wù)有多個(gè)的時(shí)候，我們的服務(wù)消費(fèi)者應(yīng)該調(diào)用哪一個(gè)服務(wù)呢？這時(shí)候就需要我們學(xué)習(xí)理解Ribbon負(fù)載均衡的實(shí)現(xiàn)原理。

當(dāng)我們?cè)赗estTemplate組件上加上@LoadBalanced注解，就會(huì)去注冊(cè)中心中拉取服務(wù)的實(shí)例列表，并且實(shí)現(xiàn)負(fù)載均衡，SpringCloud底層其實(shí)是利用了一個(gè)名為Ribbon的組件，來(lái)實(shí)現(xiàn)負(fù)載均衡功能的。

1、拋出問(wèn)題

比如我們的服務(wù)消費(fèi)者 order-service發(fā)出請(qǐng)求：http://userservice/user/1
該請(qǐng)求并不能與注冊(cè)中心中的服務(wù)列表信息相符，那么是如何找到 http://localhost:8081呢？

2、源碼解析

2.1、LoadBalancerIntercepor

上述信息已經(jīng)表明，我們沒(méi)有輸出IP和端口號(hào)，只是通過(guò)了服務(wù)名稱(chēng)（userservice） 就能找到我們想要調(diào)用的服務(wù)！

這是因?yàn)镽ibbon組件中的LoadBalancerInterceptor（負(fù)載均衡攔截器）會(huì)將調(diào)用請(qǐng)求攔截，根據(jù)服務(wù)名稱(chēng)獲取到服務(wù)實(shí)例的ip和端口。

LoadBalancerInterceptor 會(huì)在將RestTemplate的請(qǐng)求進(jìn)行攔截，然后在Eureka注冊(cè)中心根據(jù)服務(wù)名稱(chēng)獲取服務(wù)列表，隨后利用負(fù)載均衡算法得到真實(shí)的服務(wù)地址信息，替換服務(wù)名稱(chēng)。

可以看到這里的intercept方法，攔截了調(diào)用請(qǐng)求HttpRequest，然后做了一下操作：

1.request.getURI()：獲取請(qǐng)求uri，本例中就是 http://user-service/user/8

2.originalUri.getHost()：獲取uri路徑的主機(jī)名，其實(shí)就是服名稱(chēng)：userservice

3.this.loadBalancer.execute()：處理服務(wù)名稱(chēng)，和用戶請(qǐng)求

這里的this.loadBalancer是LoadBalancerClient類(lèi)型，我們繼續(xù)跟入execute方法！

2.2、LoadBalancerClient

代碼是這樣的：

getLoadBalancer(serviceId)：根據(jù)服務(wù)名稱(chēng)獲取ILoadBalancer接口，而ILoadBalancer會(huì)拿著服務(wù)名稱(chēng)去eureka中獲取服務(wù)列表并保存起來(lái)。

getServer(loadBalancer)：利用內(nèi)置的負(fù)載均衡算法，從服務(wù)列表中選擇一個(gè)。本例中，可以看到獲取了8082端口的服務(wù)

放行后，再次訪問(wèn)并跟蹤，發(fā)現(xiàn)變成獲取8081端口服務(wù)，實(shí)現(xiàn)了負(fù)載均衡：

2.3、負(fù)載均衡策略IRule

在剛才的代碼中，可以看到獲取服務(wù)使通過(guò)一個(gè)getServer方法來(lái)做負(fù)載均衡:

繼續(xù)跟入getServer方法：

繼續(xù)跟蹤源碼chooseServer方法，發(fā)現(xiàn)這么一段代碼：

我們看看這個(gè)rule是誰(shuí)：

這里的rule默認(rèn)值是一個(gè)RoundRobinRule，看看介紹：

翻譯過(guò)來(lái)就是輪詢的意思，這樣，整個(gè)負(fù)載均衡的流程我們就清楚了。

2.4、總結(jié)

Ribbon的底層采用了一個(gè)攔截器，攔截了RestTemplate發(fā)出的請(qǐng)求，對(duì)地址做了修改。用一幅圖來(lái)總結(jié)一下：

基本流程如下：

• 攔截我們的RestTemplate請(qǐng)求http://userservice/user/1
• RibbonLoadBalancerClient會(huì)從請(qǐng)求url中獲取服務(wù)名稱(chēng)，也就是userservice
• DynamicServerListLoadBalancer根據(jù)userservice到eureka拉取服務(wù)列表：localhost:8081、localhost:8082
• IRule利用內(nèi)置負(fù)載均衡規(guī)則，從列表中選擇一個(gè)服務(wù)，例如localhost:8081
• RibbonLoadBalancerClient修改請(qǐng)求地址，用localhost:8081替代userservice，得到http://localhost:8081/user/1，發(fā)起真實(shí)請(qǐng)求

3、負(fù)載均衡策略

負(fù)載均衡的規(guī)則都定義在IRule接口中，而IRule有很多不同的實(shí)現(xiàn)類(lèi)：

不同規(guī)則的含義如下：

默認(rèn)的實(shí)現(xiàn)就是ZoneAvoidanceRule，是一種輪詢方案

那么如何自定義負(fù)載均衡策略？

通過(guò)定義IRule實(shí)現(xiàn)可以修改負(fù)載均衡規(guī)則，有兩種方式：

1.代碼方式：在配置類(lèi)或啟動(dòng)類(lèi)（可以看作配置類(lèi)）中，定義一個(gè)新的IRule：

@Bean
public IRule randomRule(){
	//隨機(jī)策略
    return new RandomRule();
}

配置文件方式：在application.yml文件中，添加新的配置也可以修改規(guī)則：

userservice: # 給某個(gè)微服務(wù)配置負(fù)載均衡規(guī)則，這里是userservice服務(wù)
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # 負(fù)載均衡規(guī)則 

注意：我們一般用默認(rèn)的負(fù)載均衡規(guī)則，不做修改！

總結(jié)

本篇文章就到這里了，希望能夠給你帶來(lái)幫助，也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容！

最新評(píng)論