客戶端負載均衡 - Ribbon

Ribbon是Netflix公司開源的一個負載均衡的項目（https://github.com/Netflix/ribbon），它是一個基於HTTP、TCP的客戶端負載均衡器。

服務端負載均衡

負載均衡是微服務架構中必須使用的技術，經過負載均衡來實現系統的高可用、集羣擴容等功能。負載均衡可經過硬件設備及軟件來實現，硬件好比：F五、Array等，軟件好比：LVS、Nginx等。

用戶請求先到達負載均衡器（也至關於一個服務），負載均衡器根據負載均衡算法將請求轉發到微服務。負載均衡算法有：輪訓、隨機、加權輪訓、加權隨機、地址哈希等方法，負載均衡器維護一份服務列表，根據負載均衡算法將請求轉發到相應的微服務上，因此負載均衡能夠爲微服務集羣分擔請求，下降系統的壓力

客戶端負載均衡

上圖是服務端負載均衡，客戶端負載均衡與服務端負載均衡的區別在於客戶端要維護一份服務列表，Ribbon從Eureka Server獲取服務列表，Ribbon根據負載均衡算法直接請求到具體的微服務，中間省去了負載均衡服務。

Ribbon負載均衡的流程圖：

一、在消費微服務中使用Ribbon實現負載均衡，Ribbon先從EurekaServer中獲取服務列表。

二、Ribbon根據負載均衡的算法去調用微服務。

Ribbon測試

Spring Cloud引入Ribbon配合 restTemplate 實現客戶端負載均衡。Java中遠程調用的技術有不少，如：webservice、socket、rmi、Apache HttpClient、OkHttp等。

一、在客戶端添加Ribbon依賴：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring‐cloud‐starter‐ribbon</artifactId>
</dependency>
<dependency>
    <groupId>com.squareup.okhttp3</groupId>
    <artifactId>okhttp</artifactId>
</dependency

依賴關係：

 

二、配置Ribbon參數

ribbon:
MaxAutoRetries: 2  #最大重試次數，當Eureka中能夠找到服務，可是服務連不上時將會重試
MaxAutoRetriesNextServer: 3  #切換實例的重試次數
OkToRetryOnAllOperations: false  #對全部操做請求都進行重試，若是是get則能夠，若是是post，put等操做沒有實現冪等的狀況下是很危險的,因此設置爲false
ConnectTimeout: 5000 #請求鏈接的超時時間
ReadTimeout: 6000  #請求處理的超時時間

三、負載均衡測試

啓動兩個服務，端口須要不一致 

定義RestTemplate，使用@LoadBalanced註解

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

測試代碼

//負載均衡調用
@Test
public void testRibbon() {
    //服務id
    String serviceId = "XC‐SERVICE‐MANAGE‐CMS";
    for(int i=0;i<10;i++){
        //經過服務id調用
        ResponseEntity<CmsPage> forEntity = restTemplate.getForEntity("http://" + serviceId
+ "/cms/page/get/5a754adf6abb500ad05688d9", CmsPage.class);
        CmsPage cmsPage = forEntity.getBody();
        System.out.println(cmsPage);
    }
}        

Feign

使用Feign能夠很是方便的實現Http 客戶端。Spring Cloud引入Feign而且集成了Ribbon實現客戶端負載均衡調用

添加依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring‐cloud‐starter‐openfeign</artifactId>
</dependency>
<dependency>
    <groupId>com.netflix.feign</groupId>
    <artifactId>feign‐okhttp</artifactId>
</dependency>

定義FeignClient接口

@FeignClient(value = XcServiceList.XC_SERVICE_MANAGE_CMS)
public interface CmsPageClient {
    @GetMapping("/cms/page/get/{id}")
    public CmsPage findById(@PathVariable("id") String id);
}

啓動類添加@EnableFeignClients註解

測試

@RunWith(SpringRunner.class)
@SpringBootTest
public class FeignTest {
    @Autowired
    CmsPageClient cmsPageClient;
    @Test
    public void testFeign() {
    //經過服務id調用cms的查詢頁面接口
    CmsPage cmsPage = cmsPageClient.findById("5a754adf6abb500ad05688d9");
    System.out.println(cmsPage);
    }
}