微服务feign组件学习

手写不易,对您有帮助。麻烦一键三连。也欢饮各位大料指正,交流。
在这里插入图片描述

微服务feign组件学习

      • 1.概念
        • 1.1 feign 概念
        • 1.2 Ribbon概念
      • 2.使用
        • 2.1 集成feign
          • 2.1.1 maven依赖
          • 2.1.2 项目结构
        • 2.2 使用
          • 2.2.1 定义feign接口
          • 2.2.2 消费端服务调用
          • 2.2.3 消费端扫描feign接口
        • 2.3 参数配置
          • 2.3.1 @FeignClient参数配置
          • 2.3.2 @EnableFeignClients参数配置
      • 3.Feign原理
        • 3.1 @EnableFeignClients
        • 3.2 注册默认配置
          • 3.2.1 解析@EnableFeignClients注解
          • 3.2.2 注册配置信息到spring容器
          • 3.2.3 总结
        • 3.3 注册FeignClientBeanFactory
          • 3.3.1 扫描@FeignClient的接口类
          • 3.3.2 注册@FeignClient的接口类
        • 3.4 feign调用原理
          • 3.4.1 自动装配类
          • 3.4.2 FeignAutoConfiguration作用
          • 3.4.3 FeignContext对象
          • 3.4.4 FeignClientFactoryBean创建Target对象
          • 3.4.5 Targeter targeter方法
        • 4 总结

1.概念

​ 当我们使用微服务架构后,服务之间的调用就是我们需要额外关注的事情,springCloud Alibaba为我们提供了服务调用的两个核心组件Feign、Ribbon

  • Feign: 微服务间的通信都是通过Feign这种HttpClient客户段进行调用
  • Ribbon:负责服务间调用之前的负载均衡
1.1 feign 概念

Feign是Neflix开发的声明式、模板化的HTTP客户端,可帮助我们更加便捷、优雅地调用HTTP API。Feign支持多种注解,例如Feign自带的注解或者JAX-RS注解等。

Sping cloud openfeign 对Feign进行了增强,使其支持Spring MVC注解,另外还整合了RibbonNacos,从而使得Feign的使用更加方便。

1.2 Ribbon概念

Spring Cloud Ribbon 是基于Netflix Ribbon 实现的一套客户端负载均衡的工具。基于消费端这边先从注册中心拿到服务列表,直接在消费端就做了负载均衡,它是一种基于消费端的负载均衡。与之区别的是而基于服务端的负载均衡就像nginx(软件)和F5(硬件)这样的对服务器做反向代理的方式。

在springCloud Alibaba 中Feign默认已经集成了Ribbon。如果想要单独使用可以考虑 RestTemplate+@LoadBalanced注解的形式

@Configuration
public class ConfigBean {@Bean@LoadBalanced //使用Ribbon让RestTemplate负载均衡public RestTemplate getRestTemplate(){return new RestTemplate();}
}

后面所有使用Feign的操作则默认集成了Ribbon,此处不在赘述。

2.使用

项目基于spring-cloud版本Hoxton.SR8创建。

2.1 集成feign
2.1.1 maven依赖
<!--集成openFeign接口 其引入了feign组件和Ribbon组件-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2.1.2 项目结构

在这里插入图片描述

如上项目结构,customer模块feign调用order,并提供了一个order-api的feign接口依赖层。

2.2 使用
2.2.1 定义feign接口
@FeignClient(name = "${com.xiu.order.service}", primary = false,decode404 = false)
public interface OrderClient {@GetMapping("/provider/order/{orderPath}/create")String create(@PathVariable(value = "orderPath") String orderPath);//get请求 多于1个参数,则必须写@RequestParam注解@GetMapping("findOrder")Order findOrder(@RequestParam(name = "pName") String name,@RequestParam(name = "pAge") Integer age);//TODO 无法正常传参//@RequestParam后面是自定义参数类型将不会封装到接口的方法参数中@GetMapping("getOrder1") Order getOrder(@RequestParam("Order") Order Order);//TODO 无法正常传参//feign将会把url拼接成url?name=xx&age=yy&address=zz(address字符串形式)//这个address将会导致接口那边在获取address时,不能正常封装成Address对象而导致报错@GetMapping("getOrder2") Order getOrder1(@RequestParam(name = "name") String name,@RequestParam(name = "age") Integer age,@RequestParam(name = "address") Address address);//可以使用Map封装(远程接口使用@RequestBody Map来接收(address属性能正常接收到))@PostMapping("getOrder")  Map<String,Object> getOrder2(Map<String,Object> map);//不能使用超过1个@RequestBody@PostMapping("addOrder") Order addOrder(@RequestBody Order order, @RequestParam("pAge") Integer age);//TODO 无法正常传参    @RequestParam后面是自定义参数Address将不会封装到接口的方法参数中@PostMapping("addOrder2")Order addOrder2(@RequestBody Order Order,@RequestParam("addr") Address addr);// 多于1个参数,则必须写@RequestParam注解(并且必须写value)// feign拼接url?ids=1%2C2%2C3 (%2C,即逗号)@PostMapping("checkOrder") Order checkOrder(@RequestBody Order order, @RequestParam("ids") Integer[] ids);// 多于1个参数,则必须写@RequestParam注解(并且必须写value)// feign拼接url??ids=1&ids=2&ids=3@PostMapping("checkOrder2") Order checkOrder2(@RequestBody Order order, @RequestParam("ids") List<Integer> ids);
}
#配置文件中声明服务名 用于@FeignClient 的name属性
com:xiu:order:service: order-server

