淮安市哪里可以做网站,西安旅游景点排名前十名,wordpress 页面加载时间 查询次数_和内存,东莞做网站推广Ribbon介绍
Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具
Ribbon是Netflix发布的开源项目#xff0c;主要功能是提供客户端的软件负载均衡算法和服务调用。Ribbon客户端组件提供一系列完善的配置项如连接超时、重试等。简单的说#xff0c;就是…Ribbon介绍
Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具
Ribbon是Netflix发布的开源项目主要功能是提供客户端的软件负载均衡算法和服务调用。Ribbon客户端组件提供一系列完善的配置项如连接超时、重试等。简单的说就是在配置文件中列出Load Balance简称LB后面所有的机器Ribbon会自动的帮组你基于某种规则如简单轮询随机连接等去连接这些机器我们很容易使用Ribbon实现自定义的负载均衡算法
LB负载均衡Load Balance
**** 简单的说就是将用户的请求平摊到分配到多个服务上从而达到系统的HA高可用。
常见的负载均衡有软件Nginx、LVS、硬件FS等
Ribbon本地负载均衡客户端 VS Nginx服务端负载均衡区别
Nginx是服务器负载均衡客户端所有请求都会教给Nginx然后由nginx实现转发请求即负载均衡是由服务端实现的
Ribbon本地负载均衡在调用微服务接口时候会在注册中心上获取注册信息服务列表之后缓存到JVM本地从而本地实现RPC远程调用技术
官网https://github.com/Netflix/ribbon
Ribbon使用
1、搭建项目、参考【SpringCloud】服务提供者集群与服务发现Discovery三 的示例
采用Eureka作为注册中心且有2个服务提供者
架构如下 2、Ribbon依赖依赖如下 1 dependency
2 groupIdorg.springframework.cloud/groupId
3 artifactIdspring-cloud-starter-netflix-ribbon/artifactId
4 version2.2.2.RELEASE/version
5 scopecompile/scope
6 /dependency通过查看示例项目调用者order项目依赖发现在Eureka依赖中默认含有依赖Ribbon的依赖 3、查看RibbonClientConfiguration.javaRibbon自动装载类。 1 Configuration(proxyBeanMethods false)2 EnableConfigurationProperties3 Import({ HttpClientConfiguration.class, OkHttpRibbonConfiguration.class,4 RestClientRibbonConfiguration.class, HttpClientRibbonConfiguration.class })5 public class RibbonClientConfiguration {6 7 ...8 9 // 自动注入IRule接口用来代表负责负载均衡的策略
10 Bean
11 ConditionalOnMissingBean
12 public IRule ribbonRule(IClientConfig config) {
13 if (this.propertiesFactory.isSet(IRule.class, name)) {
14 return this.propertiesFactory.get(IRule.class, config, name);
15 }
16 ZoneAvoidanceRule rule new ZoneAvoidanceRule();
17 rule.initWithNiwsConfig(config);
18 return rule;
19 }
20
21 // 自动注入ILoadBalance接口用来代表负责均衡的操作
22 Bean
23 ConditionalOnMissingBean
24 public ILoadBalancer ribbonLoadBalancer(IClientConfig config,
25 ServerListServer serverList, ServerListFilterServer serverListFilter,
26 IRule rule, IPing ping, ServerListUpdater serverListUpdater) {
27 if (this.propertiesFactory.isSet(ILoadBalancer.class, name)) {
28 return this.propertiesFactory.get(ILoadBalancer.class, config, name);
29 }
30 return new ZoneAwareLoadBalancer(config, rule, ping, serverList,
31 serverListFilter, serverListUpdater);
32 }
33
34 ...
35 }其中自动注入IRule接口用来代表负责负载均衡的策略默认策略ZoneAvoidanceRule和自动注入ILoadBalance接口用来代表负责均衡的操作默认均衡ZoneAwareLoadBalancer
4、查看ILoadBalance接口负责均衡的操作
继承关系如下 内容如下 1 public interface ILoadBalancer {2 3 public void addServers(ListServer newServers);4 5 // 根据key选择一个服务6 public Server chooseServer(Object key);7 8 public void markServerDown(Server server);9
10 public ListServer getServerList(boolean availableOnly);
11
12 public ListServer getReachableServers();
13
14 public ListServer getAllServers();
15 }5、查看IRule接口负责均衡的策略
实现关系 内容如下
1 public interface IRule{
2
3 // 根据key选择一个服务
4 public Server choose(Object key);
5
6 public void setLoadBalancer(ILoadBalancer lb);
7
8 public ILoadBalancer getLoadBalancer();
9 }通过查看实例类可以看到具体的实现了可以知道负责均衡的策略
6、Ribbon工作原理
查看LoadBalancerAutoConfiguration自动配置类 1 Configuration(proxyBeanMethods false)2 ConditionalOnClass(RestTemplate.class)3 ConditionalOnBean(LoadBalancerClient.class)4 EnableConfigurationProperties(LoadBalancerRetryProperties.class)5 public class LoadBalancerAutoConfiguration {6 7 8 ...9
10
11 Configuration(proxyBeanMethods false)
12 ConditionalOnClass(RetryTemplate.class)
13 public static class RetryInterceptorAutoConfiguration {
14
15 Bean
16 ConditionalOnMissingBean
17 public RetryLoadBalancerInterceptor ribbonInterceptor(
18 LoadBalancerClient loadBalancerClient,
19 LoadBalancerRetryProperties properties,
20 LoadBalancerRequestFactory requestFactory,
21 LoadBalancedRetryFactory loadBalancedRetryFactory) {
22 return new RetryLoadBalancerInterceptor(loadBalancerClient, properties,
23 requestFactory, loadBalancedRetryFactory);
24 }
25
26 // RestTemplate定制器
27 Bean
28 ConditionalOnMissingBean
29 public RestTemplateCustomizer restTemplateCustomizer(
30 final RetryLoadBalancerInterceptor loadBalancerInterceptor) {
31 return restTemplate - {
32 ListClientHttpRequestInterceptor list new ArrayList(
33 restTemplate.getInterceptors());
34 list.add(loadBalancerInterceptor);
35 // 给restTemplate设置拦截器
36 restTemplate.setInterceptors(list);
37 };
38 }
39
40 }
41
42 }其中自动配置了一个LoadBalancerInterceptorLoadBalancerInterceptor是个ClientHttpRequestInterceptor客户端请求拦截器。它的作用是在客户端发起请求之前拦截进而实现客户端的负载均衡。
以下是RestTemplate注入加LoadBalanced的配置方法 1 Configuration2 public class AppConfig {3 4 /**5 * 注入restTemplate请用请求rest接口6 * return7 */8 Bean9 // 标注此注解后RestTemplate就具有了客户端负载均衡能力
10 // 负载均衡技术依赖于的是Ribbon组件~
11 // RestTemplate都塞入一个loadBalancerInterceptor 让其具备有负载均衡的能力
12 LoadBalanced
13 public RestTemplate restTemplate(){
14 return new RestTemplate();
15 }
16 }7、测试Ribbon是否根据对于的负责均衡的策略实现负载
1调试模式启动项目使用地址http://localhost:8000/consumer/payment/get/1进行访问
返回内容为提供者2个节点分别交替返回的到达负载均衡目的。
2在ZoneAvoidanceRule类中添加断点通过运行程序可以看到程序会运行到ZoneAvoidanceRule类中。
自带负载均衡规则说明
策略名策略声明策略描述实现说明BestAvailableRulepublic class BestAvailableRule extends ClientConfigEnabledRoundRobinRule选择一个最小的并发请求的server逐个考察Server如果Server被tripped了则忽略在选择其中ActiveRequestsCount最小的serverAvailabilityFilteringRulepublic class AvailabilityFilteringRule extends PredicateBasedRule过滤掉那些因为一直连接失败的被标记为circuit tripped的后端server并过滤掉那些高并发的的后端serveractive connections 超过配置的阈值使用一个AvailabilityPredicate来包含过滤server的逻辑其实就就是检查status里记录的各个server的运行状态WeightedResponseTimeRulepublic class WeightedResponseTimeRule extends RoundRobinRule根据相应时间分配一个weight相应时间越长weight越小被选中的可能性越低。一个后台线程定期的从status里面读取评价响应时间为每个server计算一个weight。Weight的计算也比较简单responsetime 减去每个server自己平均的responsetime是server的权重。当刚开始运行没有形成statas时使用roubine策略选择server。RetryRulepublic class RetryRule extends AbstractLoadBalancerRule对选定的负载均衡策略机上重试机制。在一个配置时间段内当选择server不成功则一直尝试使用subRule的方式选择一个可用的serverRoundRobinRulepublic class RoundRobinRule extends AbstractLoadBalancerRuleroundRobin方式轮询选择server轮询index选择index对应位置的serverRandomRulepublic class RandomRule extends AbstractLoadBalancerRule随机选择一个server在index上随机选择index对应位置的serverZoneAvoidanceRulepublic class ZoneAvoidanceRule extends PredicateBasedRule复合判断server所在区域的性能和server的可用性选择server使用ZoneAvoidancePredicate和AvailabilityPredicate来判断是否选择某个server前一个判断判定一个zone的运行性能是否可用剔除不可用的zone的所有serverAvailabilityPredicate用于过滤掉连接数过多的Server。
