1:Ribbon是什么

Ribbon是一个开源的客户端负载均衡器,由Netflix公布,是SpringCloud-Netflix中重要的一环,通过它将Netflix的中间层服务连贯在一起。
Ribbon客户端组件提供一系列欠缺的配置项,如连贯超时、重试等。简略的说,就是在配置文件中列出Load Balancer前面所有的服务,Ribbon会主动的基于某种规定(如简略轮询,随机连贯等)去连贯这些服务,也很容易实现自定义的负载平衡算法。

2:Ribbon能干什么

Ribbon是在客户端来实现负载平衡的拜访服务,次要的性能点:
1:服务发现,发现依赖服务的列表
2:服务抉择规定,在多个服务中如何抉择一个无效服务
3:服务监听,检测生效的服务,高效剔除生效服务

3:架构图

4:集成

  • 退出依赖
<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-ribbon</artifactId></dependency>

先不要加Eureka的starter
官网的HelloWorld
具体示例参看:
https://github.com/Netflix/ri...

5:参数配置

5.1:概述

对于Ribbon参数的key以及value类型的定义,能够通过com.netflix.client.config.CommonClientConfigKey查看
如果你没有配置任何属性,则ribbon会应用com.netflix.client.config.DefaultClientConfigImpl里的值

5.2:配置形式

Ribbon的参数配置通常有二种形式:全局配置以及指定客户端配置

  • 全局配置的形式很简略只须要应用ribbon.<key>=<value>格局进行配置即可。

其中,<key>代表了Ribbon客户端配置的参数名,<value>则代表了对应参数的值。
比方,能够向上面这样配置Ribbon的超时工夫:
ribbon.ConnectTimeout=250
全局配置能够作为默认值进行设置,当指定客户端配置了相应的key的值时,将笼罩全局配置的内容

  • 指定客户端的配置形式

<client>.ribbon.<key>=<value>的格局进行配置
<client>示意服务名,比方没有服务治理框架的时候(如Eureka),须要指定实例清单,如:userService.ribbon.listOfServers=localhost:8080

6:外围组件

6.1:Ribbon外围组件

  • IRule:依据特定算法中从服务列表中选取一个要拜访的服务
  • IPing:后盾运行线程,用来判断服务是否可用
  • ServerList: 服务列表,能够是动态的或动静的。如果它是动静的,后盾线程将刷新并按肯定的工夫距离过滤列表

还有:

  • ServerListFilter:该接口容许过滤配置或动静获取的具备所需个性的服务器列表
  • ServerListUpdater:被DynamicServerListLoadBalancer用于动静的更新服务列表
  • IClientConfig:定义各种配置信息,用来初始化ribbon客户端和负载均衡器
  • ILoadBalancer:定义软件负载平衡器操作的接口。动静更新一组服务列表及依据指定算法从现有服务器列表中抉择一个服务

6.2:配置

这些组件能够以编程形式设置,也能够是客户端配置属性的一部分,并通过反射创立。
反对的属性如下所示,应以<clientName>.ribbon.为前缀:

  • NFLoadBalancerClassName:要应用的ILoadBalancer
  • NFLoadBalancerRuleClassName:要应用的Irule
  • NFLoadBalancerPingClassName:要应用的Iping
  • NIWSServerListClassName:要应用的ServerList
  • NIWSServerListFilterClassName:要应用的ServerListFilter

6.3:IRule,罕用实现有以下几种:

都在com.netflix.loadbalancer包上面

1:RoundRobinRule:轮询规定
2:RandomRule:随机获取一个服务
3:AvailabilityFilteringRule 
这个负载均衡器规定,会先过滤掉因为屡次拜访故障而处于断路器跳闸状态的服务,还有并发的连贯数量超过阈值的服务,而后对残余的服务列表依照轮询策略进行拜访
4:WeightedResponseTimeRule  依据均匀响应工夫计算所有服务的权重,响应工夫越快,服务权重越大、被选中的概率越高。刚启动时,如果统计信息有余,则应用RoundRobinRule策略,等统计信息足够,会切换到WeightedResponseTimeRule。
5:RetryRule 先依照RoundRobinRule的策略获取服务,如果获取服务失败,则在指定工夫内会进行重试,获取可用的服务
6:BestAvailableRule 此负载均衡器会先过滤掉因为屡次拜访故障而处于断路器跳闸状态的服务,而后抉择一个并发量最小的服务
7:ZoneAvoidanceRule:默认规定,复合判断server所在区域的性能和server的可用性抉择server

6.4:IPing,罕用实现有以下几种:

都在com.netflix.loadbalancer包上面
1:DummyPing:默认实现,默认返回true,即认为服务永远活着
2:NIWSDiscoveryPing  不执行真正的ping。如果Discovery Client认为是在线,则程序认为本次心跳胜利,服务活着
3:PingUrl  此组件会应用HttpClient调用服务的一个URL,如果调用胜利,则认为本次心跳胜利,示意此服务活着。
4:NoOpPing:永远返回true,即认为服务永远活着
ServerList,罕用实现有以下几种:
都在com.netflix.loadbalancer包上面
1:ConfigurationBasedServerList,从配置文件中获取所有服务列表,也是动态获取服务列表,配置例子:sample-client.ribbon.listOfServers=
2:DiscoveryEnabledNIWSServerList 
从Eureka Client中获取服务列表。此值必须通过属性中的VipAddress来标识服务器集群。DynamicServerListLoadBalancer会调用此对象动静获取服务列表
3:DomainExtractingServerList:代理类,依据ServerList的值实现具体的逻辑