图上定义了一个feign接口并给出了feign的常用方式。需要关注的一点是接口需要使用**@FeignClient**注解修饰

name属性设置服务名(负载均衡组件会根据服务名获取对应的注册中心的所有服务对应的服务列表)。

2.2.2 消费端服务调用
public class FeignTestServiceImpl implements FeignTestService {@Resourceprivate OrderClient orderClient;@Overridepublic String sayHello() {String orderPath = orderClient.create("aaaa");log.info(orderPath);return "hello nacos!!!";}
}

在customer模块中可以像使用其自己的服务一样使用feign服务OrderClient。

2.2.3 消费端扫描feign接口
@Slf4j
@SpringBootApplication(scanBasePackages = {"com.xiu"})
//扫描指定包路径下的feignClient接口
//不指定 默认回扫描当前类CustomerApp所在的路径为basePackages
@EnableFeignClients(basePackages = {"com.xiu"})
@EnableDiscoveryClient
public class CustomerApp {public static void main(String[] args) {SpringApplication.run(CustomerApp.class, args);}
}

注意事项

消费者模块启动类上使用@EnableFeignClients注解后一定要指明Feign接口所在的包路径。 所以这里推荐你们在开发中所有feign模块最好能统一包名前缀。

2.3 参数配置
2.3.1 @FeignClient参数配置
属性说明
name指定FeignClient的名称,如果项目使用了Ribbon,name属性会作为微服务的名称,用于服务发现
urlurl一般用于调试,可以手动指定@FeignClient调用的地址
decode404当发生http 404错误时,如果该字段位true,会调用decoder进行解码,否则抛出FeignException
configurationFeign配置类,可以自定义Feign的Encoder、Decoder、LogLevel、Contract
path定义当前FeignClient的统一前缀
fallback定义容错的处理类,当调用远程接口失败或超时时,会调用对应接口的容错逻辑,fallback指定的类必须实现@FeignClient标记的接口
fallbackFactory工厂类,用于生成fallback类示例,通过这个属性我们可以实现每个接口通用的容错逻辑,减少重复的代码
2.3.2 @EnableFeignClients参数配置
属性说明
value扫描@FeignClient包地址
basePackages用户扫描Feign客户端的包,也就是@FeignClient标注的类,与value同义,并且互斥
basePackageClassesbasePackages属性的安全替代方案,每个指定类别的包将被扫描。 考虑在每个包中创建一个特殊的无操作标记类或接口,除了被该属性引用之外没有其他用途。
defaultConfiguration为所有客户端定制@Configuration,默认配置都在FeignClientsConfiguration中,可以自己定制
clients可以指定@FeignClient标注的类,如果不为空,就会禁用类路径(value、basePackages、basePackageClasses)扫描

3.Feign原理

3.1 @EnableFeignClients

feign起作用最核心的是在启动类上声明@EnableFeignClients,那么我们从该注解入手,来分析一下Feign组件的原理。

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE})
@Documented
//导入FeignClientsRegistrar类来
@Import({FeignClientsRegistrar.class})
public @interface EnableFeignClients {
}

该注解使用了@Import导入FeignClientsRegistrar,我们知道@Import注解的作用

  • 第一个是单纯的注册 beanDefinition,用于后续 bean 的加载。
  • 第二个是注册配置类,即该类会跟启动类一样,作为配置类加载。

这里的FeignClientsRegistrar就是一个配置类,其实现了ImportBeanDefinitionRegistrar接口,其中registerBeanDefinitions方法会将的bean注册成Spring的BeanDefinition并最终被实例化为Bean实例,下面来看看ImportBeanDefinitionRegistrar注册哪些bean

