对于 Ribbon 来说,有使用过 Spring Cloud 肯定不会陌生,它是服务之间通信的一种方式,通常配合Hystrix一起使用,虽然Hystrix已经成为历史,但是 Ribbon 还在,那么我这边就讲解一下它的使用。
Ribbon是Spring Cloud的一个组件, 它可以让我们使用一个注解就能轻松的搞定负载均衡。
至于什么是负载均衡,说实话我是想详细写一写的,但是通过资料整理后发现,写的又好又详细的大牛有的是,我就不在这班门弄斧了,本篇博客还是写一写它的使用。
首先我们需要将一个消费者两个生产者注册到注册中心Nacos上。ps(两个生产者的服务名称必须相同)
如图: 若此操作有疑虑,请参考上一篇 Nacos 入门案例(一)
在消费端进行以下配置:
@Bean @LoadBalanced public RestTemplate restTemplate() { return new RestTemplate(); }将RestTemplate交给容器管理时,加上注解 @LoadBalanced
紧接着利用消费者调取生产者的服务,由于消费者和生产者都已经将自身的服务发布到了 Nacos 上,所以消费者的内存中会有生产者的服务信息,此时根据生产者的服务名调用即可。
生产者Controller
@Slf4j @RequestMapping("/scz/") @RestController public class TestController { @RequestMapping("testFunction") public String testFunction(String message){ log.info("该请求打印出了:nacos1 "+message+"信息"); return "请求成功"; } }消费者Controller
@Slf4j @RequestMapping("/xfz/") @RestController public class TestController { @Autowired private RestTemplate restTemplate; @RequestMapping("testFunction") public void testFunction(String message){ log.info("消费者控制层的调用"); String forObject = restTemplate.getForObject("http://test-scz/scz/testFunction?message="+message, String.class); } }test-scz 就是生产者的服务名称。
接下来测试:利用 idea 自带 REST Client 进行测试
消费者向生产者发送五次请求。
两位生产者分别接收到了 两次/三次 总共五次请求,证明Ribbon调用成功。
Ribbon默认的负载均衡策略是轮询,但是作为一款好用的组件,负载均衡策略绝不仅限于此。
Ribbon内置了多种负载均衡策略,内部负载均衡的顶级接口为 com.netflix.loadbalancer.IRule
策略名策略描述实现说明BestAvailableRule选择一个最小的并发请求的server逐个考察Server,如果Server被tripped了,则忽略,在选择其中ActiveRequestsCount最小的serverAvailabilityFilteringRule过滤掉那些因为一直连接失败的被标记为circuit tripped的后端server,并过滤掉那些高并发的的后端server(activeconnections 超过配置的阈值)使用一个AvailabilityPredicate来包含过滤server的逻辑,其实就就是检查status里记录的各个server的运行状态WeightedResponseTimeRule根据相应时间分配一个weight,相应时间越长,weight越小,被选中的可能性越低。一个后台线程定期的从status里面读取评价响应时间,为每个server计算一个weight。Weight的计算也比较简单responsetime 减去每个server自己平均的responsetime是server的权重。当刚开始运行,没有形成statas时,使用roubine策略选择server。RetryRule对选定的负载均衡策略机上重试机制。在一个配置时间段内当选择server不成功,则一直尝试使用subRule的方式选择一个可用的serverRoundRobinRule轮询方式轮询选择server轮询index,选择index对应位置的serverRandomRule随机选择一个server在index上随机,选择index对应位置的serverZoneAvoidanceRule复合判断server所在区域的性能和server的可用性选择server使用ZoneAvoidancePredicate和AvailabilityPredicate来判断是否选择某个server,前一个判断判定一个zone的运行性能是否可用,剔除不可用的zone(的所有server),AvailabilityPredicate用于过滤掉连接数过多的Server。配置 RandomRule
在消费者配置
test-scz: # 调用的提供者的名称 ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule再测试:进行十次请求。 两位生产者分别接收到了 三次/七次 总共十次请求,证明Ribbon 负载均衡策略 修改成功。