微服务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 次 上电立刻判断按键有效状态 按…

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

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

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

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

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

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

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; 缺点…

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

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

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

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

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

大家好&#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…

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

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

局域网监控软件有哪些:五款好用的网络监控神器分享(收藏篇)

在日益复杂的企业网络环境中&#xff0c;有效地监控局域网内的活动对于确保网络安全、提高工作效率和维护企业资产至关重要。 为此&#xff0c;精选了五款市场上广受好评的局域网监控软件&#xff0c;它们各自具备独特的功能和优势&#xff0c;能够满足不同规模企业的需求&…

【七合一】字典词典成语古诗词造句英语单词文库

帝国CMS7.5 UTF-8 系统开源&#xff0c;不限域名 采用静态伪静态&#xff08;会缓存静态文件&#xff09; 一款7合一的字词句诗典籍模板&#xff0c;包含字典、词典、成语、名句、诗词、古籍、英语、作文、等等。是一款养站神器。 作文范文,作文范文可生成word文档下载能自由…

【面经总结】Java集合 - Map

Map 概述 Map 架构 HashMap 要点 以 散列(哈希表) 方式存储键值对&#xff0c;访问速度快没有顺序性允许使用空值和空键有两个影响其性能的参数&#xff1a;初始容量和负载因子。 初始容量&#xff1a;哈希表创建时的容量负载因子&#xff1a;其容量自动扩容之前被允许的最大…

矩阵练习2

48.旋转图像 规律&#xff1a; 对于矩阵中第 i行的第 j 个元素&#xff0c;在旋转后&#xff0c;它出现在倒数第i 列的第 j 个位置。 matrix[col][n−row−1]matrix[row][col] 可以使用辅助数组&#xff0c;如果不想使用额外的内存&#xff0c;可以用一个临时变量 。 还可以通…

【Linux】进程_4

文章目录 五、进程4. 进程状态5. 进程优先级6. 进程的调度和转换 未完待续 五、进程 4. 进程状态 当进程属于挂起状态时&#xff0c;进程的可执行程序代码和数据均会被从内存中换入到磁盘中&#xff0c;此时进程的PCB并没有消失&#xff0c;只要操作系统还需要管理这个进程&a…

C++11左值、右值

知识回顾&#xff0c;详解引用 简单概括&#xff0c;引用就是给已存在对象取别名&#xff0c;引用变量与其引用实体共用同一块内存空间 左右值区分 注意&#xff1a;不一定左边的都是左值&#xff0c;右边的都是右值 左边的也可能是右值&#xff0c;等号右边的也可能是左值 …

Linux C语言:函数的基本用法及传参

一、函数的基本用法 1、main函数 int main(int argc, const char * argv[]) { printf("Hello world\n"); return 0; }数据类型 函数名称 (参数) { //.... return 表达式 } 2、函数 函数是一个完成特定功能的代码模块&#xff0c;其程序代码独立&#xff0c;通常要…