2023-09-15
原文作者:王伟王胖胖 原文地址: https://blog.csdn.net/wangwei19871103/article/details/105651261

基本流程图

202309152313107571.png

RibbonLoadBalancerClient的getServer选取服务器

前面讲了RibbonLoadBalancerClientgetLoadBalancer做了什么,将服务名和一个spring上下文联系起来,创建了负载均衡器,注册了一些配置,开启了Ping和服务信息获取的定时器,更新了服务列表,最后从上下文容器里获取ZoneAwareLoadBalancer实例。接下来看看服务器怎么获取的,猜应该是执行负载均衡算法选出来的。

202309152313118982.png
因为hintnull,所以是默认的选择,调用父类的chooseServer

202309152313128053.png
内部规则是ZoneAvoidanceRule,就是前面说的把默认的RoundRobinRule给覆盖了,但是复合策略里面默认的又是RoundRobinRule,只是加了一些过滤器,根据一些条件过滤服务器。

202309152313135094.png

PredicateBasedRule的choose

最终到父类的choose方法,先获取负载均衡器lb,然后获取所有的服务器,再获取预测器getPredicate,里面是个复合的AbstractServerPredicate,可以当做过滤器,满足一定条件过滤服务器的,最后进行chooseRoundRobinAfterFiltering轮询:

        @Override
        public Server choose(Object key) {
            ILoadBalancer lb = getLoadBalancer();//获取ZoneAwareLoadBalancer
            Optional<Server> server = getPredicate().chooseRoundRobinAfterFiltering(lb.getAllServers(), key);//过滤出服务
            if (server.isPresent()) {
                return server.get();//存在就返回
            } else {
                return null;
            }       
        }

AbstractServerPredicate的chooseRoundRobinAfterFiltering

必须先走过滤器,过滤一遍,然后再轮询出服务器。

202309152313145295.png

进行过滤器过滤

202309152313154476.png
内部最终会进行ZoneAvoidancePredicateAvailabilityPredicate两个过滤器的过滤,只要有一个不满足就被过滤掉了。

202309152313163217.png

AvailabilityPredicate可用性过滤器

这个是用来过滤掉不可用的服务器,不如连接不上,还有并发太多的,他就是获取服务器信息,然后判断一些问题。

202309152313178048.png
如果检测出断路器问题或者是服务器连接数超过限制了,就要过滤掉了。

202309152313187089.png

ZoneAvoidancePredicate区域过滤器

貌似跟亚马逊云有关,我们一般默认就一个区域defaultzone,多个区域就需要有判断了,比如断电情况,负载啊这些,具体可以看ZoneAvoidancePredicateapply方法,我就不多说了。一般情况只有一个区域,就返回true了:

2023091523131963410.png

最后过滤出来的服务器集合再进行轮询算法,选出一个。

好了,今天就到这里了,希望对学习理解有帮助,大神看见勿喷,仅为自己的学习理解,能力有限,请多包涵。

阅读全文