Spring?Cloud負載均衡組件Ribbon原理是什么

這篇文章主要介紹“Spring Cloud負載均衡組件Ribbon原理是什么”的相關(guān)知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“Spring Cloud負載均衡組件Ribbon原理是什么”文章能幫助大家解決問題。

微服務(wù)體系下的 Spring Cloud Netflix 套件中 Ribbon 的主要用于負載均衡，底層默認使用 RestTemplate 通訊，并提供了 7 種負載均衡策略

前言

在微服務(wù)中，對服務(wù)進行拆分之后，必然會帶來微服務(wù)之間的通信需求，而每個微服務(wù)為了保證高可用性，又會去部署集群，那么面對一個集群微服務(wù)進行通信的時候，如何進行負載均衡也是必然需要考慮的問題。那么有需求自然就有供給，由此一大批優(yōu)秀的開源的負載均衡組件應(yīng)運而生，本文就讓我們一起來分析一下 Spring Cloud Netflix 套件中的負載均衡組件 Ribbon。

一個問題引發(fā)的思考

首先我們來看一個問題，假如說我們現(xiàn)在有兩個微服務(wù)，一個 user-center，一個 user-order，我現(xiàn)在需要在 user-center 服務(wù)中調(diào)用 user-order 服務(wù)的一個接口。

這時候我們可以使用 HttpClient，RestTemplate 等發(fā)起 http 請求，user-center 服務(wù)端口為 8001，如下圖所示：

@RestController
@RequestMapping(value = "/user")
public class UserController {
    @Autowired
    private RestTemplate restTemplate;

    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

    @GetMapping("/order")
    public String queryOrder(){
        return restTemplate.getForObject("http://localhost:8002/order/query",String.class);
    }
}

而 user-order 服務(wù)中只是簡單的定義了一個接口，user-order 服務(wù)端口為 8002：

@RestController
@RequestMapping(value = "/order")
public class UserOrderController {

    @GetMapping(value = "/query")
    public String queryAllOrder(){
        return "all orders";
    }
}

這時候只需要將兩個服務(wù)啟動，訪問 http://localhost:8001/user/order 就可以獲取到所有的訂單信息。

可以看到，這樣是可以在兩個微服務(wù)之間進行通訊的，但是，假如說我們的 user-order 服務(wù)是一個集群呢？這時候怎么訪問呢？因為 user-order 服務(wù)已經(jīng)是集群，所以必然需要一種算法來決定應(yīng)該請求到哪個 user-order 服務(wù)中，最簡單的那么自然就是隨機或者輪詢機制，輪詢或者隨機其實就是簡單的負載均衡算法，而 Ribbon 就是用來實現(xiàn)負載均衡的一個組件，其內(nèi)部支持輪詢，等算法。

Ribbon的簡單使用

接下來我們看看 Ribbon 的簡單使用。

首先改造 user-order 服務(wù)，在 user-order 服務(wù)中定義一個服務(wù)名配置：

spring.application.name=user-order-service

將 user-order 服務(wù)中的 UserOrderController 稍微改造一下，新增一個端口的輸出來區(qū)分：

@RestController
@RequestMapping(value = "/order")
public class UserOrderController {

    @Value("${server.port}")
    private int serverPort;

    @GetMapping(value = "/query")
    public String queryAllOrder(){
        return "訂單來自：" + serverPort;
    }
}

• 通過 VM 參數(shù) -Dserver.port=8002 和 -Dserver.port=8003 分別來啟動兩個 user-order 服務(wù)。

• 接下來改造 user-center 服務(wù)，在 user-center 服務(wù)中引入 Ribbon 的相關(guān)依賴：

 <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
      <version>2.2.3.RELEASE</version>
    </dependency>

• user-center 服務(wù)中新增一個 Ribbon 相關(guān)配置，列舉出需要訪問的所有服務(wù)：

user-order-service.ribbon.listOfServers=\
  localhost:8002,localhost:8003

