SpringCloud Ribbon负载均衡

如何通过Feign产生代理对象

@FeignClient(name = "user")
public interface RemoteAccountService {

    @GetMapping("/remote/uri/getUriList")
    List getUriList();
}
//调用代理对象方法栈
SynchronousMethodHandler
    MethodHandler
        LoadBalancerFeignClient
            SpringClientFactory
                ILoadBalancer

Feign关键组件类

@EnableFeignClient 声明引入feign组件的标识，同时负责解析@FeignClient
@FeignClient 声明一个远程调用的接口，供业务方完成远程调用
FeignClientsRegistrar 加载@FeignClient的所有.class文件，生成beanDefinitioin和beanInstance放入spring容器
FeignClientFactoryBean 完成feign远程调用所需要组件的聚合，同时还有@FeignClient的代理类的生成
FeignAutoConfiguration AutoConfiguration的子类，定义@Bean FeignContext、@Bean xxxHttpClient等
FeignClientsConfiguration "Feign configuration"的默认配置值，@EnableFeignClients.defaultConfiguration如果没有设置值，默认就是FeignClientsConfiguration

org.springframework.cloud.openfeign.FeignClientFactoryBean#getTarget
    applicationContext.getBean(FeignContext.class)
    从parent容器里面拿到feign.Client的子类LoadBalancerFeignClient

feignContext的产生
    FeignAutoConfiguration
    @Bean
    public void FeignContext feignContext();
feign.Client的产生
    DefaultFeignLoadBalancedConfiguration
        LoadBalancerFeignClient

负载均衡核心组件接口

ILoadBalancer
- ZoneAwareLoadBalancer
IRule (根据特定算法中从服务列表中选取一个要访问的服务)
- ZoneAvoidanceRule (默认)
- RoundRobinRule 轮询规则，默认规则。同时也是更高级rules的回退策略
- WeightedResponseTimeRule 服务响应权重
IPing (在后台运行的一个组件，用于检查服务列表是否都活)
- DummyPing
ServerList (存储服务列表。分为静态和动态。如果是动态的，后台有个线程会定时刷新和过滤服务列表)
- NacosServerList
ServerListFilter (该接口允许过滤配置或动态获取的具有所需特性的服务器列表)
- ZonePreferenceServerListFilter
ServerListUpdater (更新交给Ribbon的List的策略)
- PollingServerListUpdater

上面的6大组件都是在RibbonClientConfiguration中被初始化的

ILoadBalancer

public interface ILoadBalancer {
    public void addServers(List<Server> newServers); //向负载均衡器中维护的实例列表增加服务实例。
    public Server chooseServer(Object key); //通过某种策略，从负载均衡器中挑选出一个具体的服务实例。
    public void markServerDown(Server server); //用来通知和标识负载均衡器中某个具体实例已经停止服务，不然负载均衡器在下一次获取服务实例清单前都会认为服务实例均是正常服务的。
    public List<Server> getReachableServers();//获取当前正常服务的实例列表。
    public List<Server> getAllServers();//获取所有已知的服务实例列表，包括正常服务和停止服务的实例。
}

AbstractLoadBalancer是ILoadBalancer接口的抽象实现

public abstract class AbstractLoadBalancer implements ILoadBalancer {
    public enum ServerGroup{
        ALL, //ALL-所有服务实例
        STATUS_UP,//STATUS_UP-正常服务的实例
        STATUS_NOT_UP//STATUS_NOT_UP-停止服务的实例
    }
    public Server chooseServer() {
        return chooseServer(null);
    }
    public abstract List<Server> getServerList(ServerGroup serverGroup);
    public abstract LoadBalancerStats getLoadBalancerStats();// LoadBalancerStats 对象被用来存储负载均衡器中各个服务实例当前的属性和统计信息，这些信息非常有用，我们可以利用这些信息来观察负载均衡器的运行情况，同时这些信息也是用来制定负载均衡策略的重要依据。
}

BaseLoadBalancer类是Ribbon负载均衡器的基础实现类

定义并维护了两个存储服务实例Server对象的列表。一个用于存储所有服务实例的清单，一个用于存储正常服务的实例清单。
```
protected volatile List<Server> upServerList;
protected volatile List<Server> allServerList;
```
定义了之前我们提到的用来存储负载均衡器各服务实例属性和统计信息的LoadBalancerStats对象
定义了检查服务实例是否正常服务的IPing对象
定义了检查服务实例操作的执行策略对象IPingStrategy
定义了负载均衡的处理规则IRule对象
启动ping任务
实现了ILoadBalancer接口定义的负载均衡器应具备的一系列基本操作
- addServers 向负载均衡器中增加新的服务实例列表，该实现将原本已经维护着的所有服务实例清单
- chooseServer 挑选一个具体的服务实例，在上面介绍IRule的时候，已经做了说明，这里不再赘述。
- markServerDown 标记某个服务实例暂停服务。
- getReachableServers 获取可用的服务实例列表
- getAllServers 获取所有的服务实例列表

DynamicServerListLoadBalancer 类继承于BaseLoadBalancer类，它是对基础负载均衡器的扩展。在该负载均衡器中，实现了服务实例清单的在运行期的动态更新能力; 同时，它还具备了对服务实例清单的过滤功能，也就是说我们可以通过过滤器来选择性的获取一批服务实例清单。

serverList

public interface ServerList<T extends Server> {    
 List<T> getInitialListOfServers();    
 List<T> getUpdatedListOfServers();
}

ServerListUpdater
- PollingServerListUpdater动态服务列表更新的默认策略，也就是说DynamicServerListLoadBalancer负载均衡器中的默认实现就是它，它通过定时任务的方式进行服务列表的更新。

ServerListFilter

updateAction.doUpdate在 DynamicServerListLoadBalancer中，它的实际实现委托给了updateListOfServers函数

public void updateListOfServers() {
    List<T> servers = new ArrayList<T>();
    if (serverListImpl != null) {
        servers = serverListImpl.getUpdatedListOfServers();
        LOGGER.debug("List of Servers for {} obtained from Discovery client: {}",
                getIdentifier(), servers);

        if (filter != null) {
            servers = filter.getFilteredListOfServers(servers);
            LOGGER.debug("Filtered List of Servers for {} obtained from Discovery client: {}",
                    getIdentifier(), servers);
        }
    }
    updateAllServerList(servers);
}

服务的注册和发现