public void registerBeanDefinitions(AnnotationMetadata metadata, BeanDefinitionRegistry registry) {//解析@EnableFeignClients注解 注册默认的Configuration到spring容器registerDefaultConfiguration(metadata, registry);//注册所有扫描到的使用@FeignClient注解修饰的实例FeignClientBeanFactory(创建feignClient的工厂)到spring容器registerFeignClients(metadata, registry);
}
  • 解析@EnableFeignClients注解 注册默认的Configuration到spring容器
  • 注册所有扫描到的使用@FeignClient注解修饰的实例到spring容器
3.2 注册默认配置
3.2.1 解析@EnableFeignClients注解
 private void registerDefaultConfiguration(AnnotationMetadata metadata, BeanDefinitionRegistry registry) {//获取EnableFeignClients的相关属性信息 参考:2.3.2 @EnableFeignClients参数配置   Map<String, Object> defaultAttrs = metadata.getAnnotationAttributes(EnableFeignClients.class.getName(), true);//设置名字(内部类和普通类) if (defaultAttrs != null && defaultAttrs.containsKey("defaultConfiguration")) {String name;if (metadata.hasEnclosingClass()) {//内部类命名方式name = "default." + metadata.getEnclosingClassName();} else {//普通类name = "default." + metadata.getClassName();}//上面获取到了配置信息//将配置信息defaultConfiguration 注册到spring容器this.registerClientConfiguration(registry, name, defaultAttrs.get("defaultConfiguration"));}
}
  • 解析@EnableFeignClients获取其中配置属性defaultConfiguration

  • 将配置信息注册到spring容器。

3.2.2 注册配置信息到spring容器
private void registerClientConfiguration(BeanDefinitionRegistry registry, Object name, Object configuration) {//创建FeignClientSpecification的BeanDefinitionBeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(FeignClientSpecification.class);//设置属性信息 namebuilder.addConstructorArgValue(name);//设置属性信息 配置信息builder.addConstructorArgValue(configuration);//注册到spring容器中registry.registerBeanDefinition(name + "." + FeignClientSpecification.class.getSimpleName(), builder.getBeanDefinition());
}

FeignClientSpecification 是一个 Feign Client 的生成规范,可以简单理解为是@EnableFeignClients注解和@FeignClient注解解析后数据存放的一个类,通过bean扫描,将扫描到的@EnableFeignClients注解的defaultConfiguration属性、@FeignClient注解的configuration属性维护在这个类中,将来初始化FeignClient子容器时会将这些类实例化到子容器,这些配置类实例都是Feign Cient构建所依赖的组件。

3.2.3 总结

注册配置主要分成三部分

  1. 解析@EnableFeignClients获取其中配置属性defaultConfiguration、name属性
  2. 构建FeignClientSpecification的BeanDefinition将defaultConfiguration、name属性放入
  3. 注册FeignClientSpecification到spring容器。
3.3 注册FeignClientBeanFactory
3.3.1 扫描@FeignClient的接口类
public void registerFeignClients(AnnotationMetadata metadata,BeanDefinitionRegistry registry) {//获取扫描类包的组件ClassPathScanningCandidateComponentProvider scanner = getScanner();scanner.setResourceLoader(this.resourceLoader);//设置扫描类型 只扫描@FeignClient修饰的类(默认)AnnotationTypeFilter annotationTypeFilter = new AnnotationTypeFilter(FeignClient.class);Set<String> basePackages;//获取@EnableFeignClients的client属性Map<String, Object> attrs = metadata.getAnnotationAttributes(EnableFeignClients.class.getName());final Class<?>[] clients = attrs == null ? null: (Class<?>[]) attrs.get("clients");//clients属性为空则 使用类路径扫描 //获取其value、basePackages、basePackageClasses)作为包扫描if (clients == null || clients.length == 0) {scanner.addIncludeFilter(annotationTypeFilter);basePackages = getBasePackages(metadata);}else {//clients不为空 则禁用类路径扫描,只使用clients扫描final Set<String> clientClasses = new HashSet<>();basePackages = new HashSet<>();for (Class<?> clazz : clients) {basePackages.add(ClassUtils.getPackageName(clazz));clientClasses.add(clazz.getCanonicalName());}//clients扫描需要新增一个过滤器 即:类使用@@FeignClient修饰,且还需要是Clients中的类AbstractClassTestingTypeFilter filter = new AbstractClassTestingTypeFilter() {@Overrideprotected boolean match(ClassMetadata metadata) {String cleaned = metadata.getClassName().replaceAll("\\$", ".");return clientClasses.contains(cleaned);}};scanner.addIncludeFilter(new AllTypeFilter(Arrays.asList(filter, annotationTypeFilter)));}//获取到了类包路径进行扫描for (String basePackage : basePackages) {//获取到了类包路径中符合条件的@FeignClient修饰的接口//转换为BeanDefinition(方便注册到spring容器)Set<BeanDefinition> candidateComponents = scanner.findCandidateComponents(basePackage);for (BeanDefinition candidateComponent : candidateComponents) {if (candidateComponent instanceof AnnotatedBeanDefinition) {//校验@EnableClient修饰的必须为接口类AnnotatedBeanDefinition beanDefinition = (AnnotatedBeanDefinition) candidateComponent;AnnotationMetadata annotationMetadata = beanDefinition.getMetadata();Assert.isTrue(annotationMetadata.isInterface(),"@FeignClient can only be specified on an interface");Map<String, Object> attributes = annotationMetadata.getAnnotationAttributes(FeignClient.class.getCanonicalName());String name = getClientName(attributes);//注册某个@EnableClient的局部配置,只针对该@FeignClient接口类//注册配置方式同全局配置注册 参考:3.2注册默认配置registerClientConfiguration(registry, name,attributes.get("configuration"));//注册@FeignClient接口类registerFeignClient(registry, annotationMetadata, attributes);}}}
}