• 對 user-center 服務(wù)中的 UserController 進行改造：

@RestController
@RequestMapping(value = "/user")
public class UserController {
    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private LoadBalancerClient loadBalancerClient;

    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

    @GetMapping("/order")
    public String queryOrder(){
        //獲取一個 user-order 服務(wù)
        ServiceInstance serviceInstance = loadBalancerClient.choose("user-order-service");
        String url = String.format("http://%s:%s",serviceInstance.getHost(),serviceInstance.getPort()) + "/order/query";
        return restTemplate.getForObject(url,String.class);
    }
}

這時候我們再次訪問 http://localhost:8001/user/order 就可以看到請求的 user-order 服務(wù)會在 8002 和 8003 之間進行切換。

Ribbon 原理分析

看了上面 Ribbon 的使用示例，會不會覺得有點麻煩，每次還需要自己去獲取 ip 和端口，然后格式化 url，但是其實實際開發(fā)過程中我們并不會通過這么原始的方式來編寫代碼，接下來我們再對上面的示例進行一番改造：

@RestController
@RequestMapping(value = "/user")
public class UserController3 {
    @Autowired
    private RestTemplate restTemplate;

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

    @GetMapping("/order")
    public String queryOrder(){
        return restTemplate.getForObject("http://user-order-service/order/query",String.class);
    }
}

在這個示例中，主要就是一個關(guān)鍵主鍵起了作用：@LoadBalanced。

@LoadBalanced 注解

進入 @LoadBalanced 注解中，我們可以看到，這個注解其實沒有任何邏輯，只是加了一個 @Qualifier 注解：

這個注解大家應(yīng)該很熟悉了，常用語同一個 Bean 有多個不同名稱注入的場景。

@Qualifier注解

下面我們通過一個例子來演示一下 Qualifier注解的用法。

新建一個空的 TestDemo 類，并新增一個 TestConfiguration 類來創(chuàng)建不同名稱的 TestDemo：

@Configuration
public class TestConfiguration {
    @Bean("testDemo1")
    public TestDemo testDemo(){
        return new TestDemo();
    }

    @Bean("testDemo2")
    public TestDemo testDemo2(){
        return new TestDemo();
    }
}

這時候我們?nèi)绻枰⑷?TestDemo，那么有很多種辦法，具體的使用就需要看業(yè)務(wù)需要來決定。

• 方法一：直接使用 @Autowired，并使用 List 集合來接收 Bean，這樣所有 TestDemo 類型的 Bean 都會被注入。

• 方法二：通過使用 @Resource(name = "testDemo1") 注解來指定名稱，這樣就可以只注入一個 Bean。

• 方法三：通過使用 @Resource 和 @Qualifier(value = "testDemo1") 來指定一個 Bean，其實這種方式和方法二的效果基本一致。

• 方法四：使用 @Autowired 和 @Qualifier 注解來注入，不指定任何名稱，如下所示：

@Configuration
public class TestConfiguration {
    @Bean("testDemo1")
    public TestDemo testDemo(){
        return new TestDemo();
    }

    @Bean("testDemo2")
    public TestDemo testDemo2(){
        return new TestDemo();
    }
}

這時候運行之后我們發(fā)現(xiàn)不會有任何 Bean 被注入到集合中，這是因為當(dāng)使用這種方式來注入時，Spring 會認為當(dāng)前只需要注入被 @Qualifier 注解標(biāo)記的 Bean，而我們上面定義的兩個 TestDemo 都沒有被 @Qualifier 修飾。

這時候，我們只需要在 TestConfiguration 稍微改造，在 TestDemo 的定義上加上 @Qualifier 修飾即可：

@Configuration
public class TestConfiguration {

    @Bean("testDemo1")
    @Qualifier
    public TestDemo testDemo(){
        return new TestDemo();
    }

    @Bean("testDemo2")
    @Qualifier
    public TestDemo testDemo2(){
        return new TestDemo();
    }
}

