SpringCloud Ribbon與OpenFeign詳解如何實(shí)現(xiàn)服務(wù)調(diào)用
Ribbon
初識(shí)Ribbon
Ribbon是什么
Ribbon是Netflix發(fā)布的開(kāi)源項(xiàng)目,主要功能是提供對(duì)客戶(hù)端進(jìn)行負(fù)載均衡算法的一套工具,將Netflix的中間層服務(wù)連接在一起。Ribbon客戶(hù)端組件提供一系列完善的配置項(xiàng)如連接超時(shí),重試等。簡(jiǎn)單的說(shuō),就是在配置文件中列出Load Balancer(簡(jiǎn)稱(chēng)LB)后面所有的機(jī)器,Ribbon會(huì)自動(dòng)的幫助你基于某種規(guī)則(如簡(jiǎn)單輪詢(xún),隨即連接等)去連接這些機(jī)器。我們也可以使用Ribbon實(shí)現(xiàn)自定義的負(fù)載均衡算法。
Ribbon能干什么
前面提到說(shuō)Ribbon的作用就是向客戶(hù)端提供負(fù)載均衡算法的工具,那么什么是負(fù)載均衡呢?負(fù)載均衡就是將用戶(hù)發(fā)來(lái)的請(qǐng)求通過(guò)算法均攤到多個(gè)服務(wù)上,從而達(dá)到系統(tǒng)的HA(高可用性)
其中,負(fù)載均衡又可分為本地負(fù)載均衡(進(jìn)程內(nèi)LB)和服務(wù)端負(fù)載均衡(集中式LB),服務(wù)端負(fù)載均衡以Nginx為例,用戶(hù)的所有請(qǐng)求都會(huì)交給Nginx,由其決定請(qǐng)求將被轉(zhuǎn)發(fā)到哪個(gè)服務(wù)器;Ribbon是本地負(fù)載均衡,在調(diào)用接口的時(shí)候從 eureka 注冊(cè)中心服務(wù)器端上獲取服務(wù)注冊(cè)信息列表緩存到本地,從而可以在本地實(shí)現(xiàn)RPC遠(yuǎn)程調(diào)用服務(wù)
使用Ribbon實(shí)現(xiàn)負(fù)載均衡
實(shí)際上Ribbon可以簡(jiǎn)單的理解為負(fù)載均衡算法 + RestTemplate的調(diào)用,也就是說(shuō)想要使用Ribbon實(shí)現(xiàn)負(fù)載均衡,就可以通過(guò)這兩個(gè)技術(shù)加以實(shí)現(xiàn)。
RestTemplate三步走
第一步: 引入Ribbon場(chǎng)景啟動(dòng)器依賴(lài),但是之前使用eureka的時(shí)候我們?cè)趐om文件中導(dǎo)入過(guò)netflix-eureka-server的依賴(lài),其中就默認(rèn)引入了ribbon的場(chǎng)景啟動(dòng)器依賴(lài)(netflix-eureka-client也會(huì)默認(rèn)導(dǎo)入),如果再引一次也可以,但是真沒(méi)那必要。