上述代码比较长,但是逻辑相对简单,主要做如下事情

  1. 创建扫描器scanner扫描接口
  2. 针对clients属性来判断是否走类路径扫描,还是只扫描clients中对应的类包路径
  3. 循环扫描类包获取@FeignClient修饰的接口并转换为BeanDefinition
  4. 获取@FeignClient类中的属性信息、metadata信息
  5. 注册扫描到的BeanDefinition。
3.3.2 注册@FeignClient的接口类
private void registerFeignClient(BeanDefinitionRegistry registry,AnnotationMetadata annotationMetadata, Map<String, Object> attributes) {//从元数据中获取类信息(@FientClient注解修饰的类)String className = annotationMetadata.getClassName();//构造FeignClientFactoryBean的BeanBeanDefinitionBuilder definition = BeanDefinitionBuilder.genericBeanDefinition(FeignClientFactoryBean.class);//校验属性validate(attributes);//设置@FientClient相关属性 参考 2.3.1 @FeignClient参数配置definition.addPropertyValue("url", getUrl(attributes));definition.addPropertyValue("path", getPath(attributes));String name = getName(attributes);definition.addPropertyValue("name", name);//contextId 上下文id FeignClient的唯一标识,如果没有设置,则系统会自动生成String contextId = getContextId(attributes);definition.addPropertyValue("contextId", contextId);definition.addPropertyValue("type", className);definition.addPropertyValue("decode404", attributes.get("decode404"));definition.addPropertyValue("fallback", attributes.get("fallback"));definition.addPropertyValue("fallbackFactory", attributes.get("fallbackFactory"));definition.setAutowireMode(AbstractBeanDefinition.AUTOWIRE_BY_TYPE);AbstractBeanDefinition beanDefinition = definition.getBeanDefinition();beanDefinition.setAttribute(FactoryBean.OBJECT_TYPE_ATTRIBUTE, className);//bean的primary设置为true,容器中有多个与该bean相同类型, 优先使用primary为true的beanboolean primary = (Boolean) attributes.get("primary");beanDefinition.setPrimary(primary);//设置别名 String alias = contextId + "FeignClient";String qualifier = getQualifier(attributes);if (StringUtils.hasText(qualifier)) {alias = qualifier;}//注册到spring容器BeanDefinitionHolder holder = new BeanDefinitionHolder(beanDefinition, className,new String[] { alias });BeanDefinitionReaderUtils.registerBeanDefinition(holder, registry);
}

构建@FeignClient注解修饰的接口类对应的BeanDefinition,并注册到spring容器中,其实注册的BeanDefintion是FeignClientFactoryBean。例如:该接口被扫描后会生成一个OrderClient的BeanDefinition,注册到spring容器中,最终被spring实例化(透个底:生成的实例对象是一个FeignClientFactoryBean的getObject 创建的HttpClient的代理对象)

@FeignClient(name = "${com.xiu.order.service}", primary = false,decode404 = false)
public interface OrderClient {
}
3.4 feign调用原理