這時候再去運行，就會發(fā)現(xiàn)，testDemo1 和 testDemo2 都會被注入。

LoadBalancerAutoConfiguration 自動裝配

SpringCloud 是基于 SpringBoot 實現(xiàn)的，所以我們常用的這些分布式組件都會基于 SpringBoot 自動裝配來實現(xiàn)，我們進入 LoadBalancerAutoConfiguration 自動裝配類可以看到，RestTemplate 的注入加上了 @LoadBalanced，這就是為什么我們前面的例子中加上了 @LoadBalanced 就能被自動注入的原因：

RestTemplateCustomizer

上面我們看到，RestTemplate 被包裝成為了 RestTemplateCustomizer，而 RestTemplateCustomizer 的注入如下：

可以看到這里面加入了一個攔截器 LoadBalancerInterceptor，事實上即使不看這里，我們也可以猜測到，我們直接使用服務(wù)名就可以進行通訊的原因必然是底層有攔截器對其進行轉(zhuǎn)換成 ip 形式，并在底層進行負載均衡選擇合適的服務(wù)進行通訊。

LoadBalancerInterceptor

LoadBalancerInterceptor 是 Ribbon 中默認的一個攔截器，所以當(dāng)我們調(diào)用 RestTemplate 的 getObject 方法時，必然會調(diào)用攔截器中的方法。

從源碼中可以看到，LoadBalancerInterceptor 中只有一個 intercept() 方法：

RibbonLoadBalancerClient#execute

繼續(xù)跟進 execute 方法會進入到 RibbonLoadBalancerClient 類（由 RibbonAutoConfiguration 自動裝配類初始化）中：

這個方法中也比較好理解，首先獲取一個負載均衡器，然后再通過 getServer 方法獲取一個指定的服務(wù)，也就是當(dāng)我們有多個服務(wù)時，到這里就會選出一個服務(wù)進行通訊。

進入 getServer 方法：

我們看到，最終會調(diào)用 ILoadBalancer 中的 chooseServer 方法，而 ILoadBalancer 是一個頂層接口，這時候具體會調(diào)用哪個實現(xiàn)類那么就需要先來看一下類圖：

這里直接看類圖也無法看出到底會調(diào)用哪一個，但是不論調(diào)用哪一個，我們猜測他肯定會有一個地方去初始化這個類，而在 Spring 當(dāng)中一般就是自動裝配類中初始化或者 Configuration 中初始化，而 ILoadBalancer 正是在 RibbonClientConfiguration 類中被加載的：

ZoneAwareLoadBalancer 負載均衡器

ZoneAwareLoadBalancer 的初始化會調(diào)用其父類 DynamicServerListLoadBalancer 進行初始化，然后會調(diào)用 restOfInit 方法進行所有服務(wù)的初始化。

如何獲取所有服務(wù)

使用 Ribbon 后，我們通訊時并沒有指定某一個 ip 和端口，而是通過服務(wù)名來調(diào)用服務(wù)，那么這個服務(wù)名就可能對應(yīng)多個真正的服務(wù)，那么我們就必然需要先獲取到所有服務(wù)的 ip 和端口等信息，然后才能進行負載均衡處理。

獲取所有服務(wù)有兩種方式：

• 從配置文件獲取

• 從 Eureka 注冊中心獲?。ㄐ枰胱灾行模?。

初始化服務(wù)的方式是通過啟動一個 Scheduled 定時任務(wù)來實現(xiàn)的，默認就是 30s 更新一次，其實在很多源碼中都是通過這種方式來定時更新的，因為源碼要考慮的使用的簡單性所以不太可能引入一個第三方中間件來實現(xiàn)定時器。

具體的源碼如下所示：enableAndInitLearnNewServersFeature() 方法啟動的定時任務(wù)最終仍然你是調(diào)用 updateListOfServers() 方法來更新服務(wù)。

