Ribbon使用及其客户端负载均衡实现原理分析
1、ribbon負(fù)載均衡測(cè)試
（1）consumer工程添加依賴(lài)
<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>
說(shuō)明:
①由于spring-cloud-starter-eureka已經(jīng)依賴(lài)了spring-cloud-starter-ribbon,所以不用再添加spring-cloud-starter-ribbon依賴(lài)了
②Spring cloud 引入ribbon 配合restTemplate 實(shí)現(xiàn)客戶(hù)端負(fù)載均衡、此處需要引入Okhttp依賴(lài) （也可以使用ApacheClient等其他遠(yuǎn)程調(diào)用技術(shù)）
（2）配置ribbon參數(shù)
#配置ribbon
ribbon:
MaxAutoRetries: #最大重試次數(shù),當(dāng)Eureka中可以找到服務(wù),但是連接不上時(shí)將會(huì)重試
MaxAutoRetriesNextServer: #切換實(shí)例的重試次數(shù)、高可用場(chǎng)景
OkToRetryOnAllOperation: false #對(duì)所有操作請(qǐng)求都進(jìn)行重試,如果是get則可以,如果是post、put有重復(fù)提交的危險(xiǎn),建議設(shè)置為false
ConnectTimeout: #請(qǐng)求連接的超時(shí)時(shí)間
ReadTimeout: #請(qǐng)求處理的超時(shí)時(shí)間
（3）定義RestTemplate
@Bean
@LoadBalanced //使用該注解表示實(shí)現(xiàn)客戶(hù)端負(fù)載均衡
public RestTemplate restTemplate(){
return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
}
(4)啟動(dòng)兩各Producer工程，注意端口不同，注冊(cè)到Eureka中
(5)測(cè)試代碼
@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++){
//通過(guò)服務(wù)id調(diào)用
ResponseEntity<User> user= restTemplate.getForEntity("http://"+serviceId+"/user/get/5a754adf6abb500ad05688d9", User.class);
System.out.println(JSONObject.toJSONString(user));
}
}
}
2、客戶(hù)端負(fù)載均衡實(shí)現(xiàn)原理
（1）區(qū)別服務(wù)端負(fù)載均衡和客戶(hù)端負(fù)載均衡
向Nginx 、F5 等在請(qǐng)求發(fā)出之后，被負(fù)載均衡服務(wù)器攔截再分發(fā)到具體服務(wù)的方式是服務(wù)端負(fù)載均衡,而Ribbon是客戶(hù)端先從Eureka Server獲取服務(wù)列表，自己維護(hù)服務(wù)列表，根據(jù)負(fù)載均衡算法直接請(qǐng)求資源服務(wù)器的方式叫服務(wù)端負(fù)載均衡
（2）Ribbon 實(shí)現(xiàn)客戶(hù)端負(fù)載均衡細(xì)節(jié)
在定義RestTempalte時(shí)加@LoadBalanced注解后、restTemplate會(huì)走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使用及其客户端负载均衡实现原理分析的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 医学影像中用 python 读取 nrr
- 下一篇： Pytorch中DataLoader类