{"id":50712,"date":"2025-08-10T11:39:09","date_gmt":"2025-08-10T03:39:09","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/50712.html"},"modified":"2025-08-10T11:39:09","modified_gmt":"2025-08-10T03:39:09","slug":"ribbon%e8%b4%9f%e8%bd%bd%e5%9d%87%e8%a1%a1","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/50712.html","title":{"rendered":"Ribbon\u8d1f\u8f7d\u5747\u8861"},"content":{"rendered":"

\u76ee\u5f55<\/p>\n

\u4e00\u3001\u8d1f\u8f7d\u5747\u8861\u5b9e\u73b0\u903b\u8f91<\/p>\n

\u4e8c\u3001\u8d1f\u8f7d\u5747\u8861\u7b56\u7565<\/p>\n

\u4e09\u3001\u4fee\u6539\u8d1f\u8f7d\u5747\u8861\u89c4\u5219<\/p>\n

\u00a0\u56db\u3001\u9965\u997f\u52a0\u8f7d<\/p>\n

\n

\u6ce8：Ribbon\u62e6\u622aEureka\u8bf7\u6c42，\u627eeureka-server\u62ff\u5bf9\u5e94\u670d\u52a1\u4fe1\u606f,\u6839\u636e\u5bf9\u5e94\u7b56\u7565\u8fd4\u56de\u8c03\u7528\u7684ip\u548c\u7aef\u53e3\u3002<\/p>\n

\u4e00\u3001\u8d1f\u8f7d\u5747\u8861\u5b9e\u73b0\u903b\u8f91<\/h5>\n

1\u3001\u903b\u8f91\u56fe<\/p>\n

\"\"<\/p>\n

2\u3001ClientHttpRequestInterceptor\u63a5\u53e3：\u5ba2\u6237\u7aefhttp\u8bf7\u6c42\u62e6\u622a<\/p>\n

3\u3001LoadBalancerInterceptor\u7c7b\u5b9e\u73b0\u4e0a\u9762\u63a5\u53e3\u00a0<\/p>\n

\/\/\u8be5\u65b9\u6cd5\u62e6\u622ahttp\u8bf7\u6c42
\n@Override
\npublic ClientHttpResponse intercept(final HttpRequest request,final byte[] body,final ClientHttpRequestExecution execution){
\n\/\/\u5f97\u5230\u8bf7\u6c42\u5730\u5740：http:\/\/user-service\/user\/1
\nfinal URI originalUri = request.getURI();<\/p>\n

\/\/\u5f97\u5230\u670d\u52a1\u540duser-service
\nString serciceName=originalUri.getHost();<\/p>\n

\/\/RibbonLoadBalancerClient loadBalancer \u8fdb\u5165\u8d1f\u8f7d\u5747\u8861\u5ba2\u6237\u7aef
\nreturn this.loadBalancer.execute(serviceName,this.requestFactory.createRequest(request,body,execution));
\n} <\/p>\n

4\u3001RibbonLoadBalancerClient\u7c7b<\/p>\n

public <T> T execute(String serviceId,LoadBalancerRequest<T> request,Object hint) throws IOException{
\n\/\/\u6839\u636e\u670d\u52a1\u540d\u62ff\u5230\u670d\u52a1\u4fe1\u606f DynamicServerListLoadBalancer \u52a8\u6001\u670d\u52a1\u5217\u8868\u8d1f\u8f7d\u5747\u8861\u5668
\nILoadBalancer loadBalancer=getLoadBalancer(serviceId);<\/p>\n

\/\/\u6839\u636e\u6307\u5b9a\u7b56\u7565\u83b7\u53d6\u5177\u4f53\u670d\u52a1IP\u7aef\u53e3
\nServer server=getServer(loadBalancer,hint);
\nif(server==null){
\n throw new IllegalStateException("No instances available for"+serviceId);
\n}
\n RibbonServer ribbonServer=new RibbonServer(serviceId,server,isSecure(server,serviceId),serverIntrospector(serviceId).getMetadata(server));
\n return execute(serviceId,ribbonServer,request);
\n}<\/p>\n

protected Server getServer(ILoadBalancer loadBalancer,Object hint){
\nif(loadBalancer==null){
\nreturn null;
\n}
\nreturn loadBalancer.chooseServer(hint!=null?hint:"default");
\n} <\/p>\n

5\u3001ZoneAwareLoadBalancer\u7c7b<\/p>\n

@Override
\npublic Server chooseServer(Object key){
\nif(!ENABLED.get()||getLoadBalancerStats().getAvailableZones().size()<=1){
\nlogger.debug("Zone aware logic disabled or there is only one zone");
\nreturn super.chooseServer(key);
\n}<\/p>\n

Server server=null;
\ntry{
\nLoadBalancerStats lbStats=getLoadBalancerStats();<\/p>\n

}
\n} <\/p>\n

\u00a06\u3001BaseLoadBalancer\u7c7b<\/p>\n

public Server chooseServer(Object key){
\nif(counter==null){
\ncounter=createCounter();
\n}
\ncounter.increment();
\nif(rule==null){
\nreturn null;
\n}else{
\ntry{
\n\/\/\u8c03\u7528IRule\u89c4\u5219\u7684\u5b9e\u73b0\u7c7b\u5f97\u5230ip\u7aef\u53e3
\nreturn rule.choose(key);
\n}catch(Exception e){
\nlogger.warn("LoadBalancer [{}]: Error choosing server for key {}",name,key,e);
\nreturn null;
\n}
\n}
\n} <\/p>\n

\u4e8c\u3001\u8d1f\u8f7d\u5747\u8861\u7b56\u7565<\/h5>\n

Ribbon\u7684\u8d1f\u8f7d\u5747\u8861\u89c4\u5219\u662f\u4e00\u4e2a\u53eb\u505aIRule\u7684\u63a5\u53e3\u6765\u5b9a\u4e49\u7684，\u6bcf\u4e00\u4e2a\u63a5\u53e3\u90fd\u662f\u4e00\u79cd\u89c4\u5219\u3002 <\/p>\n

1\u3001IRule\u5c42\u7ea7(Eureka\u7684\u5b9e\u73b0\u7c7b)<\/p>\n

– AbstractLoadBalancerRule：\u7b56\u7565\u62bd\u8c61\u7c7b
\n1. RetryRule：\u91cd\u8bd5，\u91cd\u8bd5\u673a\u5236\u7684\u9009\u62e9\u903b\u8f91\u3002
\n2. ClientConfigEnabledRoundRobinRule：
\n– BestAvailableRule：\u6700\u4f4e\u5e76\u53d1，\u5ffd\u7565\u54ea\u4e9b\u77ed\u8def\u7684\u670d\u52a1\u5668，\u5e76\u9009\u62e9\u5e76\u53d1\u6570\u8f83\u4f4e\u7684\u670d\u52a1\u5668\u3002
\n– PredicateBasedRule：
\n– AvailabilityFilteringRule：\u53ef\u7528\u8fc7\u6ee4，[[#AvailabilityFilteringRule\u4f5c\u7528]]
\n– ZoneAvoidanceRule：\u533a\u57df\u6743\u91cd，[[#ZoneAvoidanceRule\u4f5c\u7528]]
\n3. RoundRobinRule：\u8f6e\u8be2，\u7b80\u5355\u8f6e\u8be2\u670d\u52a1\u5217\u8868\u6765\u9009\u62e9\u670d\u52a1\u5668\u3002\u5b83\u662fRibbon\u9ed8\u8ba4\u7684\u8d1f\u8f7d\u5747\u8861\u89c4\u5219\u3002
\n– WeightedResponseTimeRule：[[#WeightedResponseTimeRule\u4f5c\u7528]]
\n4. RandomRule：\u968f\u673a，\u968f\u673a\u9009\u62e9\u4e00\u4e2a\u53ef\u7528\u7684\u670d\u52a1\u5668\u3002 <\/p>\n

2\u3001AvailabilityFilteringRule\u4f5c\u7528<\/p>\n

\u5bf9\u4ee5\u4e0b\u4e24\u79cd\u670d\u52a1\u5668\u8fdb\u884c\u5ffd\u7565：<\/p>\n