詳解SpringCloud客戶端負(fù)載均衡Ribbo/Feign

作者：動力節(jié)點(diǎn) 2021-04-30 08:19:32

Ribbon是Netflix公司發(fā)布的開源項(xiàng)目(組件、框架、jar包)，主要功能是提供客戶端的軟件負(fù)載均衡算法，它會從eureka中獲取一個可用的服務(wù)端清單，通過心跳檢測來剔除故障的服務(wù)端節(jié)點(diǎn)以保證清單中都是可以正常訪問的服務(wù)端節(jié)點(diǎn)。

[[396983]]

Spring Cloud Ribbon

Ribbon是什么?

(Spring Cloud Netflix) -->大量使用了Netflix公司的開源項(xiàng)目
(Spring Cloud Alibaba)-->大量使用了Alibaba公司的開源項(xiàng)目

Spring Cloud Ribbon是基于Netflix Ribbon實(shí)現(xiàn)的一套客戶端負(fù)載均衡器;

我們通常說的負(fù)載均衡是指將一個請求均勻地分?jǐn)偟讲煌墓?jié)點(diǎn)單元上執(zhí)行，負(fù)載均衡分為硬件負(fù)載均衡和軟件負(fù)載均衡：

硬件負(fù)載均衡：比如 F5、深信服、Array 等;
軟件負(fù)載均衡：比如 Nginx、LVS、HAProxy 等;(是一個服務(wù)器實(shí)現(xiàn)的)

當(dāng)客戶端發(fā)送請求，則ribbon負(fù)載均衡器按某種算法(比如輪詢、權(quán)重、最小連接數(shù)等)從維護(hù)的可用服務(wù)端清單中取出一臺服務(wù)端的地址，然后進(jìn)行請求;

Ribbon非常簡單，可以說就是一個jar包，這個jar包實(shí)現(xiàn)了負(fù)載均衡算法，Spring Cloud 對 Ribbon 做了二次封裝，可以讓我們使用 RestTemplate 的服務(wù)請求，自動轉(zhuǎn)換成客戶端負(fù)載均衡的服務(wù)調(diào)用。

Ribbon 支持多種負(fù)載均衡算法，還支持自定義的負(fù)載均衡算法。

客戶端負(fù)載均衡 vs 服務(wù)端負(fù)載均衡

采用Ribbon實(shí)現(xiàn)服務(wù)調(diào)用

1、首先加入ribbon的依賴，但是eureka已經(jīng)依賴了ribbon，所以這里不需要再引用ribbon的依賴;

2、要使用ribbon，只需要一個注解：

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

在RestTemplate上面加入@LoadBalanced注解，這樣就可以實(shí)現(xiàn)RestTemplate 在調(diào)用時自動負(fù)載均衡;

我們這里現(xiàn)在啟動了eureka集群(3個eureka) 和服務(wù)提供者集群(2個service-goods) 和一個服務(wù)調(diào)用者(service-portal)

#告訴服務(wù)端，服務(wù)實(shí)例的唯一ID

eureka.instance.instance-id=34-sprinGCloud-service-portal

Ribbon 負(fù)載均衡策略

Ribbon 的負(fù)載均衡策略是由 IRule 接口定義, 該接口由如下實(shí)現(xiàn)：

在jar包：com.netflix.ribbon#ribbon-loadbalancer中;

要使用ribbon實(shí)現(xiàn)負(fù)載均衡，在Spring 的配置類里面把對應(yīng)的負(fù)載均衡接口實(shí)現(xiàn)類作為一個Bean配置一下就行了;

負(fù)載均衡的入口：ILoadBalancer接口

如果要切換負(fù)載均衡策略：

@Bean 
public IRule iRule(){ 
    return new RoundRobinRule(); 
}

如果我們沒有指定負(fù)載均衡策略，ribbon默認(rèn)的負(fù)載均衡是ZoneAvoidanceRule;(新版本，G版本)

Spring Cloud Feign

Feign是什么?

