springcloud之Ribbon负载均衡源码探究深入浅出

向右看齐 2022-11-06 02:59 22阅读 0赞

# Ribbon负载均衡深入浅出 #

### 文章目录 ###

*  Ribbon负载均衡深入浅出
 *   *  一、Ribbon负载均衡
     *  二、Ribbon负载均衡过程
     *  三、Ribbonn关键轮训算法
     *  四、Ribbon支持的负载均衡策略介绍

## 一、Ribbon负载均衡 ##

什么是Ribbon Ribbon是一个客户端负载均衡工具，通过Spring Cloud封装

注解： @LoadBalanced 标识ribbon负载均衡

/** * 负载均衡调用 * @return */
        @LoadBalanced
        @Bean
        public RestTemplate restTemplate() { 
            return new RestTemplate();
        }
    
    // 使用
     Object forObject = restTemplate.getForObject("http://被调用的服务名/api/v1/order/getProduct", Object.class);

从端的角度负载均衡有两种

服务端负载均衡  
客户端负载均衡  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70]

## 二、Ribbon负载均衡过程 ##

进入注解 @LoadBalanced 查看源码：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 1]

负载均衡策略请求来之后进入到 excute 方法

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 2]

**RibbonLoadBalancerClient** implements LoadBalancerClient

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 3]

默认 DynamicServerListLoadBalancer

![在这里插入图片描述][20210307193244938.png]

DynamicServerListLoadBalancer exteds BaseLoadBalancer

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 4]

**RibbonLoadBalancerClient** 的 getServer 方法

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 5]

这里调用 DynamicServerListLoadBalancer 的 chooseServer 方法，发现 DynamicServerListLoadBalancer 没有 chooseServer 方法，则查找其父类 BaseLoadBalancer

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 6]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 7]

## 三、Ribbonn关键轮训算法 ##

public Optional<Server> chooseRoundRobinAfterFiltering(List<Server> servers, Object loadBalancerKey) { 
            // 这的服务信息，将有配置中心获取，所用的配置中心是Nacos
            List<Server> eligible = getEligibleServers(servers, loadBalancerKey);
            if (eligible.size() == 0) { 
                return Optional.absent();
            }
        	// 根据下标获取服务【下标就是通过轮训算法算出来的】
            return Optional.of(eligible.get(incrementAndGetModulo(eligible.size())));
    }
    
    // 关键轮训算法
    private final AtomicInteger nextIndex = new AtomicInteger();
     
    // modulo 为在注册中 注册的被调用服务的这个服务实例数
    private int incrementAndGetModulo(int modulo) { 
            for (;;) { 
                int current = nextIndex.get();
                int next = (current + 1) % modulo;
                if (nextIndex.compareAndSet(current, next) && current < modulo)
                    return current;
            }
        }

## 四、Ribbon支持的负载均衡策略介绍 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 8]

<table> 
 <thead> 
  <tr> 
   <th>策略类</th> 
   <th>命名</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>RandomRule</td> 
   <td>随机策略</td> 
   <td>随机选择server</td> 
  </tr> 
  <tr> 
   <td>RoundRobinRule</td> 
   <td>轮询策略</td> 
   <td>按照顺序选择server（默认）</td> 
  </tr> 
  <tr> 
   <td>RetryRule</td> 
   <td>重试策略</td> 
   <td>当选择server不成功，短期内尝试选择一个可用的server</td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>AvailabilityFilteringRule</td> 
   <td>可用过滤策略</td> 
   <td>过滤掉一直失败并被标记为circuit tripped的server，过滤掉那些高并发链接的server（active connections超过配置的阈值）</td> 
  </tr> 
  <tr> 
   <td>WeightedResponseTimeRule</td> 
   <td>响应时间加权重策略</td> 
   <td>根据server的响应时间分配权重，以响应时间作为权重，响应时间越短的服务器被选中的概率越大，综合了各种因素，比如：网络，磁盘，io等，都直接影响响应时间</td> 
  </tr> 
  <tr> 
   <td>ZoneAvoidanceRule</td> 
   <td>区域权重策略</td> 
   <td>综合判断server所在区域的性能，和server的可用性，轮询选择server</td> 
  </tr> 
 </tbody> 
</table>

**配置文件中自定义选择策略：**

订单服务增加配置
    # 服务名称
    mesmile-video-service:
      ribbon:
      	# 填写 IRule 实现类中负载均衡策略 这里测试 随机负载策略
        NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

**结论-》策略选择：**

1、如果每个机器配置一样，则建议不修改策略 (推荐)  
2、如果部分机器配置强，则可以改为 WeightedResponseTimeRule

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70]: /images/20221023/ce3ff895187646c996da069255254379.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 1]: /images/20221023/a73ebaf107674100a3e9df194154e053.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 2]: /images/20221023/1a2245c616694aa9b47fcf6aa1b1404b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 3]: /images/20221023/0e3c8c217b4a441e96e54aa15c0656c5.png
[20210307193244938.png]: /images/20221023/ab430f91282a49f5af642f59ca0de1c8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 4]: /images/20221023/54a02f9511bb488da56fe429c1d9a3ff.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 5]: /images/20221023/28519050ef524fd9a3ea8689005b26cd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 6]: /images/20221023/bfc591c3b5a4437ab30df6bbcf565f23.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 7]: /images/20221023/127375d375324f3bbdb054179c65dc0c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1cHJlemhlbmc_size_16_color_FFFFFF_t_70 8]: /images/20221023/7b10b196930f40318226e2561be02958.png