ribbon

• • ribbon concept
  • ribbon核心組件IRule
  • 模仿源碼重寫輪詢

ribbon concept

spring cloud ribbon 是基于Netflix ribbon實現的一套客戶端負載均衡的工具。
簡單的說， Ribbon是Netflix發布的開源項目， 主要功能是提供客戶端的軟件負載均衡算法和服務
完善的配置項如連接超時，重試等。簡單的說，就是在配置文件中列出Load Balancer (簡稱LB), 助你基于某種規則(如簡單輪詢,隨機連接等)去連接這些機器。

目前進入維護模式，替代品：spring cloud loadBalance.

---

restTemplate api

https://docs.spring.io/spring-framework/docs/5.2.2.RELEASE/javadoc-api/org/springframework/web/client/RestTemplate.html

getObject, getEntity postObject, postEntity

---

負載均衡

LB負載均衡(Load Balance)是什么
簡單的說就是將用戶的請求平攤的分配到多個服務上,從而達到系統的HA (高可用)。
常見的負載均衡有軟件Nginx, LVS,硬件F5等。
Ribbon本地負載均衡客戶端VS Nginx服務端負載均衡區別
Nginx是服務器負載均衡,客戶端所有請求都會交給nginx,然后由nginx實現轉發請求。即負載均衡是由服務端實現的。
Ribbon本地負載均衡，在調用微服務接口時候，會在注冊中心上獲取注冊信息服務列表之后緩存到JVM本地,從而在本地實現RPC遠程服務調用技術。

負載均衡+RestTemplate調用。

ribbon核心組件IRule

ribbon客戶端負載均衡接口及實現類
接口以及子類

算法實現

---

替換默認的輪詢算法, 使用隨機

package top.bitqian.rule; // 不要同mainBoot一個目錄import com.netflix.loadbalancer.IRule; import com.netflix.loadbalancer.RandomRule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;/*** 自定義ribbon 負載均衡規則代替默認輪詢規則* @author echo lovely* @date 2020/12/6 17:34*/@Configuration public class SelfRule {@Beanpublic IRule getIRule() {// 隨機return new RandomRule();}}

然后主啟動類添加@RibbonClient注解。

模仿源碼重寫輪詢

負載均衡算法原理： rest接口的第幾次請求數%服務器集群總數量 = 實際服務調用服務器的下標。 每次重啟服務后，rest接口從1開始。

接口

package top.bitqian.springcloud.lb;import org.springframework.cloud.client.ServiceInstance;import java.util.List;/*** 負載均衡 接口--> 輪詢~*/ public interface LoadBalance {/*** 根據可用的服務實例列表 輪詢獲取某個實例~* @param serviceInstanceList 可用服務實例列表* @return 輪詢后的某個服務實例~*/ServiceInstance getInstance(List<ServiceInstance> serviceInstanceList);}

---

實現

package top.bitqian.springcloud.lb.impl;import org.springframework.cloud.client.ServiceInstance; import org.springframework.stereotype.Component; import top.bitqian.springcloud.lb.LoadBalance;import java.util.List; import java.util.concurrent.atomic.AtomicInteger;/*** 仿照源碼寫輪詢算法* @author echo lovely* @date 2020/12/8 20:37*/@Component public class MyLoadBalance implements LoadBalance {// init 0private final AtomicInteger atomicInteger = new AtomicInteger(0);public final int getAndIncrease() {int current;int next;do {current = this.atomicInteger.get();next = current >= 2147483647 ? 0 : current + 1;} while (!this.atomicInteger.compareAndSet(current, next)); // 期望值，修改值System.out.println("the next value -----> " + next);return next;}@Overridepublic ServiceInstance getInstance(List<ServiceInstance> serviceInstanceList) { // 機器列表// 得到服務器的下標位置int index = getAndIncrease() % serviceInstanceList.size();return serviceInstanceList.get(index);} }

---

controller // 測試手寫的輪詢算法~@GetMapping("/consumer/payment/lb")public String getPaymentByLb() {// 根據服務名獲取服務列表List<ServiceInstance> serviceInstanceList =discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");// 1 2, 1 2, 1 2, 獲取服務~ServiceInstance instance = myLb.getInstance(serviceInstanceList);URI uri = instance.getUri();return restTemplate.getForObject(uri + "/payment/lb", String.class);}

總結

以上是生活随笔為你收集整理的ribbon, restTemplate 负载均衡服务调用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。