Feign 是 Netflix 公司開發(fā)的一個聲明式的 REST 調(diào)用客戶端; (調(diào)用遠(yuǎn)程的restful風(fēng)格的http接口的一個組件)

調(diào)用組件其實(shí)很多，比如：

1、Httpclient(apache)

2、Httpurlconnection (jdk)

3、restTemplate(spring)

4、OkHttp(android)

5、Feign (Netflix) --> 實(shí)現(xiàn)非常優(yōu)雅

Spring Cloud Feign 對 Ribbon 負(fù)載均衡進(jìn)行了簡化，在其基礎(chǔ)上進(jìn)行了進(jìn)一步的封裝，在配置上大大簡化了開發(fā)工作，它是一種聲明式的調(diào)用方式，它的使用方法是定義一個接口，然后在接口上添加注解，使其支持了Spring MVC標(biāo)準(zhǔn)注解和HttpMessageConverters，F(xiàn)eign可以與Eureka和Ribbon組合使用以支持負(fù)載均衡。

Feign能干什么?

Feign旨在簡化微服務(wù)消費(fèi)方(調(diào)用者，客戶端)代碼的開發(fā)，前面在使用Ribbon+RestTemplate進(jìn)行服務(wù)調(diào)用時，利用RestTemplate對http請求的封裝處理，形成了一套模版化的調(diào)用方式，但是在實(shí)際開發(fā)中，由于服務(wù)提供者提供的接口非常多，一個接口也可能會被多處調(diào)用，F(xiàn)eign在Ribbon+RestTemplate的基礎(chǔ)上做了進(jìn)一步封裝，在Feign封裝之后，我們只需創(chuàng)建一個接口并使用注解的方式來配置，即可完成對服務(wù)提供方的接口綁定，簡化了使用Ribbon + RestTemplate的調(diào)用，自動封裝服務(wù)調(diào)用客戶端，減少代碼開發(fā)量;

使用Feign實(shí)現(xiàn)消費(fèi)者

使用 Feign 實(shí)現(xiàn)消費(fèi)者，我們通過下面步驟進(jìn)行：

第一步：創(chuàng)建普通 Spring Boot 工程

把接口放在通用的接口層、常量類、model的項(xiàng)目中

第二步：添加依賴

要添加的依賴主要是

spring-cloud-starter-netflix-eureka-client 和 spring-cloud-starter-feign，如下：

<!-- spring-cloud-starter-openfeign --> 
<dependency> 
    <groupId>org.springframework.cloud</groupId> 
    <artifactId>spring-cloud-starter-openfeign</artifactId> 
</dependency>

第三步：聲明服務(wù)

定義一個 GoodsRemoteClient 接口，通過@FeignClient 注解來指定服務(wù)名稱，進(jìn)而綁定服務(wù)，然后再通過 SpringMVC 中提供的注解來綁定服務(wù)提供者提供的接口，如下：

@FeignClient("34-SPRINGCLOUD-SERVICE-GOODS") 
public interface GoodsService { 
@RequestMapping("/service/goods") 
public String goods(); 
}

這相當(dāng)于綁定了一個名叫34-SPRINGCLOUD-SERVICE-GOODS (這里34-SPRINGCLOUD-SERVICE-GOODS大小寫34-sprinGCloud-service-goods都可以 ) 的服務(wù)提供者提供的/service/goods 接口;

第四步：添加注解

在項(xiàng)目入口類上添加@EnableFeignClients 注解表示開啟 Spring Cloud Feign的支持功能;

第五步：使用 Controller 中調(diào)用服務(wù)

接著來創(chuàng)建一個 Controller 來調(diào)用上面的服務(wù)，如下：

public class GoodsController { 
    @Autowired 
    private GoodsService goodsService; 
    /** 
     * 使用feign進(jìn)行調(diào)用 
     * 
     * @return 
     */ 
    @RequestMapping("/cloud/goodsFeign") 
    public ResultObject goodsFeign() { 
        //調(diào)用遠(yuǎn)程的一個controller, restful的調(diào)用 
        return goodsService.goods(); 
    } 
}