Ribbon引入

image.png
eurake客户端自带,或者手动引入
image.png

负载均衡策略修改

ribbon有7种负载均衡策略可供选择:

策略类   命名 描述
RandomRule 随机策略 随机选择server
RoundRobinRule 轮询策略 按照顺序选择server(ribbon默认策略)
RetryRule 重试策略 在一个配置时间段内,当选择server不成功,则一直尝试选择一个可用的server
BestAvailableRule 最低并发策略 逐个考察server,如果server断路器打开,则忽略,再选择其中并发链接最低的server
AvailabilityFilteringRule 可用过滤策略 过滤掉一直失败并被标记为circuit tripped的server,过滤掉那些高并发链接的server(active connections超过配置的阈值)
ResponseTimeWeightedRule 响应时间加权重策略 根据server的响应时间分配权重,响应时间越长,权重越低,被选择到的概率也就越低。响应时间越短,权重越高,被选中的概率越高,这个策略很贴切,综合了各种因素,比如:网络,磁盘,io等,都直接影响响应时间
ZoneAvoidanceRule 区域权重策略 综合判断server所在区域的性能,和server的可用性,轮询选择server并且判断一个AWS Zone的运行性能是否可用,剔除不可用的Zone中的所有server

修改方式

1.全局的负载策略

如果想要创建一个全局的负载策略,只需添加一个配置类,也可自己扩展,添加逻辑,如下:

  1. import org.springframework.beans.factory.annotation.Autowired;
  2. import org.springframework.context.annotation.Bean;
  3. import org.springframework.context.annotation.Configuration;
  4. import com.netflix.client.config.IClientConfig;
  5. import com.netflix.loadbalancer.IRule;
  6. import com.netflix.loadbalancer.RandomRule;
  7. @Configuration
  8. public class RibbonConfiguration {
  9. @Bean
  10. public IRule ribbonRule() {
  11. return new RandomRule();
  12. }
  13. }

**

2.某个服务源设置特有的策略

如果想要对某个服务源设置特有的策略,可以在工程启动类上添加@RibbonClient注解,当然,对应配置代码也需要调整:

  1. /**
  2. * 自定义-标记注解
  3. */
  4. public @interface AvoidScan {
  5. }
  1. import org.springframework.beans.factory.annotation.Autowired;
  2. import org.springframework.context.annotation.Bean;
  3. import org.springframework.context.annotation.Configuration;
  4. import com.netflix.client.config.IClientConfig;
  5. import com.netflix.loadbalancer.IRule;
  6. import com.netflix.loadbalancer.RandomRule;
  7. /**
  8. * Ribbon负载策略配置类,IClientConfig是针对客户端的管理配置器,配合@RibbonClient注解使用
  9. */
  10. @Configuration
  11. @AvoidScan
  12. public class RibbonConfiguration {
  13. @Autowired
  14. private IClientConfig config;
  15. @Bean
  16. public IRule ribbonRule(IClientConfig config) {
  17. return new RandomRule();
  18. }
  19. }

主启动类修改:

  1. import org.springframework.boot.SpringApplication;
  2. import org.springframework.boot.autoconfigure.SpringBootApplication;
  3. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  4. import org.springframework.cloud.netflix.ribbon.RibbonClient;
  5. import org.springframework.cloud.netflix.ribbon.RibbonClients;
  6. import org.springframework.context.annotation.ComponentScan;
  7. import org.springframework.context.annotation.FilterType;
  8. import cn.springcloud.book.config.AvoidScan;
  9. import cn.springcloud.book.config.TestConfiguration;
  10. /**
  11. * 工程启动类
  12. */
  13. @SpringBootApplication
  14. @EnableDiscoveryClient
  15. @RibbonClient(name = "client-a", configuration = RibbonConfiguration.class)//表示针对client-a服务使用的负责策略是经过RibbonConfiguration配置类的。
  16. //@RibbonClients(value = {
  17. // @RibbonClient(name = "client-a", configuration = RibbonConfiguration.class),
  18. // @RibbonClient(name = "client-b", configuration = RibbonConfiguration.class)
  19. //})//这种方式跟@RibbonClient类似,不过这个是针对多个服务进行策略指定。
  20. @ComponentScan(excludeFilters = {@ComponentScan.Filter(type = FilterType.ANNOTATION, value = {AvoidScan.class})})//表示让工程在启动的时候,不让Spring扫描被@AvoidScan注解标记的类,
  21. //因为配置的是针对特殊服务的负载策略,不是全局的,如果不排除,启动就会报错。
  22. public class RibbonLoadbalancerApplication {
  23. public static void main(String[] args) {
  24. SpringApplication.run(RibbonLoadbalancerApplication.class, args);
  25. }
  26. }

3.配置文件方式

如果想使用配置文件的方式,进行配置负责策略,语法是 client name.ribbon.*,client name是我们自己给服务取的名字,即:spring.application.name设置的值。如下:

  1. client-a:
  2. ribbon:
  3. NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #针对client-a服务使用随机策略


ribbon的重试机制,默认是开启的,需要添加超时与重试的策略配置,如下:

client-a:
  ribbon:
    ConnectTimeout: 30000
    ReadTimeout: 60000
    MaxAutoRetries: 1 #对第一次请求的服务的重试次数
    MaxAutoRetriesNextServer: 1 #要重试的下一个服务的最大数量(不包括第一个服务)
    OkToRetryOnAllOperations: true

#说明:这里配置的ConnectTimeout和ReadTimeout是当HTTP客户端使用的是HttpClient才生效,这个时间最终会被设置到HttpClient中。
#在设置的时候需要结合hystrix的超时时间来综合考虑,针对使用的场景,设置太小会导致很多请求失败,设置太大会导致熔断控制变差。

提供了7个核心接口:

接口 简述 默认实现
IClientConfig 定义ribbon中管理配置的接口 DefaultClientConfigImpl
IRule 定义ribbon中负载均衡策略的接口 ZoneAvoidanceRule
IPing 定义定期ping服务,检查可用性的接口 DummyPing
ServerList 定义获取服务列表方法的接口 ConfigurationBasedServerList
ServerListFilter 定义特定场景下,获取服务列表的方法接口 ZonePreferenceServerListFilter
ILoadBalancer 定义负载均衡选择服务的核心方法接口 ZoneAwareLoadBalancer
ServerListUpdater 为DynamicServerListLoadBalancer定义动态更新服务列表的接口 PollingServerListUpdater

轮训算法理论

image.png