背景
-
早上刷圈看到 Spring Cloud Hoxton.M2 Released 的訊息，隨手發布到了我的知識星球，過了會有個朋友過來如下問題， 抽取半天時間學習spring-cloud-loadbalancer 的原始碼，整理出此文總結
-
Spring Cloud Hoxton.M2 是第一個整合新的loadbalancer實作來替代Ribbon的版本
Spring Cloud Hoxton.M2 is the first release containing both blocking and non-blocking load balancer client implementations as an alternative to Netflix Ribbon which has entered maintenance mode.
- spring-cloud-loadbalancer 的淵源
- 2017年spring 開始嘗試開發新的專案
spring-cloud-loadbalancer替代ribbon，專案托管在
spring-cloud-incubator 范訓器
（多提一嘴，spring cloud alibaba 等頂級的專案大多從此范訓出來的，代表著 spring cloud 的發展方向） - 經過N個月的不維護，還以為spring 放棄此專案時，突然把此專案標記成歸檔遷移到spring-cloud-commons
- 發布2.2.0.M2 版本
如何使用
- 這里基于 最新的hoxton.m2 版本才可以使用，所以要配置spring的代理maven庫
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Hoxton.M2</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencyManagement>
- 加入nacos-client ，使用 2.1.0版本，特別注意排除 ribbon依賴，不然loadbalancer 無效
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</exclusion>
</exclusions>
</dependency>
- 加入 loadbalancer pom坐標
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-loadbalancer</artifactId>
</dependency>
- 配置使用還是和 ribbon 一樣配置
@Configuration
public class LbConfiguration {
@Bean
@LoadBalanced
RestTemplate restTemplate() {
return new RestTemplate();
}
}
@GetMapping("/demo")
public String doOtherStuff() {
return restTemplate.getForObject("http://big-provider-server/demo", String.class);
}
原始碼決議
LoadBalancerClient 實作
- 目前版本只提供了 BlockingLoadBalancerClient 的實作， 注意看中文注釋
// 洗掉只保留了核心代碼注意
public class BlockingLoadBalancerClient implements LoadBalancerClient {
@Override
public <T> T execute(String serviceId, LoadBalancerRequest<T> request)
throws IOException {
// 根據 服務名稱去查詢可用實體
ServiceInstance serviceInstance = choose(serviceId);
return execute(serviceId, serviceInstance, request);
}
@Override
public ServiceInstance choose(String serviceId) {
// 獲取負載均衡策略
ReactiveLoadBalancer<ServiceInstance> loadBalancer = loadBalancerClientFactory
.getInstance(serviceId);
// 執行負載均衡策略獲取可以實體
Response<ServiceInstance> loadBalancerResponse = Mono.from(loadBalancer.choose())
.block();
return loadBalancerResponse.getServer();
}
}
loadBalancer 負載均衡策略實作
- 目前只有一個RoundRobinLoadBalancer 輪詢選擇server的方式
public class RoundRobinLoadBalancer implements ReactorServiceInstanceLoadBalancer {
public Mono<Response<ServiceInstance>> choose(Request request) {
ServiceInstanceSupplier supplier = this.serviceInstanceSupplier.getIfAvailable();
return supplier.get().collectList().map(instances -> {
if (instances.isEmpty()) {
log.warn("No servers available for service: " + this.serviceId);
return new EmptyResponse();
}
// TODO: enforce order?
int pos = Math.abs(this.position.incrementAndGet());
ServiceInstance instance = instances.get(pos % instances.size());
return new DefaultResponse(instance);
});
}
}
和ribbon 比較
默認負載均衡比較
- ribbon 提供7中默認的負載均衡策略，常見的常見都有覆寫，一般我們都是使用
ZoneAvoidanceRule復合判斷server所在區域的性能和server的可用性選擇server
配置方面豐富性
- 目前
spring-cloud-loadbalancer僅支持 重試操作的配置 - ribbon 支持超時、懶加載處理、重試及其和 hystrix整合高級屬性等
結論
-
老老實實用 ribbon
-
以上原始碼 https://github.com/pigxcloud/big
-
歡迎關注 基于Spring Boot 2.1.7、 Spring Cloud Greenwich.SR2、 OAuth2 的RBAC 權限管理系統
-
歡迎關注我們獲得更多的好玩JavaEE 實踐
專案推薦: Spring Cloud 、Spring Security OAuth2的RBAC權限管理系統 歡迎關注
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/168589.html
標籤：Java