Ribbon使用及其客户端负载均衡实现原理分析
1、ribbon負(fù)載均衡測試
（1）consumer工程添加依賴
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</dependency>
說明:
①由于spring-cloud-starter-eureka已經(jīng)依賴了spring-cloud-starter-ribbon,所以不用再添加spring-cloud-starter-ribbon依賴了
②Spring cloud 引入ribbon 配合restTemplate 實現(xiàn)客戶端負(fù)載均衡、此處需要引入Okhttp依賴 （也可以使用ApacheClient等其他遠(yuǎn)程調(diào)用技術(shù)）
（2）配置ribbon參數(shù)
#配置ribbon
ribbon:
MaxAutoRetries: #最大重試次數(shù),當(dāng)Eureka中可以找到服務(wù),但是連接不上時將會重試
MaxAutoRetriesNextServer: #切換實例的重試次數(shù)、高可用場景
OkToRetryOnAllOperation: false #對所有操作請求都進(jìn)行重試,如果是get則可以,如果是post、put有重復(fù)提交的危險,建議設(shè)置為false
ConnectTimeout: #請求連接的超時時間
ReadTimeout: #請求處理的超時時間
（3）定義RestTemplate
@Bean
@LoadBalanced //使用該注解表示實現(xiàn)客戶端負(fù)載均衡
public RestTemplate restTemplate(){
return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
}
(4)啟動兩各Producer工程，注意端口不同，注冊到Eureka中
(5)測試代碼
@SpringBootTest
@RunWith(SpringRunner.class)
public class TestRibbon { @Autowired
private RestTemplate restTemplate; @Test
public void testRibbon(){ String serviceId = "Producer";
for(int i=0;i<10;i++){
//通過服務(wù)id調(diào)用
ResponseEntity<User> user= restTemplate.getForEntity("http://"+serviceId+"/user/get/5a754adf6abb500ad05688d9", User.class);
System.out.println(JSONObject.toJSONString(user));
}
}
}
2、客戶端負(fù)載均衡實現(xiàn)原理
（1）區(qū)別服務(wù)端負(fù)載均衡和客戶端負(fù)載均衡
向Nginx 、F5 等在請求發(fā)出之后，被負(fù)載均衡服務(wù)器攔截再分發(fā)到具體服務(wù)的方式是服務(wù)端負(fù)載均衡,而Ribbon是客戶端先從Eureka Server獲取服務(wù)列表，自己維護服務(wù)列表，根據(jù)負(fù)載均衡算法直接請求資源服務(wù)器的方式叫服務(wù)端負(fù)載均衡
（2）Ribbon 實現(xiàn)客戶端負(fù)載均衡細(xì)節(jié)
在定義RestTempalte時加@LoadBalanced注解后、restTemplate會走LoadbanlanceInterceptor攔截器
LoadbanlanceInterceptor.class
@Override
public ClientHttpResponse intercept(final HttpRequest request, final byte[] body,
final ClientHttpRequestExecution execution) throws IOException {
final URI originalUri = request.getURI();
String serviceName = originalUri.getHost();
Assert.state(serviceName != null, "Request URI does not contain a valid hostname: " + originalUri);
//調(diào)用RibbonLoadBalancerClient
return this.loadBalancer.execute(serviceName, requestFactory.createRequest(request, body, execution));
}
RibbonLoadBalancerClient.class
@Override
public <T> T execute(String serviceId, LoadBalancerRequest<T> request) throws IOException {
//獲取服務(wù)列表
ILoadBalancer loadBalancer = getLoadBalancer(serviceId);
//根據(jù)負(fù)載均衡算法從服務(wù)列表中獲取本次調(diào)用服務(wù)的地址
Server server = getServer(loadBalancer);
if (server == null) {
throw new IllegalStateException("No instances available for " + serviceId);
}
RibbonServer ribbonServer = new RibbonServer(serviceId, server, isSecure(server,
serviceId), serverIntrospector(serviceId).getMetadata(server));
return execute(serviceId, ribbonServer, request);
}
總結(jié)
以上是生活随笔為你收集整理的Ribbon使用及其客户端负载均衡实现原理分析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 医学影像中用 python 读取 nrr
- 下一篇： Pytorch中DataLoader类