Spring Cloud Alibaba - Ribbon入门案例(Ribbon支持的负载均衡策略)

    技术2022-07-11  129

    Spring Cloud Alibaba - Ribbon入门案例

    讲述正文前置步骤使用负载均衡策略

    讲述

    对于 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 负载均衡策略 修改成功。

    Processed: 0.016, SQL: 9