前言:在上一篇文章中我们介绍了如何去切换Ribbon的负载均衡模式,而本章节内容则是介绍Ribbon默认负载轮询算法的原理。
1、负载轮询算法公式
rest接口第N次请求数 % 服务器集群总数 = 实际调用服务器下标(每次服务器重启后rest接口计数从1开始)
举例子:
现在集群有两台服务器,分别有payment8001、payment8002这两个实例,即服务器集群总数为2
把这两个实例放进一个List集合里,即List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
如:List[0] instances = 127.0.0.1:8001
List[1] instances = 127.0.0.1:8002
之后对请求数进行%服务器集群总数的操作,然后取出实际调用的服务器下标,用该下标从实例集合里取出的实例就是要访问的服务器
如:
第1次请求 : 1 % 2 = 1,即这时要调用List集合下标为1的服务器,获得instances下标为1的服务器地址127.0.0.1:8002,然后调用这台服务器
第2次请求 : 2 % 2 = 0,即这时要调用List集合下标为0的服务器,获得instances下标为0的服务器地址127.0.0.1:8001,然后调用这台服务器
第3次请求 : 3 % 2 = 1,即这时要调用List集合下标为1的服务器,获得instances下标为1的服务器地址127.0.0.1:8002,然后调用这台服务器
第4次请求 : 4 % 2 = 0,即这时要调用List集合下标为0的服务器,获得instances下标为0的服务器地址127.0.0.1:8001,然后调用这台服务器
第5次请求 : 5 % 2 = 1,即这时要调用List集合下标为0的服务器,获得instances下标为1的服务器地址127.0.0.1:8002,然后调用这台服务器
如此类推.......
以上就是Ribbon轮询算法的原理
2、Ribbon负载轮询算法源码解析
(1)我们进入到MySelfRule这个类里面,然后点进IRule类
(2)点击跳转到IRule接口的RoundRobinRule实现类里,RoundRobinRule这个类就是关于轮询算法的代码实现
(3)解析源代码
[1]我们可以看到RoundRobinRule构造方法里初始化了一个值为0的AtomicInteger类
[2]负载均衡算法主要实现在choose方法里,我们看choose方法可以看到关于各种关于服务的非空判断和各种的取值,其中最重要的是通过incrementAndGetModulo方法取得下标,然后根据这个下标从服务集合里取出其中一个服务
[3]incrementAndGetModulo方法,它的实现方式就跟我们第一个步骤介绍的算法一样,即:
往incrementAndGetModulo方法传入服务总数,nextServerCyclicCounter.get()方法取得原子类当前的值,因为默认值是0,所以取得的值是0,即current的值为0,(current + 1) % modulo的计算方式就跟我们第一个步骤说的一样,即是请求次数%服务总数,current为0,module是服务总数,假使我们当前的服务有有payment8001、payment8002两个,即module是2,(current + 1) % modulo求得next的值为1,nextServerCyclicCounter.compareAndSet(current, next))方法能比较AtomicInteger的值是否被其他线程改变了,若没改变则把next的值更新到AtomicInteger里,如被改变了,则继续下次循环,直到设置AtomicInteger值成功,把next的值返回为止,在不断地调用choose方法时,会不断地进行对AtomicInteger+1然后对服务总数求模取余的操作,然后不断返回下标,不断的返回相应下标的服务