## 名词解释
* Server:在本文中,Ribbon Server指的是“服务提供者”所代表的微服务。
## 一、ILoadBalancer接口
在上一节我们为大家介绍了Ribbon的负载均衡实现的HTTP请求流程,其中有一个非常关键的接口就是ILoadBalancer 。本节就来重点的介绍一下该接口的实现逻辑:即如何实现负载均衡策略。
~~~
public interface ILoadBalancer {
void addServers(List<Server> var1);
Server chooseServer(Object var1);
void markServerDown(Server var1);
/** @deprecated */
@Deprecated
List<Server> getServerList(boolean var1);
List<Server> getReachableServers();
List<Server> getAllServers();
}
~~~
* chooseServer()方法是根据key去获取Server;该方法是ILoadBalancer接口中最重要的一个方法,决定了如何使用“负载均衡算法”选择合适的微服务实例Server,进行远程服务调用。
* addServers()方法是添加一个Server集合;
* markServerDown()方法用来标记某个服务下线;
* getReachableServers()获取可用的Server集合;
* getAllServers()获取所有的Server集合。
下图是ILoadBalancer接口的实现类图。

在上一节中,我们介绍了RibbonLoadBalancerClient,其中调用了ILoadBalancer 接口的chooseServer方法。

在BaseLoadBalancer(ILoadBalancer接口实现类)中可以找到如下的chooseServer()的方法实现。

从上图中可以看出,chooseServer()选择微服务实例Server的过程是在rule.choose方法中实现的。这里的rule是一个IRule接口的实现类对象。IRule接口就是Ribbon负载均衡中,提供负载均衡策略抽象方法的接口。其默认的负载均衡策略就是:轮询。轮询用白话讲就是,服务提供者轮着被调用,平均分、你一次、我一次。

## 二、IRule接口
IRule接口是负载均衡的策略接口,它有三个方法:
* choose()是根据key 来获取微服务server
* setLoadBalancer()和getLoadBalancer()是用来设置和获取ILoadBalancer的
~~~
public interface IRule {
Server choose(Object var1);
void setLoadBalancer(ILoadBalancer var1);
ILoadBalancer getLoadBalancer();
}
~~~
下图是IRule接口的所有实现类,即:Ribbon默认提供的负载均衡策略。

