Spring Cloud：使用Ribbon實現(xiàn)負載均衡詳解（下）

Levy_X 2019-01-15

展開全文

在上一篇文章（Spring Cloud：使用Ribbon實現(xiàn)負載均衡詳解（上））中，我對 Ribbon 做了一個介紹，Ribbon 可以實現(xiàn)直接通過服務(wù)名稱對服務(wù)進行訪問。這一篇文章我詳細分析一下如何使用 Ribbon 實現(xiàn)客戶端的負載均衡。

1. 使用 Ribbon 實現(xiàn)負載均衡

要實現(xiàn)負載均衡，首先要有多個訂單服務(wù)提供者，目前我們就一個 microservice-order-provider01，端口號 8001，我們可以仿照這個服務(wù)，再創(chuàng)建兩個子模塊，也是訂單服務(wù)提供者，取名為 microservice-order-provider02，端口號 8002 和 microservice-order-provider03，端口號 8003。

現(xiàn)在三個訂單服務(wù)有了，再加上 Ribbon 和 Eureka 集群后，系統(tǒng)的架構(gòu)如下：

Ribbon 是客戶端的負載均衡工具，它在服務(wù)的消費方，首先三個訂單服務(wù) 8001、8002 和 8003 都會注冊到 Eureka 集群，Ribbon 會先從 Eureka 集群（7001、7002 和 7003）中查詢可用的服務(wù)列表，然后根據(jù) Ribbon 提供的負載均衡算法，負載均衡的請求可用的訂單服務(wù)。

Ribbon 默認的負載均衡算法是輪詢，也就是按順序挨個的調(diào)用。我們先來搭建一下整個服務(wù)架構(gòu)，上面提到了，首先要拷貝兩個訂單服務(wù)，端口號分別為 8002 和 8003，一起來對比看下三個訂單服務(wù)的配置文件。

8001 端口的訂單服務(wù)配置：

# 服務(wù)端口號
server:
  port: 8001

# 數(shù)據(jù)庫地址
datasource:
  url: localhost:3306/microservice01
# 省略數(shù)據(jù)庫的基本配置

spring:
  application:
    name: microservice-order # 對外暴露的服務(wù)名稱

# 客戶端注冊進eureka服務(wù)列表里
eureka:
  client:
    service-url:
      defaultZone: http://eureka01:7001/eureka/,http://eureka02:7002/eureka/,http://eureka03:7003/eureka/,
  instance:
    instance-id: 書籍訂單服務(wù)-8001  # 人性化顯示出服務(wù)的信息
    prefer-ip-address: true    # 訪問路徑可顯示ip地址

8002 端口的訂單服務(wù)配置：

# 服務(wù)端口號
server:
  port: 8002

# 數(shù)據(jù)庫地址
datasource:
  url: localhost:3306/microservice02
# 數(shù)據(jù)庫基本配置省略

spring:
  application:
    name: microservice-order # 對外暴露的服務(wù)名稱

# 客戶端注冊進eureka服務(wù)列表里
eureka:
  client:
    service-url:
      defaultZone: http://eureka01:7001/eureka/,http://eureka02:7002/eureka/,http://eureka03:7003/eureka/,
  instance:
    instance-id: 書籍訂單服務(wù)-8002  # 人性化顯示出服務(wù)的信息
    prefer-ip-address: true    # 訪問路徑可顯示ip地址

8003 端口的訂單服務(wù)配置：

# 服務(wù)端口號
server:
  port: 8003

# 數(shù)據(jù)庫地址
datasource:
  url: localhost:3306/microservice03
# 數(shù)據(jù)庫基本配置省略

spring:
  application:
    name: microservice-order # 對外暴露的服務(wù)名稱


# 客戶端注冊進eureka服務(wù)列表里
eureka:
  client:
    service-url:
      defaultZone: http://eureka01:7001/eureka/,http://eureka02:7002/eureka/,http://eureka03:7003/eureka/,
  instance:
    instance-id: 書籍訂單服務(wù)-8003  # 人性化顯示出服務(wù)的信息
    prefer-ip-address: true    # 訪問路徑可顯示ip地址

對比后發(fā)現(xiàn)，有幾個地方需要注意：

