Spring Cloud 負(fù)載均衡器 Ribbon原理及實現(xiàn)
Ribbon簡介
分布式系統(tǒng)中,各個微服務(wù)會部署多個實例,如何將服務(wù)消費者均勻分?jǐn)偟蕉鄠€服務(wù)提供者實例上,就要使用到負(fù)載均衡器
Ribbon 是負(fù)載均衡器 ,它提供了很多負(fù)載均衡算法,例如輪詢、隨即等,在配置服務(wù)提供者地址后,可以將服務(wù)消費者請求均勻的分發(fā)
為服務(wù)消費者整合Ribbon
添加 Ribbon 依賴庫
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-ribbobn</artifactId> </dependency>
給 RestTemplate 添加 @LoadBalaced 注解,就可整合 RestTemplate 和 Ribbon
@Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); }
修改Controller,請求地址修改為 http://flim-user/user/ ,當(dāng) Ribbon 和 Eureka 配合使用時,會自動將虛擬主機名映射成微服務(wù)的網(wǎng)絡(luò)地址,并注入了 LoadBalancerClient 輸出當(dāng)前選擇的微服務(wù)節(jié)點
@RestController public class MovieController { private final Logger log = LoggerFactory.getLogger(MovieController.class); @Autowired private RestTemplate restTemplate; @Autowired private LoadBalancerClient loadBalancerClient; @GetMapping("/user/{id}") public User findById(@PathVariable int id){ return this.restTemplate.getForObject("http://flim-user/"+id,User.class); } @GetMapping("/log-instance") public void logInstance(){ ServiceInstance serviceInstance = this.loadBalancerClient.choose("flim-user"); log.info("{}:{}:{}",serviceInstance.getServiceId(),serviceInstance.getHost(),serviceInstance.getPort()); } }
運行測試程序
- 啟動 Eureka Server
- 啟動 2 個或更多 flim-user 實例
- 啟動 flim-consumer
- 訪問 http://localhost:8761/ 查看微服務(wù) flim-user 是否注冊成功
- 多次訪問 http://localhost:8010/user/1 會返回如下結(jié)果
{"id":1,"username":"account1","name":"張三","age":20,"balance":100.00}
多次訪問 http://localhost:8010/log-instance 控制臺會輸出以下信息
可以看到請求會均勻的分布到兩個用戶微服務(wù)上
2017-12-17 20:47:53.975 INFO 12313 --- [nio-8010-exec-2] com.linyuan.controller.MovieController : flim-user:linyuandembp:8764
2017-12-17 20:47:54.215 INFO 12313 --- [nio-8010-exec-1] com.linyuan.controller.MovieController : flim-user:linyuandembp:8763
2017-12-17 20:47:54.445 INFO 12313 --- [nio-8010-exec-3] com.linyuan.controller.MovieController : flim-user:linyuandembp:8764
2017-12-17 20:47:54.690 INFO 12313 --- [nio-8010-exec-4] com.linyuan.controller.MovieController : flim-user:linyuandembp:8763
2017-12-17 20:47:54.935 INFO 12313 --- [nio-8010-exec-5] com.linyuan.controller.MovieController : flim-user:linyuandembp:8764
注意 :不能將 restTemplate.getForObject(...) 與 loadBalancerClient.choose(...) 寫在同一方法中,因為 rest-Template 實際上就是一個 Ribbon 客戶端,本身已經(jīng)包含“choose”行為
代碼方式配置 Ribbon
可以使用Java代碼或?qū)傩宰远x Ribbon 的配置,Ribbon 默認(rèn)配置類是 RibbonClientConfiguration,也可以使用一個 POJO 自定義 Ribbon 配置,這種 配置是細(xì)粒度的,不同的 Ribbon 客戶端可以使用不同的配置
創(chuàng)建 Ribbon 配置類
/** * 該類為配置類 * 不應(yīng)該被ComponentScan掃描 */ @Configuration public class RibbonConfiguration { @Bean public IRule ribbonRule(){ //配置負(fù)載均衡的規(guī)則,更改為隨機 return new RandomRule(); } }
使用 @RibbonClient 或 @RibbonClients 注解為服務(wù)提供者指定配置類
@SpringBootApplication @EnableDiscoveryClient @RibbonClient(name = "flim-user",configuration = RibbonConfiguration.class) public class FlimConsumerApplication { @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(FlimConsumerApplication.class, args); } }
訪問測試地址 http://localhost:8010/log-instance 可看見請求會隨機分布到兩微服務(wù)上
2017-12-17 21:08:52.769 INFO 12524 --- [nio-8010-exec-7] com.linyuan.controller.MovieController : flim-user:linyuandembp:8763
2017-12-17 21:08:52.946 INFO 12524 --- [nio-8010-exec-8] com.linyuan.controller.MovieController : flim-user:linyuandembp:8763
2017-12-17 21:08:53.138 INFO 12524 --- [nio-8010-exec-9] com.linyuan.controller.MovieController : flim-user:linyuandembp:8763
2017-12-17 21:08:53.319 INFO 12524 --- [io-8010-exec-10] com.linyuan.controller.MovieController : flim-user:linyuandembp:8764
2017-12-17 21:08:53.511 INFO 12524 --- [nio-8010-exec-1] com.linyuan.controller.MovieController : flim-user:linyuandembp:8763
注意 :RibbonConfiguration 類不能被 @ComponentScan 掃描到,否則配置信息就會被所有 @RibbonClient 共享,因此如果只想自定義某個 Ribbon 客戶端的配置,必須防止被 @ComponentScan 掃描
配置文件方式配置 Ribbon
通過配置文件方式自定義 Ribbon 屬性更加方便,配置的前綴是 <clientName>.ribbon.
- NFLoadBalancerClassName:配置 ILoadBalancer 的實現(xiàn)類
- NFLoadBalancerRuleClassName:配置 IRule 的實現(xiàn)類
- NFLoadBalancerPingClassName:配置 IPing 實現(xiàn)類
- NIWSServerListClassName:配置 ServerList 的實現(xiàn)類
- NIWSServerListFilterClassName:配置 ServerListFilter 的實現(xiàn)類
通過配置文件定義Ribbon配置
flim-user: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
常用的 Ribbon 全局配置
ribbon: ConnectionTimeout: #連接超時時間 ReadTimeout: #讀取超時時間 OkToRetryOnAllOperatotions: #對所有操作請求都進行重試 MaxAutoRetriesNextServer: #切換服務(wù)器實例的重試次數(shù) MaxAutoRetries: #對當(dāng)前實例的重試次數(shù) ServerListRefreshInterval: #刷新服務(wù)列表源的間隔時間
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- Spring?Cloud?Alibaba?Nacos服務(wù)治理平臺服務(wù)注冊、RestTemplate實現(xiàn)微服務(wù)之間訪問負(fù)載均衡訪問的問題
- SpringCloud feign微服務(wù)調(diào)用之間的異常處理方式
- Spring Cloud多個微服務(wù)之間調(diào)用代碼實例
- spring cloud eureka微服務(wù)之間的調(diào)用詳解
- springcloud gateway如何實現(xiàn)路由和負(fù)載均衡
- spring cloud 之 客戶端負(fù)載均衡Ribbon深入理解
- Spring Cloud實現(xiàn)微服務(wù)調(diào)用的負(fù)載均衡(詳解)
相關(guān)文章
java中的JsonSerializer用法,前后端單位轉(zhuǎn)換必備
這篇文章主要介紹了java中的JsonSerializer用法,前后端單位轉(zhuǎn)換必備!具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-10-10Spring?Cloud?Ribbon?中的?7?種負(fù)載均衡策略的實現(xiàn)方法
Ribbon?內(nèi)置了?7?種負(fù)載均衡策略:輪詢策略、權(quán)重策略、隨機策略、最小連接數(shù)策略、重試策略、可用性敏感策略、區(qū)域性敏感策略,并且用戶可以通過繼承?RoundRibbonRule?來實現(xiàn)自定義負(fù)載均衡策略,對Spring?Cloud?Ribbon負(fù)載均衡策略相關(guān)知識感興趣的朋友一起看看吧2022-03-03SpringBoot如何打印mybatis的執(zhí)行sql問題
這篇文章主要介紹了SpringBoot如何打印mybatis的執(zhí)行sql問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-03-03Java使用jdbc連接實現(xiàn)對MySQL增刪改查操作的全過程
JDBC的全稱是Java?Database?Connectivity,即Java數(shù)據(jù)庫連接,它是一種可以執(zhí)行SQL語句的Java?API,下面這篇文章主要給大家介紹了關(guān)于Java使用jdbc連接實現(xiàn)對MySQL增刪改查操作的相關(guān)資料,需要的朋友可以參考下2023-03-03