微服务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.rhkb.cn/news/350841.html

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

相关文章

Ubuntu 22.04 解决 firefox 中文界面乱码

问题复现 在为Ubuntu 22.04 Server安装完整的GNOME 42.01桌面后&#xff0c;将桌面语言设置为中文时&#xff0c;打开Firefox可能会出现中文乱码的问题。经过网上调查发现&#xff0c;这个问题是由Snap软件包引起的。 解决方案 为了避免在Ubuntu 22.04中文模式下的乱码问题…

Redis系列-4 Redis集群介绍

Redis集群 Redis提供了持久化能力&#xff0c;保证了重启不会丢失数据&#xff1b;但Redis重启至完全恢复期间&#xff0c;缓存不可用。另外&#xff0c;对于高并发场景下&#xff0c;单点Redis服务器的性能不能满足吞吐量要求&#xff0c;需要进行横向扩展。此时&#xff0c;…

mmdeploy环境部署流程

参考&#xff1a;mmdeploy/docs/zh_cn/01-how-to-build/linux-x86_64.md at main open-mmlab/mmdeploy (github.com) 从零入门《openmmlab》mmdeploy[1]环境安装及简单上手_哔哩哔哩_bilibili 我的环境&#xff1a; docker容器&#xff0c;ubuntu20.04&#xff0c;cuda11.7…

注解(Annotation)(一)

Java 注解&#xff08; Annotation &#xff09;又称 Java 标注&#xff0c;是 JDK5.0 引入的一种注释机制。 Java 语言中的类、 构造器、 方法、成员变量、参数等都可以被注解进行标注。 自定义注解 --- 格式 自定义注解就是自己做一个注解来使用。 public interface …

C++ | Leetcode C++题解之第140题单词拆分II

题目&#xff1a; 题解&#xff1a; class Solution { private:unordered_map<int, vector<string>> ans;unordered_set<string> wordSet;public:vector<string> wordBreak(string s, vector<string>& wordDict) {wordSet unordered_set(w…

[Cloud Networking] SPDY 协议

文章目录 1. 背景2. SPDY 之前3. SPDY 项目目标4. SPDY 功能特点4.1 SPDY基本功能4.2 SPDY高级功能 1. 背景 TCP是通用的、可靠的传输协议&#xff0c;提供保证交付、重复抑制、按顺序交付、流量控制、拥塞避免和其他传输特性。 HTTP是提供基本请求/响应语义的应用层协议。 不…

Apache IoTDB进行IoT相关开发实践

当今社会&#xff0c;物联网技术的发展带来了许多繁琐的挑战&#xff0c;尤其是在数据库管理系统领域&#xff0c;比如实时整合海量数据、处理流中的事件以及处理数据的安全性。例如&#xff0c;应用于智能城市的基于物联网的交通传感器可以实时生成大量的交通数据。据估计&…

【面试干货】Integer 和 int 的区别

【面试干货】Integer 和 int 的区别 1、基本类型与包装类型2、内存占用3、自动装箱与拆箱4、null 值5、常量池6、总结 &#x1f496;The Begin&#x1f496;点点关注&#xff0c;收藏不迷路&#x1f496; 在Java中&#xff0c;Integer 和 int 是两种不同类型的变量&#xff0c;…

REST风格

黑马程序员Spring Boot2 文章目录 1、REST简介1.1 优点1.2 REST风格简介1.3 注意事项 2、RESTful入门案例 1、REST简介 1.1 优点 隐藏资源的访问行为&#xff0c;无法通过地址的值对资源适合中操作书写简化 1.2 REST风格简介 按照RST风格访问资源时使用行为动作区分对资源进…

Python:基础爬虫

Python爬虫学习&#xff08;网络爬虫&#xff08;又称为网页蜘蛛&#xff0c;网络机器人&#xff0c;在FOAF社区中间&#xff0c;更经常的称为网页追逐者&#xff09;&#xff0c;是一种按照一定的规则&#xff0c;自动地抓取万维网信息的程序或者脚本。另外一些不常使用的名字…

OpenGauss常操作

OpenGauss官网已经有很详细的说明了,但是对于新手而言还有一些需要注意的地方; 安装 yum一键安装; yum -y install libaio-devel yum -y install readline-devel yum -y install libnsl 单独创建用户和组; groupadd dbgroup useradd -g dbgroup omm passwd omm 取消打开文…

RK3568平台(input篇)输入设备应用编程

一.输入设备介绍 输入设备其实就是能够产生输入事件的设备就称为输入设备&#xff0c;常见的输入设备包括鼠标、键盘、触摸屏、按钮等等&#xff0c;它们都能够产生输入事件&#xff0c;产生输入数据给计算机系统。 对于输入设备的应用编程其主要是获取输入设备上报的数据、输…

Django更改超级用户密码

Django更改超级用户密码 1、打开shell 在工程文件目录下敲入&#xff1a; python manage.py shell再在python交互界面输入&#xff1a; from django.contrib.auth.models import User user User.objects.get(username root) user.set_password(123456) user.save()其中ro…

每日一练——有效的括号

20. 有效的括号 - 力扣&#xff08;LeetCode&#xff09; 错误记录 #include<stddef.h> #include<stdlib.h> #include<assert.h> #include<stdbool.h>typedef char STDataType;typedef struct Stack {STDataType* a;int capacity;int top; } Stack;vo…

【回文 马拉车】214. 最短回文串

本文涉及知识点 回文 马拉车 LeetCode214. 最短回文串 给定一个字符串 s&#xff0c;你可以通过在字符串前面添加字符将其转换为回文串。找到并返回可以用这种方式转换的最短回文串。 示例 1&#xff1a; 输入&#xff1a;s “aacecaaa” 输出&#xff1a;“aaacecaaa” 示…

超详解——Python 字典详解——小白篇

目录 1. 创建字典 示例&#xff1a; 2. 访问字典中的元素 示例&#xff1a; 3. 修改字典元素 示例&#xff1a; 4. 删除字典元素 示例&#xff1a; 5. 查找元素是否是字典的键 示例&#xff1a; 6. 标准类型操作符 获取字典长度 合并两个字典 7. 常用内置函数 k…

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

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

读AI新生:破解人机共存密码笔记02进化

1. 人工智能的标准模型 1.1. 机器优化人类提供的固定目标 1.1.1. 是一条死胡同 1.1.1.1. 当你走进死胡同时&#xff0c;你最好掉头返回&#xff0c;找出走错的地方 1.2. 问题不在于我们可能无法做好构建人工智能系统的工作&…

atmega8 上传程序

使用icsp 烧写时先关闭串口程序&#xff0c;与串口uart连接相关的电路勿于电脑连接 接触不良 1.使用icsp 上传 1&#xff09;可以直接上传程序 如官方示例blink 或是 serial示例 2&#xff09;可以先烧录bootload 方便下次使用串口上传程序代码 A)使用专门的icsp 上传器上传…

AI Stable diffusion 报错:稳定扩散模型加载失败,退出

可能是内存不够&#xff0c;看看你最近是加了新的大的模型&#xff0c;可以把你的stable-diffusion-webui\models\Stable-diffusion目录下的某个ckpt删除掉&#xff0c;可能ckpt太大&#xff0c;无法加载成功&#xff1b; Stable diffusion model failed to load, exiting 如图…