對外暴露的服務(wù)名稱必須要相同，因為都是同一個服務(wù)，只不過有多個而已，因為接下來Ribbon是通過服務(wù)名來調(diào)用服務(wù)的；
每個服務(wù)連接了不同的數(shù)據(jù)庫，這樣用來區(qū)分不同的服務(wù)，便于測試，實際中也可能是便于維護；
每個服務(wù)的個性化名稱展示可以區(qū)分一下，這樣在eureka里可以很好的辨別出來

Eureka 集群還是使用前面的 7001、7002 和 7003，首先我們啟動 Eureka 集群，然后分別啟動 8001、8002 和 8003 三個訂單服務(wù)。（友情提示：這里已經(jīng)啟動了6個工程了，如果電腦的性能跟不上的話，可能已經(jīng)開始卡頓了）。

啟動了之后，可以訪問下 eureka01:7001，看下三個訂單服務(wù)是否正常注冊到 eureka 集群里。如下圖，說明集群和訂單服務(wù)均正常。

OK，接下來就是重點了，我們啟動服務(wù)消費方，也就是上一節(jié)中的訂單消費服務(wù)，然后在瀏覽器輸入 http://localhost:9001/consumer/order/get/1 即可查詢到對應(yīng)的訂單服務(wù)：

{'id':1,'name':'跟武哥一起學 Spring Boot','price':39.99,'dbSource':'microservice03'}

刷新頁面，可以看到，結(jié)果如下：

{'id':1,'name':'跟武哥一起學 Spring Boot','price':39.99,'dbSource':'microservice01'}

再刷新頁面，可以看到，結(jié)果如下：

{'id':1,'name':'跟武哥一起學 Spring Boot','price':39.99,'dbSource':'microservice02'}

可以看到，dbsource的值一在 microservice01、microservice02 和 microservice03 之間輪詢切換（這個值是我在三個數(shù)據(jù)庫中設(shè)置的不同的值，就是為了在這展示，方便看到效果），這就說明了，Ribbon 的負載均衡已經(jīng)起作用了，客戶端會輪詢的根據(jù)服務(wù)名，從 8001、8002 和 8003 之間切換訪問，從而達到負載均衡的效果。

同時，也可以看到，Ribbon 的默認負載均衡算法是輪詢。

2. 如何指定 Ribbon 的負載均衡策略

由上面的結(jié)果可知，Ribbon 默認的策略是輪詢，那么 Ribbon 除了輪詢，還有哪些負載均衡的策略呢？我們?nèi)绾稳ピO(shè)置自己想要的策略呢？

Ribbon 自帶的負載均衡策略有如下幾個：

RoundRibbonRule：輪詢。人人有份，一個個來！
RandomRule：隨機。拼人品了！
AvailabilityFilteringRule：先過濾掉由于多次訪問故障而處于斷路器跳閘狀態(tài)的服務(wù)，以及并發(fā)連接數(shù)超過閾值的服務(wù)，剩下的服務(wù)，使用輪詢策略。
WeightedResponseTimeRule：根據(jù)平均響應(yīng)時間計算所有服務(wù)的權(quán)重，響應(yīng)越快的服務(wù)權(quán)重越高，越容易被選中。一開始啟動時，統(tǒng)計信息不足的情況下，使用輪詢。
RetryRule：先輪詢，如果獲取失敗則在指定時間內(nèi)重試，重新輪詢可用的服務(wù)。
BestAvailableRule：先過濾掉由于多次訪問故障而處于斷路器跳閘狀態(tài)的服務(wù)，然后選擇一個并發(fā)量最小的服務(wù)。
ZoneAvoidanceRule：復合判斷 server 所在區(qū)域的性能和 server 的可用性選擇服務(wù)器

如何指定 Ribbon 自帶的負載均衡策略呢？我們需要在配置類中指定一下即可，如下：

/**
 * 配置RestTemplate
 * @author shengwu ni
 */
@Configuration
public class RestTemplateConfig {

    /**
     * '@LoadBalanced'注解表示使用Ribbon實現(xiàn)客戶端負載均衡
     * @return RestTemplate
     */
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

    /**
     * 指定其他負載均衡策略
     * @return IRule
     */
    @Bean
    public IRule myRule() {
        // 指定重試策略：先輪詢，若獲取失敗則在指定時間內(nèi)重試，重新輪詢可用的服務(wù)。
        return new RetryRule();
    }
}