第二步: 使用配置文件開(kāi)啟 RestTemplate
/**
* @ClassName: ApplicationContextConfig
* @Description: 程序配置類(lèi),用于開(kāi)啟RestTemplate服務(wù),以供后面使用
* @author: chenhao
* @date: 2022/7/17
*/
@Configuration
public class ApplicationContextConfig {
@Bean
@LoadBalanced
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
}第三步: 使用RestTemplate的API實(shí)現(xiàn)負(fù)載均衡,RestTemplate的API根據(jù)請(qǐng)求方式的不同可以被分為get和post,根據(jù)返回類(lèi)型又可以分為Object(響應(yīng)體轉(zhuǎn)化成的json串)和Entity(響應(yīng)的重要信息,包括響應(yīng)頭、狀態(tài)碼、響應(yīng)體等,可以使用對(duì)應(yīng)的get方法獲取到值),所以說(shuō)最主要的四個(gè)API是getForObject、postForObject、getForEntity、postForEntity,這里我把四種API的使用方法都向大家介紹一下
@RestController
@Slf4j
@RequestMapping("consumer")
@Api("消費(fèi)者的訂單管理類(lèi)")
public class OrderController {
// 先注入RestTemplate對(duì)象
@Resource
private RestTemplate restTemplate;
// 使用API實(shí)現(xiàn)負(fù)載均衡
@ApiOperation(value = "創(chuàng)建一條支付記錄", tags = ApiVersionConstant.v1_0)
@PostMapping(value = "/payment/create", produces = {"application/json;charset=UTF-8"})
public CommonResult<Integer> create(@RequestBody Payment payment) {
return restTemplate.postForObject(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/create", payment, CommonResult.class);
}
@ApiOperation(value = "根據(jù)ID查詢(xún)支付記錄", tags = ApiVersionConstant.v1_0)
@GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
public CommonResult<Payment> getPayment(@PathVariable("id") Integer id) {
return restTemplate.getForObject(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
}
@ApiOperation(value = "根據(jù)ID查詢(xún)支付記錄Entity", tags = ApiVersionConstant.v1_0)
@GetMapping(value = "/payment/getForEntity/{id}", produces = {"application/json;charset=UTF-8"})
public CommonResult<Payment> getPaymentEntity(@PathVariable("id") Integer id) {
ResponseEntity<CommonResult> entity = restTemplate.getForEntity(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
if (entity.getStatusCode().is2xxSuccessful()) {
return entity.getBody();
} else {
return new CommonResult<>(444, "操作失敗");
}
}
@ApiOperation(value = "創(chuàng)建一條支付記錄Entity", tags = ApiVersionConstant.v1_0)
@PostMapping(value = "/payment/createEntity", produces = {"application/json;charset=UTF-8"})
public CommonResult<Integer> createEntity(@RequestBody Payment payment) {
return restTemplate.postForEntity(UrlConstant.CLUSTER_PAYMENT_URL + "/payment/create", payment, CommonResult.class)
.getBody();
}
}負(fù)載均衡算法
經(jīng)過(guò)我們上面的嘗試,不難發(fā)現(xiàn)使用RestTemplate實(shí)現(xiàn)的負(fù)載均衡算法是輪詢(xún)機(jī)制,實(shí)際上IRule中不僅僅只提供了一種算法

IRule實(shí)現(xiàn)算法切換
第一步: 新建一個(gè)package,在官方文檔中聲明了IRule的配置類(lèi)不能放到@ComponentScan注解所能掃描到的當(dāng)前包以及子包下,否則自定義的配置類(lèi)就會(huì)被Ribbon的所有客戶(hù)端所共享,以至于失去客戶(hù)端定制化的可能性。主程序入口上的@SpringBootApplication注解是復(fù)合注解,其中就包含@ComponentScan注解,而且是直接掃描主程序入口所在的當(dāng)前包以及子包,也就是說(shuō)配置類(lèi)必須放到主程序入口之外的包下,于是需要新建一個(gè)package
第二步: 在新建的包中新建一個(gè)MySelfRule規(guī)則類(lèi),用于設(shè)置輪詢(xún)算法,如果不設(shè)置的話(huà)就默認(rèn)為輪詢(xún)
@Configuration
public class MySelfRule {
@Bean
public IRule myRule() {
// 修改輪詢(xún)算法為隨機(jī)算法
return new RandomRule();
}
}
第三步: 主啟動(dòng)類(lèi)上使用@RibbonClient(name = “CLOUD-PAYMENT-SERVICE”, configuration = MySelfRule.class)注解,用于指定應(yīng)用服務(wù)和自定義算法規(guī)則的配置類(lèi)
@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "CLOUD-PAYMENT-SERVICE", configuration = MySelfRule.class)
public class OrderMain80 {
public static void main(String[] args) {
SpringApplication.run(OrderMain80.class, args);
}
}
輪詢(xún)算法
所謂的輪詢(xún)算法就是根據(jù)所有的服務(wù),依次將請(qǐng)求均攤到所有的服務(wù)依次訪(fǎng)問(wèn),它的算法實(shí)現(xiàn)就是用RestTemplate接收到的請(qǐng)求數(shù)量對(duì)服務(wù)器集群的數(shù)量進(jìn)行取模運(yùn)算,余數(shù)就是服務(wù)在服務(wù)列表中對(duì)應(yīng)的索引位置,所以說(shuō)可以實(shí)現(xiàn)輪詢(xún)。但是如果中途服務(wù)器關(guān)掉的話(huà)接收到的請(qǐng)求數(shù)量就會(huì)從1重新計(jì)數(shù)
OpenFeign
初識(shí)OpenFeign
什么是OpenFeign
openFeign是要聲明式的web服務(wù)客戶(hù)端,或叫做聲明式REST客戶(hù)端,它讓編寫(xiě)web服務(wù)客戶(hù)端變得簡(jiǎn)單。它將提供者的restful服務(wù)偽裝成接口進(jìn)行消費(fèi),消費(fèi)者只需要通過(guò)feign接口+注解就可以直接調(diào)用提供者的服務(wù)接口,也就是可以實(shí)現(xiàn)接口對(duì)接口的調(diào)用,而無(wú)需像ribbon一樣通過(guò)restTemplate方式對(duì)提供者的服務(wù)進(jìn)行調(diào)用
值得注意的一點(diǎn)是,openFeign內(nèi)置了負(fù)載均衡器-Ribbon,所以說(shuō)openfeign也可以使用負(fù)載均衡算法

如何使用OpenFeign
第一步: 引入相關(guān)依賴(lài)
<!--openfeign-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
第二步: 配置配置文件,只是基本配置和注冊(cè),沒(méi)有OpenFeign獨(dú)有的配置
server:
port: 80
eureka:
client:
register-with-eureka: false
service-url:
#服務(wù)端的地址,服務(wù)端為集群版,向所有的模塊都注冊(cè)
defaultZone: http://localhost:7001/eureka,
http://localhost:7002/eureka,
http://localhost:7003/eureka
第三步: 主啟動(dòng)類(lèi)開(kāi)啟OpenFeign客戶(hù)端
@SpringBootApplication
@EnableFeignClients
public class OrderFeignMain80 {
public static void main(String[] args) {
SpringApplication.run(OrderFeignMain80.class, args);
}
}
第四步: 之前使用ribbon是直接在controller里調(diào)用payment服務(wù)的controller,但是openfeign則是通過(guò)service調(diào)用,于是第三步就是創(chuàng)建一個(gè)service接口用于調(diào)用payment服務(wù)的接口
@Component
@FeignClient(value = "CLOUD-PAYMENT-SERVICE") // 用于指定服務(wù)名,可在eureka或者服務(wù)的配置文件中查看
public interface PaymentFeignService {
@GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
CommonResult<Payment> getPaymentById(@PathVariable("id") Integer id);
}
第五步: controller層調(diào)用service接口
@RestController
@RequestMapping("consumer")
public class OrderFeignController {
@Autowired
private PaymentFeignService paymentFeignService;
@GetMapping(value = "/payment/get/{id}", produces = {"application/json;charset=UTF-8"})
public CommonResult<Payment> getPaymentById(@PathVariable("id") Integer id) {
return paymentFeignService.getPaymentById(id);
}
}
如此操作也可實(shí)現(xiàn)order服務(wù)對(duì)payment服務(wù)的調(diào)用,而且由于OpenFeign默認(rèn)引入Ribbon,去進(jìn)行order服務(wù)訪(fǎng)問(wèn)的時(shí)候,后端會(huì)默認(rèn)輪詢(xún)名為是“CLOUD-PAYMENT-SERVICE”的微服務(wù),也就是兩個(gè)payment服務(wù)
OpenFeign超時(shí)控制
使用OpenFeign調(diào)用服務(wù)接口,默認(rèn)等待時(shí)間為1秒,超時(shí)就會(huì)直接報(bào)錯(cuò)。如果有些服務(wù)的調(diào)用確實(shí)會(huì)花費(fèi)超過(guò)1s的時(shí)間,就需要我們?cè)诜?wù)調(diào)用方(也就是order服務(wù))的配置文件中進(jìn)行配置
由于OpenFeign的超時(shí)控制由其底層的ribbon實(shí)現(xiàn),于是配置文件中的超時(shí)控制也由ribbon進(jìn)行配置
#設(shè)置feign客戶(hù)端超時(shí)時(shí)間(OpenFeign默認(rèn)支持ribbon)
ribbon:
#指的是建立連接所用的時(shí)間,適用于網(wǎng)絡(luò)狀況正常的情況下, 兩端連接所用的時(shí)間
ReadTimeout: 5000
#指的是建立連接后從服務(wù)器讀取到可用資源所用的時(shí)間
ConnectTimeout: 5000
OpenFeign日志打印
OpenFeign提供了日志打印的功能,我們可以通過(guò)日志的打印監(jiān)控接口的調(diào)用情況,從而了解接口調(diào)用時(shí)HTTP請(qǐng)求的具體細(xì)節(jié),具體的使用分
第一步: 使用配置類(lèi)配置日志級(jí)別
@Configuration
public class FeignConfig {
/**
* 日志級(jí)別
* NONE:默認(rèn)的,不顯示任何日志
* BASIC:僅記錄請(qǐng)求方法、URL、響應(yīng)狀態(tài)碼以及執(zhí)行時(shí)間
* HEADERS:請(qǐng)求方法、URL、響應(yīng)狀態(tài)碼、執(zhí)行時(shí)間、請(qǐng)求和響應(yīng)的頭信息
* FULL:請(qǐng)求方法、URL、響應(yīng)狀態(tài)碼、執(zhí)行時(shí)間、請(qǐng)求和響應(yīng)的頭信息、正文以及元數(shù)據(jù)
*/
@Bean
Logger.Level feignLoggerLevel() {
return Logger.Level.FULL;
}
}
第二步: 配置文件開(kāi)啟日志打印,并指定監(jiān)控的接口和級(jí)別
logging:
level:
# feign日志以 debug 級(jí)別監(jiān)控 com.atguigu.springcloud.service.PaymentFeignService 接口
com.xiaochen.springcloud.service.PaymentFeignService: debug
打印出來(lái)的日志如下:

