Spring cloud netflix ribbon设计思路在上一篇文章已经提及,本篇文章是记录本人阅读源码过程中的一些笔记,纯粹是看到一点,写一点。
ribbon是通过往resttemplate(标注了@LoadBalanced)插入拦截器LoadBalancerInterceptor启作用,拦截过程如下:
1.spring boot方式加载spring-cloud-commons-(版本).jar时,会启用自动配置LoadBalancerAutoConfiguration,该类中,自动将有所有标注了@LoadBalanced的resttemplate, 用一个列表restTemplates维护起来。另外还做了三个事情:1)创建拦截器LoadBalancerInterceptor的bean 2)创建了RestTemplateCustomizer的bean,用于将上面的拦截器插入restTemplates内resttemplate对象的拦截器列表。该bean类似函数接口,由SmartInitializingSingleton的bean调用该函数接口。3)创建了LoadBalancerRequestFactory,工厂类,最终目的是重构负载均衡器返回的服务器信息,变成具体的host:port的请求地址。实现方法是给LoadBalancerInterceptor创建请求对象LoadBalancerRequest,该对象的apply方法会将传入的HttpRequest转换为一个包装类ServiceRequestWrapper,接着继续执行http请求后续通用流程。至于在什么地方apply被调用,后面会提及。这里ServiceRequestWrapper作用是override HttpRequest的getURI方法(http请求后续通用流程会调用此方法),该方法内部调用 RibbonLoadBalancerClient(下面会讲)的reconstructURI,其内部调用了RibbonLoadBalancerContext(下面会讲).reconstructURIWithServer达到上述说的最终目的(这源码好tmd啰嗦,就是一堆c++回调函数类似的东西),4)创建了RetryLoadBalancerInterceptor等和重试相关的bean,这块还没仔细看,先不说。
2.既然是拦截器,resttemplate发起请求时,会先调用LoadBalancerInterceptor的intercept(finalHttpRequest request, final byte[] body, finalClientHttpRequestExecution execution)方法,方法内部通过gethost方法获取请求的host地址(一般就是被调用服务名了,用serviceId标记);接着通过类型为LoadBalancerClient的bean执行进一步的操作:execute(String serviceId,LoadBalancerRequest request),具体bean类型为RibbonLoadBalancerClient。
补充:LoadBalancerInterceptor有两个对象,:LoadBalancerClient和LoadBalancerRequestFactory,是通过构造函数赋值。后者讲过了,前者的创建,是在spring-cloud-netflix-core-(版本).jar加载时,自动配置RibbonAutoConfiguration后创建的,具体的bean是RibbonLoadBalancerClient
3.RibbonLoadBalancerClient的execute方法做了几件核心事情,1)通过SpringClientFactory和serviceId获取类型为ILoadBalancer的bean,这属于ribbon组件的类型;2)调用该bean的chooseServer方法,传入参数是一个“default”字符串,返回Server对象(ribbon的类型);3)根据Server对象构造其包装对象RibbonServer,额外存储了服务名,https标识和元数据集合 4)执行LoadBalancerRequest的apply方法(作用上面1.有提到),传入的就是RibbonServer对象,根据该对象信息,构造并发送请求到实际的host:port地址。从而实现了从向服务名请求转换到具体地址(经负载均衡组件挑选)请求。
到这里,spring cloud客户端负载均衡的顶层流程走完,后续重点理解ribbon中ILoadBalancer.chooseServer具体做了什么负载均衡相关事宜,以及ribbon本身一堆初始化的东东。
补充:3.这里涉及了几个关键辅助对象:1)SpringClientFactory,是在spring-cloud-netflix-core-(版本).jar加载时,调用RibbonAutoConfiguration进行自动配置时创建的。这是 a factory that creates client, load balancer and client configuration instances. It creates a Spring ApplicationContext per client name, and extracts the beans that it needs from there.从代码看,是通过为每一个服务名创建一个AnnotationConfigApplicationContext容器(不懂请恶补spring基础知识)来达到每个服务名都有独立的client,load balancer等bean。从SpringClientFactory构造函数中看到,这些bean基本是通过RibbonClientConfiguration来配置创建。当然如果用了eureka,以EurekaRibbonClientConfiguration的bean为主; 2)RibbonLoadBalancerContext用于存储部分被负载均衡器使用的上下文和api操作,也是通过SpringClientFactory获取