3.1、3.2从@EnableFeignClients注解为切入点分析类其做了哪些操作,下面从open-feign的自动装配类为切入点,来看看feign做了哪些。

3.4.1 自动装配类
自动装配类作用
FeignAutoConfiguration核心配置类
FeignRibbonClientAutoConfiguration负责配置Feign与Ribbon的集成(负载均衡相关)
FeignLoadBalancerAutoConfiguration支持feign调用时候的负载均衡
FeignAcceptGzipEncodingAutoConfiguration支持Feign调用时候可以使用GZIP编码进行响应。
可以节省网络资源,加快响应时间
FeignContentGzipEncodingAutoConfiguration支持Feign调用时候可以使用GZIP编码发送请求。
  • FeignRibbonClientAutoConfiguration和FeignLoadBalancerAutoConfiguration显然是做负载均衡的
  • FeignHalAutoConfiguration是用来处理application/hal+json这种的,
  • FeignAcceptGzipEncodingAutoConfiguration和FeignContentGzipEncodingAutoConfiguration都是定义了feign的拦截器,用来设置压缩相关的请求头,
  • 核心的配置类就一个FeignAutoConfiguration。
3.4.2 FeignAutoConfiguration作用

通过FeignAutoConfiguration类的代码研究,该类做了如下事情

  • 引入两个配置FeignClientProperties、FeignHttpClientProperties(都是http请求相关配置类,前者是为HttpURLConnection(默认的client)配置类,后者是ApacheHttpClient和OkHttpClient的配置类。
  • 构造FeignContext对象实例。
  • 引入的类有feign.hystrix.HystrixFeign则创建HystrixTargeter(openfeign会添加熔断机制,所以该对象被创建)否则创建DefaultTargeter,Target:Feign客户端代理对象的由该对象target方法生成。(前者是带有熔断机制的Target,后者是默认普通的Target
3.4.3 FeignContext对象

FeignContext主要用于管理Feign客户端的上下文信息。它是一个spring的子容器。承担了以下几个关键职责:

  1. Bean存储与检索:spring子容器,它保存了所有与Feign客户端相关的bean,包括自定义的编解码器、连接(Contract)、拦截器(Request Interceptors)等。这些bean可以根据名称或类型从FeignContext 中获取,为Feign客户端的构建提供必要的组件。
  2. 作用域隔离:在多客户端场景下,FeignContext 支持不同客户端之间的配置隔离,每个客户端都可以拥有自己独立的配置。
  3. 动态配置:它允许在运行时动态地向Feign客户端添加或替换组件。
//1、自动注入配置类
@Autowired(required = false)
private List<FeignClientSpecification> configurations = new ArrayList<>();//构造FeignContext
@Bean
public FeignContext feignContext() {FeignContext context = new FeignContext();//设置配置信息context.setConfigurations(this.configurations);return context;
}public void setConfigurations(List<C> configurations) {//把所有的feign客户端配置类实例保存到configurations成员map中,key是client的名字,value是client本身。 for (C client : configurations) {this.configurations.put(client.getName(), client);}
}

上述方式中构建了FeignContext并将其通过3.2.2小节配置信息构造的FeignClientSpecification 是一个 Feign Client 的生成规范放入FeignContext的map容器中。

createContext方法

FeignContext有一个核心方法createContext 其会基于某个figenClient的name创建对应的AnnotationConfigApplicationContext对象

//针对每个feign客户端创建一个AnnotationConfigApplicationContext。
protected AnnotationConfigApplicationContext createContext(String name) {//构造AnnotationConfigApplicationContext (spring容器)AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();//注册每个feign客户端自己的配置类if (this.configurations.containsKey(name)) {for (Class<?> configuration : this.configurations.get(name).getConfiguration()) {//注册configuration对应的beanDeinftion对象context.register(configuration);}}//注册全局的配置类for (Map.Entry<String, C> entry : this.configurations.entrySet()) {if (entry.getKey().startsWith("default.")) {for (Class<?> configuration : entry.getValue().getConfiguration()) {context.register(configuration);}}}//注册用于占位符解析的配置类context.register(PropertyPlaceholderAutoConfiguration.class,this.defaultConfigType);//添加了环境变量feign.client.name = 客户端的名字context.getEnvironment().getPropertySources().addFirst(new MapPropertySource(this.propertySourceName,Collections.<String, Object>singletonMap(this.propertyName, name)));//设置了父类Context和本Context的名字。if (this.parent != null) {// Uses Environment from parent as well as beanscontext.setParent(this.parent);// jdk11 issue// https://github.com/spring-cloud/spring-cloud-netflix/issues/3101context.setClassLoader(this.parent.getClassLoader());}context.setDisplayName(generateDisplayName(name));context.refresh();return context;
}

也就是说每一个feign客户端都有一个AnnotationConfigApplicationContext,这个context里面注册了这个feign客户端的自己的配置类、全局默认的配置类、注册用于占位符解析的配置类,添加了环境变量feign.client.name = feign客户端的名字,设置了父类Context和本Context的名字。

3.4.4 FeignClientFactoryBean创建Target对象

Target是我们服务端实际请求的fegin真正对象。负责创建和配置Feign客户端的目标对象。这个接口定义了如何将一个接口绑定到一个具体的HTTP服务地址上,是连接Feign客户端定义与实际HTTP请求执行逻辑的纽带。其中FeignAutoConfiguration自动装配类会创建一个默认普通的DefaultTargeter或者带有熔断机制的HystrixTargeter。

同时3.3.3小节注册的FeignClientFactoryBean在spring容器启动进行实例化该类的时候会调用其中的getObject方法也会创建对应的Target对象。下面我们来看看代码实现。

//FactoryBean 获取其工厂创建的bean
@Override
public Object getObject() throws Exception {return getTarget();
}<T> T getTarget() {//获取feignContext 自动装配后会实例化该对象并放入spring容器中FeignContext context = applicationContext.getBean(FeignContext.class);//构造feign对象(基础信息)Feign.Builder builder = feign(context);//基于负载均衡创建httpClient,用于后面feign调用if (!StringUtils.hasText(url)) {if (!name.startsWith("http")) {url = "http://" + name;}else {url = name;}url += cleanPath();//基于负载均衡创建httpclient代理对象return (T) loadBalance(builder, context,new HardCodedTarget<>(type, name, url));}//如果有 @FeignClient的url属性 则基于url创建httpClient,用于后面feign调用if (StringUtils.hasText(url) && !url.startsWith("http")) {url = "http://" + url;}String url = this.url + cleanPath();//获取可用的clientClient client = getOptional(context, Client.class);if (client != null) {if (client instanceof LoadBalancerFeignClient) {//url直连不使用负载,但是引入了ribbon相关的负载,则基于ribbon进行url的负载client = ((LoadBalancerFeignClient) client).getDelegate();}if (client instanceof FeignBlockingLoadBalancerClient) {//url直连不使用负载,但是引入了Spring Cloud LoadBalancer相关的负载,//则基于Spring Cloud LoadBalancer进行url的负载client = ((FeignBlockingLoadBalancerClient) client).getDelegate();}builder.client(client);}//url直连的httpclient代理对象Targeter targeter = get(context, Targeter.class);return (T) targeter.target(this, builder, context,new HardCodedTarget<>(type, name, url));
}

上述代码做了如下事情:

  1. 获取FeignContext对象,便于从其中获取对应的FeignClient客户端的配置信息构建feign对象
  2. 基于基础信息构建feign(基础信息:日志类、编解码、连接信息等)
  3. 创建feign对象的client客户端,有两种方式 url直连的普通client和具有负载功能的client
  4. Targeter.target创建HttpClient代理对象。

feignContext获取相关配置对象

在上述构建feign对象的代码中大量用到了context.getInstance方法获取对应的配置信息,所以还是比较FeignContext还是比较重要的。

其底层调用FeignContext有一个核心方法createContext获取的。

protected <T> T getOptional(FeignContext context, Class<T> type) {return context.getInstance(contextId, type);
}protected <T> T get(FeignContext context, Class<T> type) {T instance = context.getInstance(contextId, type);if (instance == null) {throw new IllegalStateException("No bean found of type " + type + " for " + contextId);}return instance;}
//上述两个方法都使用 context.getInstance(contextId, type);
  • get(context, Feign.Builder.class):Feign.Builder
  • get(context, FeignLoggerFactory.class):获取feign日志工厂
  • encoder(get(context, Encoder.class)) 编码器对象
  • decoder(get(context, Decoder.class)) 解码器对象
  • contract(get(context, Contract.class)); 连接对象
  • getOptional(context, Client.class); FeignClient客户端
  • get(context, Targeter.class); Targeter对象
3.4.5 Targeter targeter方法

不管是直连还是负载的代理对象创建都需要先获取targeter对象在调用其target方法。

而loadBalance方法除了和直连调用一样的逻辑,只是其创建的实LoadBalancerFeignClient对象。所以此处分析该方法即可了解其中逻辑。

protected <T> T loadBalance(Feign.Builder builder, FeignContext context,HardCodedTarget<T> target) {//从feignContext中获取Client,其获取的是LoadBalancerFeignClientClient client = getOptional(context, Client.class);if (client != null) {builder.client(client);//创建的是HystrixTargeter(openFeign会自动引入熔断机制)Targeter targeter = get(context, Targeter.class);//生成代理对象return targeter.target(this, builder, context, target);}throw new IllegalStateException("No Feign Client for loadBalancing defined. Did you forget to include spring-cloud-starter-netflix-ribbon?");
}

在这里插入图片描述
通过上图可以看到Targeter. targeter方法其实基于jdk动态代理创建了FeignClient对象。

4 总结

feign服务调用的完整流程如下:

  • 容器启动的时候,首先是走@EnableFeignClients去注册默认的配置类、注册FeignClient和FeignClient的配置类

  • 基于自动装配类@FeignAutoConfiguration,创建FeignContext,把配置类都放进去。创建Targeter用于创建代理对象

  • FactoryBean的getObject() 创建对应的代理对象,基于Targeter.targeter的jdk动态代理生成FeignClient对象

  • 当@Autowired注入feign客户端的时候,发起调用通过代理对象发起http请求完成整个调用

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/27692.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

单通道电容感应芯片XW01T用于水位检测、人体感应

概述 XW01T SOT23-6封装和丝印 XW01T 是一个单通道电容感应芯片,广泛应用于水位检测,人体感应等应用场合。 特点 做非接触式液位检测和长按功能检测 自动环境校准 内置按键消抖,无需软件再消抖 嵌入共模干扰去除电路 每秒按键反应速度可达 20 次 上电立刻判断按键有效状态 按…

数据分析的流程是啥样?

数据分析在当今的商业环境中扮演着至关重要的角色。通过深入挖掘和理解数据&#xff0c;企业可以做出更明智的决策&#xff0c;优化产品与服务&#xff0c;提高市场竞争力。然而&#xff0c;数据分析并非简单的数据堆砌和解读&#xff0c;它需要一个系统的流程来确保分析的准确…

【C++11】第一部分(一万六千多字)

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 目录 前言 C11简介 统一的列表初始化 &#xff5b;&#xff5d;初始化 std::initializer_list 声明 auto decltype 右值引用和移动语义 左值引用和右值引用 左值引…

【Python】数据处理:NumPy

NumPy是一个用于科学计算的开源Python库&#xff0c;其名称来源于“Numerical Python”的缩写。它提供了支持大规模多维数组和矩阵运算的功能&#xff0c;此外还包含了大量的数学函数库&#xff0c;可以高效地进行各种数学操作。 import numpy as np数组创建、属性和操作 数组…

Docker|了解容器镜像层(2)

引言 容器非常神奇。它们允许简单的进程表现得像虚拟机。在这种优雅的底层是一组模式和实践&#xff0c;最终使一切运作起来。在设计的根本是层。层是存储和分发容器化文件系统内容的基本方式。这种设计既出人意料地简单&#xff0c;同时又非常强大。在今天的帖子[1]中&#xf…

基于mybatis plus增加较复杂自定义查询以及分页

基于java技术&#xff0c;spring-boot和mybatis-plus搭建后台框架是现在非常流行的技术。 其中关于多表关联查询的实现相对比较复杂&#xff0c;在这里进行记录以供开发人员参考。 以一个系统中实际的实体类为查询为例&#xff0c; T3dMaterial实体其中的fileType属性及字段…

桶排序!!

桶排序 算法描述bucketSort函数bucketSort完整代码topKFrequent函数topKFrequent完整代码 完整代码 算法描述 给定一个整数数组 nums 和一个整数 k &#xff0c;请返回其中出现频率前 k 高的元素。可以按 任意顺序 返回答案。 bucketSort函数 这个函数将输入数组根据元素出现…

Scrapy与MongoDB的异步数据存储

在数据采集过程中&#xff0c;处理大量的数据请求和存储任务是常见的需求。使用Scrapy来爬取数据并将其存储到MongoDB中是一个高效的解决方案。本文将介绍如何实现一个异步插入MongoDB的Scrapy管道。 项目背景 在本项目中&#xff0c;我们需要从某些公开网站上爬取数据&#…

java安装并配置环境

安装前请确保本机没有java的残留&#xff0c;否则将会安装报错 1.安装java jdk&#xff1a;安装路径Java Downloads | Oracle 中国 百度网盘链接&#xff1a;https://pan.baidu.com/s/11-3f2QEquIG3JYw4syklmQ 提取码&#xff1a;518e 2.双击 按照流程直接点击下一步&#x…

618:带货短剧,阿里VS拼多多的新战场

霸道总裁爱上我、穿越回古代成为后宫之主...让人上头的短剧今年持续升温&#xff0c;成为不少人的“电子榨菜”。 今年618&#xff0c;短剧又变身火热的主角&#xff0c;成为各大平台和品牌的新战场。 淘宝早在“逛逛”板块的二级页面&#xff0c;增加了名为“剧场”的板块&a…

机器学习实验------PCA

目录 一、介绍 二、算法流程 &#xff08;1&#xff09;数据中心化 &#xff08;2&#xff09;计算协方差矩阵 &#xff08;3&#xff09;特征值分解 &#xff08;4&#xff09;选择特征 三、运行结果展示 四、实验中遇到的问题 五、PCA的优缺点 优点&#xff1a; 缺点…

vue相关的前端知识回顾

nvm的安装 nvm 是一个 nodejs 版本管理工具。 使用 nvm 可以安装不同版本的 nodejs。也能够实时的切换不同的版本的NodeJS。 官方文档&#xff1a;https://github.com/nvm-sh/nvm 安装命令&#xff1a; curl -o- https://raw.githubusercontent.com/nvm-sh/nvm/v0.39.7/in…

联想正式发布全栈算力基础设施新品,加速筑基AI 2.0时代

6月14日&#xff0c;以“异构智算 稳定高效”为主题的联想算力基础设施新品发布会在北京成功举办。 据「TMT星球」了解&#xff0c;在与会嘉宾和合作伙伴的见证下&#xff0c;联想正式发布率先搭载英特尔至强 6能效核处理器的联想问天WR5220 G5、联想ThinkSystem SR630 V4、联…

前端传递bool型后端用int收不到

文章目录 背景模拟错误点解决方法 背景 我前几天遇到一个低级错误&#xff0c;就是我前端发一个请求&#xff0c;把参数送到后端&#xff0c;但是我参数里面无意间传的布尔型&#xff08;刚开始一直没注意到&#xff0c;因为当时参数有十几个&#xff09;&#xff0c;但是我后…

Python-算法编程100例-系统设计题(入门级)-疫情人员管理

题目描述&#xff1a; 现有一套用于管理疫情下人员流动风险的软件系统&#xff0c;请实现以下接口&#xff1a; RiskMonitor(int[] people):系统初始化&#xff0c;people[i]的下标表示人员编号&#xff0c;值表示所在地区的编号。初始时所有地区&#xff08;包括没人的地区&…

“土猪拱白菜” 的学霸张锡峰,如今也苦于卷后端

大家好&#xff0c;我是程序员鱼皮&#xff0c;前几天在网上刷到了一个视频&#xff0c;是对几年前高考励志演讲的学霸张锡峰的采访。 不知道大家有没有看过他的演讲视频。在演讲中&#xff0c;衡水中学的学霸张锡峰表达了城乡孩子差距大、穷人家的孩子只想要努力成为父母的骄…

[C#]使用C#部署yolov10的目标检测tensorrt模型

【测试通过环境】 win10 x64vs2019 cuda11.7cudnn8.8.0 TensorRT-8.6.1.6 opencvsharp4.9.0 .NET Framework4.7.2 NVIDIA GeForce RTX 2070 Super cuda和tensorrt版本和上述环境版本不一样的需要重新编译TensorRtExtern.dll&#xff0c;TensorRtExtern源码地址&#xff1a;T…

博客论坛系统java博客管理系统基于springboot+vue的前后端分离博客论坛系统

文章目录 博客论坛系统一、项目演示二、项目介绍三、部分功能截图四、部分代码展示五、底部获取项目源码&#xff08;9.9&#xffe5;带走&#xff09; 博客论坛系统 一、项目演示 博客论坛系统 二、项目介绍 基于springbootvue的前后端分离博客论坛系统 系统角色&#xff1a…

java程序员写博客的方法论

作为一名Java程序员&#xff0c;撰写技术博客是一种提升个人品牌、分享知识以及巩固学习成果的有效方式。以下是一些关于如何高效撰写高质量Java技术博客的方法论建议&#xff1a; 1. 明确目标受众 确定你的读者是谁&#xff1a;初学者、中级开发者还是高级工程师&#xff1f…

【Qt】QT textBrowser 设置字体颜色和大小

1. 效果 2. 代码 {ui->methodText->append("<font size9 colorgreen> dddddddddd </font>");ui->methodText->append("<font size9 colorred> vvvvvvvvvv </font>"); }