首先,这只是我个人的一点质疑,可能是因为我自己菜没有领悟到作者的意思,也正因此,想发出来给大家一起探讨.

在昨晚,我因为在编写自己的开源项目的负载均衡模块,所以去看了下Netflix的RibbonLoadbalancer的源码,然后它是这样做的

首先定义一个ILoadBalancer接口,这个接口是干嘛的呢?大家可以想象为一个自动饮料机,我们想要饮料的时候,按一个按键(chooseServer(Object key)),投一个硬币(当然它的几个源码实现类里,这个key其实没有多少意义),就能获得我们想要的饮料,由此来看,大家可以将它抽象为一个对我们隐藏了内部细节的容器

下面再来看一个接口,这个接口是干什么的呢?将注释里的英文翻译下,就是这个接口是定义负载均衡的规则的,最典型的负载均衡规则就是轮询啊,根据响应时间进行自动权重啊(根据响应时间这个,它的源码里是有实现类的ResponseTimeWeightedRule不过被标记为了过时类,也就是不推荐我们使用)

好了,接下来就是我认为它不合理的地方了,请看下面这个实现了IRule的抽象类,请注意它的成员变量,它封装了ILoadbalancer类

请大家想象一个场景,现在你想去一个超市买水果,你有可能走路去,有可能骑车去,也有可能做公交车,不管怎样,去超市买水果这是一个没有细节的概念,为什么没有细节呢?因为我们不知道你会以什么样的方式去,此时你会以什么样的方式去就是一个可能会发生变化的变量.

那么对比到我们的代码里,ILoadBalancer就是你要去超市买水果,这是一个没有变化的,封闭了细节的概念,试问你在自动饮料机买饮料的时候知道饮料机内部经历了什么样的变化吗?而IRule就是我们是以什么样的方式去超市了,此时它是可能会发生变化的,因为我们可能用轮询算法,有可能用权重算法,但不管用什么,它们最终都会取出一个Server.,这个结果是不会改变的,也就代表

我们的ILoadBalancer是不会改变的,那么你将ILoadBalancer封装到IRule里是什么意思呢?我”个人”认为,正确的做法应该是这样的:

 好吧,我继续看了一会又发现一个问题,这个问题也在验证了我的想法是对的

 很明显,作者自己也知道,IRule应该是ILoadbalancer的细节

what???敢情您饶了一大圈最后又绕回去了呀.我们再看看rule.choose(key)里的具体内容

额额额,你调来调去最后又调回来了…

不过,有一行代码让我感觉到了作者的高并发编程水平也…

这个nextServerCyclicCounter是个AtomticInteger类.

首先我们来说说为什么作者不直接return nextServerCyclicCounter.getAndIncrement()呢?因为如果要getAndIncrement的话,那么会导致一个问题,那么就是我就要写出这样的代码

if(nextServerCyclicCounter.get()==服务数量){

nextServerCyclicCounter.set(0)

}

但是这样就有一个问题,那就是虽然AtomticInteger类的每个操作都是原子性的,但是加起来就不是了,也就是说,线程A刚刚进入了判断CPU时间片就被抢了,此时,线程B也进来了,那么他们拿到的将是同样的数据.

而用这个方法呢?同样也有个问题,就是作者难道不知道compareAndSet()方法本身就是死循环的吗,我知道作者的意思,作者本来是想在外面套个死循环,如果不成功我就再试一次,这样我get()方法拿到的还是最新的值.

但是!!!compareAndSet()这个方法不成功是会一直循环的啊,这样就会导致还在里面自旋的线程的next的数据并不是实时的….

最后我看了下译文

额…然而人家getAndIncrement()方法是这样的

因为这里已经上了循环了…

 完毕~欢迎大家说出我不对的地方…