#### 1)RoundRobinRule(默认)
轮询选择,轮询Server服务数组中index,选择 index 对应位置的 Server。即:取数组下标,每次加1,保证数组中的备选Server依次被调用。
#### 2)RandomRule
从多个备选Server(服务提供者),随机选择一个 Server。
#### 3)RetryRule
对选定的负载均衡策略机加上重试机制,也就是说当选定了某个策略进行请求负载时在一个配置时间段内若选择 Server 不成功,则一直尝试使用 subRule 的方式选择一个可用的 Server。
#### 4)WeightedResponseTimeRule
对RoundRobinRule扩展,根据响应时间分配一个 Weight(权重),响应时间越长,Weight 越小,被选中的可能性越低。
#### 5)ResponseTimeWeightedRule
作用同 WeightedResponseTimeRule,ResponseTime-Weighted Rule 后来改名为 WeightedResponseTimeRule。
#### 6)BestAvailablRule
先过滤掉因为多次访问故障,而被标记为Error的Server。然后选择一个并发量(ActiveRequestCount)最小的Server。俗话说就是:先去掉不能干活的,然后在能干活的里面找一个最闲的。
#### 7)AvailabilityFilteringRule
过滤掉那些一直连接失败的且被标记为 circuit tripped 的后端 Server,并过滤掉那些高并发的后端 Server 或者**使用一个 AvailabilityPredicate 来包含过滤 Server 的逻辑**。其实就是检查 Status 里记录的各个 Server 的运行状态 。
#### 8)ZoneAvoidanceRule
**使用 ZoneAvoidancePredicate 和 AvailabilityPredicate 来判断是否选择某个 Server**,前一个判断判定一个 Zone 的运行性能是否可用,剔除不可用的 Zone(的所有 Server),AvailabilityPredicate 用于过滤掉连接数过多的 Server。
* * *
后两种方式,需要结合断路、超时等参数配置。使用起来比较复杂,容易进坑。从笔者观察的角度使用者也比较少(几乎没见过),基础的Rule(轮询、权重、BestAvailabl)策略,使用简单,运行也比较高效。
如果真的没有合适的负载均衡策略,我们还可以根据自己的算法进行自定义。后面章节就会为大家介绍到。
## 三、负载均衡策略配置
Ribbon默认的负载均衡策略是:轮询,如果我们想调整一下负载均衡策略,可以通过如下的配置。在“服务消费者”的服务中,做ribbon负载均衡策略的调整。
网上有很多版本的配置方式(基于注解的、基于配置文件的),目前最简单的方式就是:
~~~
aservice-rbac:
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
~~~
针对aservice-rbac对外调用服务提供者的服务,使用RandomRule策略。
- 文档简介
- 模块与代码分支说明
- dongbb-cloud项目核心架构
- 微服务架构进化论
- SpringBoot与Cloud选型兼容
- Spring Cloud组件的选型
- 单体应用拆分微服务
- 单体应用与微服务对比
- 微服务设计拆分原则
- 新建父工程及子模块框架
- 通用微服务初始化模块构建
- 持久层模块单独拆分
- 拆分rbac权限管理微服务
- Hello-microservice
- 构建eureka服务注册中心
- 向服务注册中心注册服务
- 第一个微服务调用
- 远程服务调用
- HttpClient远程服务调用
- RestTemplate远程服务调用
- RestTemplate多实例负载均衡
- Ribbon调用流程源码解析
- Ribbon负载均衡策略源码解析
- Ribbon重试机制与饥饿加载
- Ribbon自定义负载均衡策略
- Feign与OpenFeign
- Feign设计原理源码解析
- Feign请求压缩与超时等配置
- 服务注册与发现
- 白话服务注册与发现
- DiscoveryClient服务发现
- Eureka集群环境构建(linux)
- Eureka集群多网卡环境ip设置
- Eureka集群服务注册与安全认证
- Eureka自我保护与健康检查
- 主流服务注册中心对比(含nacos)
- zookeeper概念及功能简介
- zookeeper-linux集群安装
- zookeeper服务注册与发现
- consul概念及功能介绍
- consul-linux集群安装
- consul服务注册与发现
- 通用-auatator导致401问题
- 分布式配置中心-apollo
- 服务配置中心概念及使用场景
- apollo概念功能简介
- apollo架构详解
- apollo分布式部署之Portal
- apollo分布式部署之环境区分
- apollo项目权限管理实战
- apollo-java客户端基础
- apollo与SpringCloud服务集成
- apollo实例配置热更新
- apollo命名空间与集群
- apollo灰度发布(日志热更新为例)
- SpringCloudConfig配置中心
- config-git配置文件仓库
- config配置中心搭建与测试
- config客户端基础
- config配置安全认证
- config客户端配置刷新
- config配置中心高可用
- BUS消息总线
- bus消息总线简介
- docker安装rabbitMQ
- 基于rabbitMQ的消息总线
- bus实现批量配置刷新
- alibaba-nacos
- nacos介绍与单机部署
- nacos集群部署方式(linux)
- nacos服务注册与发现
- nacos服务注册中心详解
- nacos客户端配置加载
- nacos客户端配置刷新
- nacos服务配置隔离与共享
- nacos配置Beta发布
- 服务熔断降级hystrix
- 服务降级&熔断&限流
- Hystrix集成并实现服务熔断
- Jemter模拟触发服务熔断
- Hystrix服务降级fallback
- Hystrix结合Feign服务降级
- 远程服务调用异常传递的问题
- Hystrix-Feign异常拦截与处理
- Hystrix-DashBoard单服务监控
- Hystrix-dashboard集群监控
- 分布式系统流量卫兵sentinel
- sentinel简介与安装
- 客户端集成与实时监控
- 实战流控规则-QPS限流
- 实战流控规则-线程数限流
- 实战流控规则-关联限流
- 实战流控规则-链路限流
- 实战流控效果-WarmUp
- 实战流控效果-匀速排队
- BlockException处理
- 实战熔断降级-RT
- 实战熔断降级-异常数与比例
- DegradeException处理
- 注解与异常的归纳总结
- Feign降级及异常传递拦截
- 动态规则nacos集中存储
- 热点参数限流
- 系统自适应限流
- 微服务网关-GateWay
- 还有必要学习Zuul么?
- 简介与非阻塞异步IO模型
- GateWay概念与流程
- 新建一个GateWay项目
- 通用Predicate的使用
- 自定义PredicateFactory
- 编码方式构建静态路由
- Filter过滤器介绍与使用
- 自定义过滤器Filter
- 网关请求转发负载均衡
- 结合nacos实现动态路由配置
- 整合Sentinel实现资源限流
- 跨域访问配置
- 网关层面全局异常处理
- 微服务网关安全认证-JWT篇
- Gateway-JWT认证鉴权流程
- 登录认证JWT令牌颁发
- 全局过滤器实现JWT鉴权
- 微服务自身内部的权限管理