7: 联合Eureka

在SpringCloud中应用的HelloWorld

  • 先退出依赖:
<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-eureka</artifactId></dependency><dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-web</artifactId></dependency>

能够不必退出Ribbon依赖,因为Eureka的starter外面蕴含了ribbon

  • 写一个配置类

提供RestTemplate,示例如下:

@Bean@LoadBalancedpublic RestTemplate rt(){    return new RestTemplate();}
  • 写一个Hello2的Controller,在办法外面应用RestTemplate
  • 启动SpringBoot的启动类,而后就能够通过页面进行拜访测试了

8: RestTemplate

  • RestTemplate 是Spring提供的用于拜访Rest服务的客户端,RestTemplate提供了多种便捷拜访近程Http服务的办法,可能大大提高客户端的编写效率。
  • @LoadBalanced示意restTemplate应用LoadBalancerClient执行申请,会主动应用负载平衡策略,它外部会在RestTemplate中退出LoadBalancerInterceptor这个拦截器,这个拦截器的作用就是应用负载平衡。这样在拜访近程服务的时候,能够间接应用Provider向Eureka Server注册的虚构名字,如:

rt.getForObject("http://userService/userServiceProvider?name=cc", String.class);

  • 当Eureka与Ribbon联合应用(即两者都在类门路上)时,ribbonServerList将被扩大为DiscoveryEnabledNIWSServerList,扩大名为Eureka的服务器列表。它还用NIWSDiscoveryPing替换IPing接口,代理到Eureka以确定服务器是否启动。
  • 能够通过代码来进行配置,比方配置IRule、IPing等
  • 设置属性ribbon.eureka.enabled = false将明确禁用在Ribbon中应用Eureka

9:ServerListFilter

罕用实现有以下几种:
都在com.netflix.loadbalancer包上面

  • ZoneAffinityServerListFilter  过滤掉所有的不和客户端在雷同zone的服务,如果和客户端雷同的zone不存在,才不过滤不同zone有服务。启用此配置应用以下配置

<clientName>.ribbon.EnableZoneAffinity=true

  • ServerListSubsetFilter  ZoneAffinityServerListFilter的子类。此过滤器确保客户端仅看到由ServerList实现返回的整个服务器的固定子集。 它还能够定期用新服务器代替可用性差的子集中的服务器。要启用此过滤器,请指定以下属性:
myClient.ribbon.NIWSServerListClassName=com.netflix.niws.loadbalancer.DiscoveryEnabledNIWSServerList # the server must register itself with Eureka server with VipAddress "myservice"myClient.ribbon.DeploymentContextBasedVipAddresses=myservicemyClient.ribbon.NIWSServerListFilterClassName=com.netflix.loadbalancer.ServerListSubsetFilter# only show client 5 servers. default is 20.myClient.ribbon.ServerListSubsetFilter.size=5

10:ServerListUpdater

ServerListUpdater,罕用实现有以下几种:
都在com.netflix.loadbalancer包上面

  • PollingServerListUpdater 默认的实现策略。此对象会启动一个定时线程池,定时执行更新策略
  • EurekaNotificationServerListUpdater 当收到缓存刷新的告诉,会更新服务列表。

11:IClientConfig

罕用实现有以下几种:
com.netflix.client.config.DefaultClientConfigImpl IClientConfig的默认实现

12:ILoadBalancer

罕用实现有以下几种:
都在com.netflix.loadbalancer包上面

  • DynamicServerListLoadBalancer DynamicServerListLoadBalancer组合Rule、IPing、ServerList、ServerListFilter、ServerListUpdater 实现类,实现动静更新和过滤更新服务列表
  • ZoneAwareLoadBalancer  这是DynamicServerListLoadBalancer的子类,次要退出zone的因素。统计每个zone的均匀申请的状况,保障从所有zone选取对以后客户端服务最好的服务组列表

13:重试机制

SpringCloud通过整合Spring retry来加强RestTemplate的重试能力,对于开发者来说,只须要简略配置,即可实现重试策略,配置示例如下:
//该参数用来开启重试机制,它默认是敞开的

spring.cloud.loadbalancer.retry.enabled=true //断路器的超时工夫须要大于Ribbon的超时工夫,不然不会触发重试hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=10000 //申请连贯超时工夫userService.ribbon.ConnectTimeout=250 //申请解决的超时工夫userService.ribbon.ReadTimeout=1000 //对所有操作申请都进行重试userService.ribbon.OkToRetryOnAllOperations=true //切换实例的重试次数userService.ribbon.MaxAutoRetriesNextServer=2 //对以后实例的重试次数userService.ribbon.maxAutoRetries=1

14:@RibbonClient

注解@RibbonClient,这样做的目标是为了在启动该微服务的时候就能去加载咱们的自定义Ribbon配置类,从而使配置失效,形如:
@RibbonClient(name="userService",configuration=MyConf2.class)

  • 这个userService不是轻易写的,而是注册到Eureka发现组件上的微服务服务端,意思是要对所有工程名为userService的服务提供者进行负载平衡治理
  • 官网文档明确给出了正告:这个测试配置类MyConf2不能放在@ComponentScan所扫描的以后包下以及子包下,否则咱们自定义的这个配置类就会被所有的Ribbon客户端所共享,也就是说咱们达不到特殊化定制的目标了。