最終在獲取到服務(wù)之后會調(diào)用父類 BaseLoadBalancer 中的將所有服務(wù)設(shè)置到 allServerList 集合中（BaseLoadBalancer 類中維護了一些負載均衡需要使用到的服務(wù)相關(guān)信息）。

如何判斷服務(wù)是否可用

當(dāng)我們獲取到配置文件（或者 Eureka 注冊中心）中的所有服務(wù)，那么這時候能直接執(zhí)行負載均衡策略進行服務(wù)分發(fā)嗎？顯然是不能的，因為已經(jīng)配置好的服務(wù)可能會宕機（下線），從而導(dǎo)致服務(wù)不可用，所以在 BaseLoadBalancer 中除了有一個 allServerList 集合來維護所有服務(wù)器，還有一個集合 upServerList 用來維護可用服務(wù)集合，那么如何判斷一個服務(wù)是否可用呢？答案就是通過心跳檢測來判斷一個服務(wù)是否可用。

心跳檢測 Task

在講心跳檢測之前，我們先看一下 BaseLoadBalancer 中的 setServersList 方法，有一段邏輯比較重要：

這段邏輯我們看到，默認情況下，如果 Ping 的策略是 DummyPing，那么默認 upServerList = allServerList，而實際上，假如我們沒有進行進行特殊配置，其實默認的就是 DummyPing，這也是在 RibbonClientConfiguration 類中被加載的：

在 BaseLoadBalancer 初始化過程中，也會啟動一個 Scheduled 定時任務(wù)去定時更新任務(wù)，最終和 forceQuickPing() 方法一樣，調(diào)用一個默認策略來觸發(fā)心跳檢測，而默認策略就是 DummyPing，也就是默認所有服務(wù)都是可用的。

雖然默認不執(zhí)行真正的心跳檢測操作，但是 Netflix 中提供了 PingUrl 等其他策略，PingUrl 其實就是發(fā)起一個 http 請求，如果有響應(yīng)就認為服務(wù)可用，沒響應(yīng)就認為服務(wù)不可用。

修改心跳檢測策略可以通過如下配置切換（user-order-service 為客戶端的服務(wù)名），既然是可配置的，那么也可以自己實現(xiàn)一個策略，只需要實現(xiàn) IPing 接口即可。

user-order-service.ribbon.NFLoadBalancerPingClassName=com.netflix.loadbalancer.PingUrl

Ribbon 的負載均衡算法

當(dāng)獲取到可用服務(wù)之后，那么最后應(yīng)該選擇哪一個服務(wù)呢？這就需要使用到負載均衡策略，在 Ribbon 中，可以通過配置修改，也可以自定義負載均衡策略（實現(xiàn) IRule 接口）。

• RandomRule：隨機算法

• RoundRobinRule：輪詢算法

• ZoneAvoidanceRule：結(jié)合分區(qū)統(tǒng)計信息篩選出合適的分區(qū)（默認的負載均衡算法）

• RetryRule：在 deadline 時間內(nèi)，如果請求不成功，則重新發(fā)起請求知道找到一個可用的服務(wù)。

• WeightedResponseTimeRule：根據(jù)服務(wù)器的響應(yīng)時間計算權(quán)重值，服務(wù)器響應(yīng)時間越長，這個服務(wù)器的權(quán)重就越小，會有定時任務(wù)對權(quán)重值進行更新。

• AvailabilityFilteringRule：過濾掉短路（連續(xù) 3 次連接失?。┑姆?wù)和高并發(fā)的服務(wù)。

• BestAvailableRule：選擇并發(fā)數(shù)最低的服務(wù)器

負載均衡算法可通過以下配置進行修改：

user-order-service.ribbon.NFLoadBalancerRuleClassName=Rule規(guī)則的類名

關(guān)于“Spring Cloud負載均衡組件Ribbon原理是什么”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識，可以關(guān)注億速云行業(yè)資訊頻道，小編每天都會為大家更新不同的知識點。