到此這篇關(guān)于SpringCloud Ribbon與OpenFeign詳解如何實(shí)現(xiàn)服務(wù)調(diào)用的文章就介紹到這了,更多相關(guān)SpringCloud Ribbon與OpenFeign內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
在jmeter的beanshell中用java獲取系統(tǒng)當(dāng)前時(shí)間的簡(jiǎn)單實(shí)例
這篇文章介紹了在jmeter的beanshell中用java獲取系統(tǒng)當(dāng)前時(shí)間的簡(jiǎn)單實(shí)例,有需要的朋友可以參考一下2013-09-09
在IntelliJ IDEA中為自己設(shè)計(jì)的類(lèi)庫(kù)生成JavaDoc的方法示例
這篇文章主要介紹了在IntelliJ IDEA中為自己設(shè)計(jì)的類(lèi)庫(kù)生成JavaDoc的方法示例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
java 鍵盤(pán)輸入一個(gè)數(shù),輸出數(shù)組中指定元素的示例
今天小編就為大家分享一篇java 鍵盤(pán)輸入一個(gè)數(shù),輸出數(shù)組中指定元素的示例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-07-07
Java多線(xiàn)程之等待隊(duì)列DelayQueue詳解
這篇文章主要介紹了Java多線(xiàn)程之等待隊(duì)列DelayQueue詳解, DelayQueue被稱(chēng)作"等待隊(duì)列"或"JDK延遲隊(duì)列",存放著實(shí)現(xiàn)了Delayed接口的對(duì)象,對(duì)象需要設(shè)置到期時(shí)間,當(dāng)且僅當(dāng)對(duì)象到期,才能夠從隊(duì)列中被取走(并非一定被取走),需要的朋友可以參考下2023-12-12
Spring Cloud中關(guān)于Feign的常見(jiàn)問(wèn)題總結(jié)
這篇文章主要給大家介紹了Spring Cloud中關(guān)于Feign的常見(jiàn)問(wèn)題,文中通過(guò)示例代碼介紹的很詳細(xì),需要的朋友可以參考借鑒,下面來(lái)一起看看吧。2017-02-02
k8s部署java項(xiàng)目的實(shí)現(xiàn)
本文主要介紹了k8s部署java項(xiàng)目的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-12-12
淺談Java包裝類(lèi)型Long的==操作引發(fā)的低級(jí)bug
本文主要介紹了淺談Java包裝類(lèi)型Long的==操作引發(fā)的低級(jí)bug,文中通過(guò)示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-08-08
springboot整合Nacos組件環(huán)境搭建和入門(mén)案例詳解(最新推薦)
本文介紹了Nacos的基礎(chǔ)概念、關(guān)鍵特性、專(zhuān)業(yè)術(shù)語(yǔ)和生態(tài)圈,如何在Windows環(huán)境下搭建Nacos單個(gè)服務(wù),以及如何整合SpringBoot2來(lái)使用Nacos進(jìn)行服務(wù)注冊(cè)和配置管理,感興趣的朋友一起看看吧2025-03-03
Spring Boot CORS 配置方法允許跨域請(qǐng)求的最佳實(shí)踐方案
跨域請(qǐng)求在現(xiàn)代Web開(kāi)發(fā)中非常重要,特別是在涉及多個(gè)前端和后端服務(wù)時(shí),本文詳細(xì)介紹了跨域請(qǐng)求的背景、重要性以及如何解決跨域問(wèn)題,通過(guò)SpringBoot框架的CORS配置,可以有效地處理跨域請(qǐng)求,確保數(shù)據(jù)傳輸?shù)陌踩院陀脩?hù)體驗(yàn),感興趣的朋友跟隨小編一起看看吧2024-11-11

