首页 > 编程语言 >Feign源码解析5:loadbalancer

Feign源码解析5:loadbalancer

时间:2024-01-14 15:23:41浏览次数:37  
标签:容器 Feign spring nacos bean 源码 class loadbalancer

背景

经过前面几篇的理解,我们大致梳理清楚了FeignClient的创建、Feign调用的大体流程,本篇会深入Feign调用中涉及的另一个重要组件:loadbalancer,了解loadbalancer在feign调用中的职责,再追溯其是如何创建的。

在讲之前,我先提个重点,本文章的前期是引用了nacos依赖且开启了如下选项,启用了nacos的Loadbalancer:

spring.cloud.loadbalancer.nacos.enabled=true

nacos的Loadbalancer是支持了基于nacos实例中的元数据进行服务实例筛选,比如权重等元数据。

不开这个选项,则是用默认的Loadbalancer,不知道支不支持基于nacos实例中的元数据进行服务实例筛选(没测试)。

我们这边是打开了这个选项,所以本文就基于打开的情况来讲。

feign调用流程

大体流程

接上一篇文章,feign调用的核心代码如下:

image-20240114113200793

1处主要是封装请求;

2处主要是依靠loadbalancer获取最终要调用的实例。

但是在1和2之间,有一段代码是,获取LoadBalancerLifecycle类型的bean列表,大家看到什么lifecycle之类的名字,大概能知道,这些类是一些listener类,一般包含了几个生命周期相关的方法,比如这里就是:

void onStart(Request<RC> request);

void onStartRequest(Request<RC> request, Response<T> lbResponse);

void onComplete(CompletionContext<RES, T, RC> completionContext);

这几个方法分别就是在loadbalancer的不同阶段进行调用。

比如,我举个例子,我之前发现feign的日志里没打印最终调用的实例的ip、端口,导致查日志不方便,所以我就定义了一个自定义的LoadBalancerLifecycle类,将最终选择的实例的ip端口打印出来。

image-20240114113841901

我们看下,这里是如何获取LoadBalancerLifecycle对象的?

loadBalancerClientFactory.getInstances(serviceId, LoadBalancerLifecycle.class)

工厂用途

loadBalancerClientFactory这个字段,类型为LoadBalancerClientFactory,其定义:

public class LoadBalancerClientFactory extends NamedContextFactory<LoadBalancerClientSpecification>

再看其注释:

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.

这里就直说了,这是个工厂,它会给每个client创建一个spring容器。这里的client是啥呢,其实是org.springframework.cloud.client.loadbalancer.LoadBalancerClient类型的对象,它是在spring-cloud-commons中定义的接口:

image-20240114115218070

工厂自身的创建

工厂本身是自动装配的:

image-20240114121947011

看上图,需要一个构造函数参数,这个就是一些配置:

image-20240114122040282

调用的构造函数逻辑如下:

public class LoadBalancerClientFactory extends NamedContextFactory<LoadBalancerClientSpecification>

public static final String NAMESPACE = "loadbalancer";    
public static final String PROPERTY_NAME = NAMESPACE + ".client.name";

public LoadBalancerClientFactory(LoadBalancerClientsProperties properties) {
    super(LoadBalancerClientConfiguration.class, NAMESPACE, PROPERTY_NAME);
    this.properties = properties;
}

这里调用了父类构造函数,把几个值存到父类中:

private final String propertySourceName;
private final String propertyName;
private Class<?> defaultConfigType;

public NamedContextFactory(Class<?> defaultConfigType, String propertySourceName, String propertyName) {
    this.defaultConfigType = defaultConfigType;
    this.propertySourceName = propertySourceName;
    this.propertyName = propertyName;
}

完成构造后,我们发现,还调用了:

clientFactory.setConfigurations(this.configurations.getIfAvailable(Collections::emptyList));

这里的configurations类型是:

private final ObjectProvider<List<LoadBalancerClientSpecification>> configurations;

image-20240114122524436

这个字段本身是通过构造函数方式注入的,来源呢,就是spring 容器。

我们有必要探究下,这个LoadBalancerClientSpecification类型的bean,是怎么进入spring 容器的?

其实,这个类也是代表了一份LoadbalancerClient的配置,之前feignClient也是一样的:

public class LoadBalancerClientSpecification implements NamedContextFactory.Specification {

	private String name;

	private Class<?>[] configuration;
}

这种类型的bean,其实是通过LoadBalancerClient注解和LoadBalancerClients注解进入容器的,当你使用这两个注解时,其实是支持配置一个class:

image-20240114123017911

image-20240114123039013

然后,它们两注解都import了一个LoadBalancerClientConfigurationRegistrar类:

image-20240114122913148

这个会负责将对应的配置class,注册到容器中:

image-20240114123306881

注册时,name会有所区别,如果是LoadBalancerClients注解引入的,会加个default前缀。

image-20240114123447968

在默认情况下(引入了nacos-discovery、spring-cloud-loadbalancer的情况下),就会在代码中如下三处有@LoadBalancerClients注解:

image-20240114124649366

image-20240114124730849

image-20240114124757216

所以,我们工厂创建时debug,可以看到如下场景:

image-20240114124936926

从工厂获取LoadBalancerLifecycle

上面讲完了工厂的创建,这里回到工厂的使用。我们之前看到,会获取LoadBalancerLifecycle这种bean:

loadBalancerClientFactory.getInstances(serviceId, LoadBalancerLifecycle.class),

但奇怪的是,获取bean不应该先用loadBalancerClientFactory创建的给各个loadBalancerClient的spring容器;再从容器获取bean吗?

这里是简化了,直接让工厂负责全部事务,我要bean的时候,只找工厂要,工厂内部自己再去创建spring容器那些。

所以我们看到,工厂是实现了接口:

public class LoadBalancerClientFactory extends NamedContextFactory<LoadBalancerClientSpecification>
		implements ReactiveLoadBalancer.Factory<ServiceInstance>    

这个接口就有如下方法,这是个泛型方法:

Allows accessing beans registered within client-specific LoadBalancer contexts.
    
<X> Map<String, X> getInstances(String name, Class<X> type);

下面就看看方法如何实现的:

image-20240114125611955

这里就是分了两步,先获取容器,再从容器获取bean。

创建容器

这个获取容器是先从缓存map获取,没有则创建。

image-20240114125754859

我们这里自然是没有的,进入createContext:

image-20240114130159006

这里首先是创建了一个spring上下文,里面是有一个bean容器的,容器里要放什么bean呢,首先就是上图中的configurations中那些LoadBalancerClient注解里指定的配置类,再然后,就是LoadBalancerClients注解里指定的那些默认的配置类,我们这里有3处LoadBalancerClients注解,但是只有nacos那一个,指定了配置类:

@LoadBalancerClients(defaultConfiguration = NacosLoadBalancerClientConfiguration.class)
public class LoadBalancerNacosAutoConfiguration {

所以,这里会把NacosLoadBalancerClientConfiguration这个配置类注册到容器。

接下来,是如下这行:

context.register(PropertyPlaceholderAutoConfiguration.class, this.defaultConfigType);

这里的defaultConfigType是啥呢,其实就是创建工厂时,指定的LoadBalancerClientConfiguration:

image-20240114130737961

到这里为止,基本spring容器该手工放入的bean就这些了。但这个容器内到时候只会有这些bean吗,不是的。

因为我们这里放进去的几个bean,内部又定义了更多的bean。

nacosLoadBalancerClientConfiguration
loadBalancerClientConfiguration    

nacosLoadBalancerClientConfiguration

首先是自动装配一个NacosLoadBalancer(在缺少这种ReactorLoadBalancer bean的情况下)

image-20240114131703086

再下来,会自动装配ServiceInstanceListSupplier bean:

image-20240114131857085

loadBalancerClientConfiguration

这边注意,也是在没注册这个bean的时候,自动装配ReactorLoadBalancer,这个其实会和上面的nacos的产生竞争,最终到底是哪个上岗呢,只能看顺序了:

image-20240114132145192

和nacos一样,自动装配ServiceInstanceListSupplier:

image-20240114132231126

竞争关系谁胜出

我们上面提到,nacos的配置类和spring-cloud-loadbalancer的配置类,是全面竞争的,最终的话,是谁胜出呢?

我们看看容器完成bean创建后的情况:

image-20240114133009841

可以发现,是nacos的配置赢了。

具体为什么赢,这个暂时不细说,基本就是bean的order那些事情。反正现在nacos赢了,看起来也没啥问题,我们就继续往后走,目前是完成了bean容器的创建。

获取LoadBalancerLifecycle类型bean

我这个项目,并没定义这种bean,所以实际是取不到的,注意的是,在LoadbalancerClient对应的容器取不到,还是会去父容器取的。

我们在父容器也没定义,所以最终是取不到。

根据服务名获取最终实例

loadBalancerClient

目前准备分析如下代码:

image-20240114133356196

先看下这个字段来自于哪里:

image-20240114141150266

image-20240114141248933

可以看出,来自于spring容器注入。

image-20240114141418748

所以,这里可以看出,loadBalancerClient类型为BlockingLoadBalancerClient。

loadBalancerClient.choose

进入该方法:

image-20240114141024073

image-20240114141628863

image-20240114141647797

最终就是从容器获取,取到的就是nacos自动装配的NacosLoadBalancer:

image-20240114141739653

loadBalancer.choose

nacos这里的实现用的反应式编程,不怎么了解这块,反正最终是调用getInstanceResponse方法,且会把从nacos获取到的服务列表传递进来:

image-20240114142341843

image-20240114142555615

可以看到,这里传入的就是实际的服务实例,还包含了nacos相关的元数据,如cluster、weight、是否临时、是否健康等。

后续的逻辑就根据实例的各种属性进行筛选,如meta.nacos.cluster、ipv4/ipv6、

image-20240114142817880

根据权重进行选择:

image-20240114143419421

根据实例进行feign调用

image-20240114143627515

我们跟进去后,发现主要就是feignClient.execute进行调用,在前后则是调用生命周期的相关方法:

image-20240114143957771

我们看到,这个client就是默认的FeignClient,比较原始,直接就是用原生的HttpURLConnection;我们之前文章提到,也是可以使用httpclient、okhttp那些feign.Client的实现,只要引入对应依赖即可。

image-20240114144221192

另外,这个也是没有连接池的,每次都是打开新连接;这里也用了外部options参数中的超时时间。

image-20240114144501645

后面的响应处理就略过不讲了。

总结

我们总算是把大体流程都讲完了,下一篇讲讲我遇到的问题。

标签:容器,Feign,spring,nacos,bean,源码,class,loadbalancer
From: https://www.cnblogs.com/grey-wolf/p/17963745

相关文章

