springcloud学习（二）之Ribbon

心已赠人 2023-01-02 05:26 96阅读 0赞

## Ribbon介绍 ##

Ribbon是Netflix发布的负载均衡器。 Eureka⼀般配合Ribbon进⾏使⽤， Ribbon利⽤从Eureka中读取到服务信息，在调⽤服务提供者提供的服务时，会根据⼀定的算法进⾏负载。  
Ribbon属于客户端负载均衡。

### 负载均衡 ###

负载均衡分为**客户端负载均衡**和**服务器端负载均衡**。

![fba45e177bebdb7e1e98b3cf04b756b3.png][]

所谓**服务器端负载均衡**，⽐如Nginx、 F5这些，请求到达服务器之后由这些负载均衡器根据⼀定的算法将请求路由到⽬标服务器处理。

所谓**客户端负载均衡**，⽐如我们要说的Ribbon，服务消费者客户端会有⼀个服务器地址列表，调⽤⽅在请求前通过⼀定的负载均衡算法选择⼀个服务器进⾏访问，负载均衡算法的执⾏是在请求客户端进⾏。

### Ribbon的使用 ###

不需要引⼊额外的Jar坐标，因为在服务消费者中我们引⼊过eureka-client，它会引⼊Ribbon相关Jar

![9dcf2d0f109b92bb7e84b453ce656a1d.png][]

使用方式：在注入RestTemplate的配置类上加上@LoadBalanced注解即可。

@SpringBootApplication
    @EnableDiscoveryClient
    public class AutoDeliverApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(AutoDeliverApplication.class, args);
        }
        /** * 注⼊RestTemplate * @return */
        @Bean
        @LoadBalanced
        public RestTemplate getRestTemplate() { 
            return new RestTemplate();
        }
    }

为了区分调用不同的服务提供者，我们将服务提供者的代码稍作修改：

@RestController
    @RequestMapping("/resume")
    public class ResumeController { 
        @Autowired
        private ResumeService resumeService;
        @Value("${server.port}")
        private Integer port;
        
        @GetMapping("/openstate/{userId}")
        public Integer findDefaultResumeState(@PathVariable Long userId) { 
            return port;
        }
    }

在服务提供者中获取各自的端口号（在application.yml中配置的），通过服务消费者的调用我们就能够看出调的哪个服务提供者。  
测试结果如下：

![0b2cdeb7e94b7a9d0303b71210d20e6b.gif][]

### 修改负载均衡策略 ###

在服务消费者的配置文件中添加负载均衡策略：

#针对的被调⽤⽅微服务名称,不加就是全局⽣效
    lagou-service-resume:
      ribbon:
        NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #负载策略调整

<table> 
 <thead> 
  <tr> 
   <th>负载均衡策略</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>RoundRobinRule：轮询策略</td> 
   <td>默认超过10次获取到的server都不可⽤，会返回⼀个空的server</td> 
  </tr> 
  <tr> 
   <td>RandomRule：随机策略</td> 
   <td>如果随机到的server为null或者不可⽤的话，会while不停的循环选取</td> 
  </tr> 
  <tr> 
   <td>RetryRule：重试策略</td> 
   <td>⼀定时限内循环重试。默认继承RoundRobinRule，也⽀持⾃定义注⼊， RetryRule会在每次选取之后，对选举的server进⾏判断，是否为null，是否alive，并且在500ms内会不停的选取判断。⽽RoundRobinRule失效的策略是超过10次， RandomRule是没有失效时间的概念，只要serverList没都挂。</td> 
  </tr> 
  <tr> 
   <td>BestAvailableRule：最⼩连接数策略</td> 
   <td>遍历serverList，选取出可⽤的且连接数最⼩的⼀个server。该算法⾥⾯有⼀个LoadBalancerStats的成员变量，会存储所有server的运⾏状况和连接数。如果选取到的server为null，那么会调⽤RoundRobinRule重新选取。</td> 
  </tr> 
  <tr> 
   <td>AvailabilityFilteringRule：可⽤过滤策略</td> 
   <td>扩展了轮询策略，会先通过默认的轮询选取⼀个server，再去判断该server是否超时可⽤，当前连接数是否超限，都成功再返回。</td> 
  </tr> 
  <tr> 
   <td>ZoneAvoidanceRule：区域权衡策略（<strong>默认策略</strong>）</td> 
   <td>扩展了轮询策略，继承了2个过滤器： ZoneAvoidancePredicate和AvailabilityPredicate，除了过滤超时和链接数过多的server，还会过滤掉不符合要求的zone区域⾥⾯的所有节点， AWS --ZONE <strong>在⼀个区域/机房内的服务实例中轮询</strong></td> 
  </tr> 
 </tbody> 
</table>

### 源码剖析 ###

负载均衡策略的顶级接口是IRule，

![abc01dec409200742678f5dd9e7334b6.png][]

每个负载均衡策略调用的实现类都会实现其中的choose方法

![4f33097cd1362f8a802a807609c77089.png][]

ribbon使用demo地址：[ribbon使用demo][ribbon_demo]

欢迎访问我的博客：[https://www.liuyj.top][https_www.liuyj.top]

[fba45e177bebdb7e1e98b3cf04b756b3.png]: /images/20221120/34cb90a97288413e877234e6e5698755.png
[9dcf2d0f109b92bb7e84b453ce656a1d.png]: /images/20221120/9d461b0cb4874c7786aa2e2cf1ab581d.png
[0b2cdeb7e94b7a9d0303b71210d20e6b.gif]: /images/20221120/52d8ec9bf18842fa8f54836f7ce871be.png
[abc01dec409200742678f5dd9e7334b6.png]: /images/20221120/591a1aab7ba444a9baf289e50ddabebe.png
[4f33097cd1362f8a802a807609c77089.png]: /images/20221120/235a4264d38e4f81a6e7621289446195.png
[ribbon_demo]: https://gitee.com/mikecn/ribbon-demo
[https_www.liuyj.top]: https://www.liuyj.top