  • 性能篇:深入源码解析和性能测试arraylist和LinkedList差异!
    嗨,大家好,我是小米!今天我们要谈论的是Java中两个常用的集合类:ArrayList和LinkedList。大家都知道,这两者在新增和删除元素的操作上有一些差异,那么它们究竟在性能上有何表现呢?我们通过深入源码解析和性能测试来一探究竟!ArrayList新增元素到末尾这是最常见的新增元素操作,我们使用......
  • 深入理解 Hadoop (一)网络通信架构与源码浅析
    HadoopRPC网络通信框架原理剖析YARNRPC服务端的工作大致可以分为四个阶段:第一个阶段:Server初始化和启动在Server初始化的时候,会初始化Listener组件(内部启动了一个AcceptSelector绑定了相应的端口,用来处理客户端的OP_ACCEPT事件),内部还初始化了一组Reader线程,其......
  • C++源码中司空见惯的PIMPL是什么?
    前言:C++源码中司空见惯的PIMPL是什么?用原始指针、std::unique_ptr和std::shared_ptr指向Implementation,会有什么不同?优缺点是什么?读完这篇文章,相信你能搞懂这种设计方式并将其运用于实践,也将更容易阅读源码。1.PIMPL是什么?PIMPL是PointertoIMPLementation的缩写,意思是指......
  • AQS源码解析
    AQS结构特性内部包含Node、ConditionObject静态内部类,Node用来存储没竞争到锁的线程状态、CondidtionObject是对条件变量的封装;volatileintstate变量记录锁的状态,1表示锁被持有、0表示锁被释放,同时对应三个方法来更改/获取锁的状态:getState()、setState(intnewState......
  • 从零开始的源码搭建:详解连锁餐饮行业中的点餐小程序开发
    时下,点餐小程序成为了许多餐饮企业引入的一种创新工具,不仅方便了顾客的用餐体验,同时也提高了餐厅的运营效率。本文将详细探讨如何从零开始搭建一个源码,并深入解析连锁餐饮行业中的点餐小程序开发过程。 一、需求分析与规划在开始源码搭建之前,首先需要明确点餐小程序的具体需求。这......
  • 源码开发实战:连锁餐饮数字化转型中的点餐小程序
    如今,商家通过引入点餐小程序,不仅可以提高服务速度,还能够增加用户粘性,实现数字化运营的目标。为了实现这一愿景,源码开发成为一种高效的手段。 一、技术选型在开发点餐小程序时,选择合适的技术是关键一环,结合小程序开发框架,实现了前后端分离,提高了开发效率。此外,数据库采用了高性能的......
  • Android 14 新特性代码 UUID.fromString & Matcher.matches 的细节改动(扒源码)
    文章目录前言UUID处理的更改正则表达式的更改结束前言Android14已经出来好久好久了…今天其他的暂且不论,单纯的讲一下OpenJDK17更新的两点变更(扒源代码)~对正则表达式的更改UUID处理首先,正则表达式的更改:现在,为了更严格地遵循OpenJDK的语义,不允许无效的组引用。您可能会......
  • 基于SpringBoot+Vue的居家养老系统设计实现(源码+lw+部署文档+讲解等)
    (文章目录)前言:heartpulse:博主介绍:✌全网粉丝10W+,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java、小程序技术领域和毕业项目实战✌:heartpulse:......
  • 短视频系统源码,如何限制视频分辨率?
    导言:在短视频系统源码的许多场景下,我们需要确保用户上传的视频满足一定的分辨率要求,以保证在后续的处理中能够获得良好的视觉效果。在短视频系统源码开发时需要对用户上传的视频分辨率进行限制,以确保页面加载和播放的性能。技术实现步骤:1、创建视频元素和Canvas:con......
  • 一对一直播系统源码,后台管理系统权限控制方案
    纯前端控制前端写死配置文件,通过用户角色信息判断是否有权限。例如constanth={'admin':{//路由权限,如果路由权限为false/undefined则整个页面无权限//如果路由权限为true,则拥有全部路由下操作的权限'/home':true,......