记一次多线程调用Feign接口失败问题

在一次调用FeignClient时，开启了40多个线程调用，然而每次只能调通10个。查看日志发现：

Task javautilconcurrentFutureTask@2019af96 rejected from javautilconcurrentThreadPoolExecutor@78cc480d[Running, pool size = 10, active threads = 10, queued tasks = 0, completed tasks = 0]

根据其提示我们可以看出线程池大小只有10，从而拒绝执行新的线程，触发了Hystrix熔断机制。查阅 Hystrix文档 发现Hystrix为每个依赖提供一个小的线程池（或信号）（ 默认10个线程 ），如果线程池已满调用将被立即拒绝。可以通过修改配置提高Hystrix的并发能力，在配置文件中加入：

hystrix:

  threadpool:

    default:

      coreSize: 50  # 设置线程池大小为50

1跟踪抛出异常的堆栈，发现在对返回结果的json解析中抛出异常

2为什么会解析json失败呢，我们单独调用feign对应的接口是正常的，json也是正常可以解析的

3难道feign的处理过返回的内容，又去跟了下fegin处理过程发现从response获取到流并没有任何异常，难道是出在了源头？但是源头又没有任何异常，此时思绪已经混乱，试着在google上查找有没有相关的问题，没想到在feign的github上找到类似问题 >

Feign是一个声明式的web服务客户端，它使得web服务调用非常的简单，当我们使用Feign时，Spring Cloud

整合了Ribbon和Eureka，从而为我们提供了一个负载均衡的>

首先feign接口处和被调用的controller接口无法相同。

1：如果controller的接口有@RequestParm制定了参数名称，那么feign那里也要加入这个注解的属性，并且名字也要取的相同。

2：feign处必须有@RequestParm注解（针对get请求），controller处不一定需要该注解

3：如果想使用get请求传输pojo对象，就使用@SpringQueryMap注解，这个注解会帮我们解析传入的对象的参数然后拼接到url(这里不懂等会讲原理)

4：@SpringQueryMap只能使用一次，使用多次，后面参数接收的值都是填充第一个参数的值。

传入的值为4月1号和4月22号，

然后尝试将传入的参数改为@SpringQueryMap DatesVo datesVo,并不能解析复杂对象，因为feign的本质是对>

本文会基于Feign源码，看看Feign到底是怎么实现远程调用

上文中，我们的 user-service 服务需要调用远程的 order-service 服务完成一定的业务逻辑，而基本实现是order-service提供一个spi的jar包给user-service依赖，并且在user-service的启动类上添加了一个注解

这个注解就是@EnableFeignClients，接下来我们就从这个注解入手，一步一步解开Feign的神秘面纱

该注解类上的注释大概的意思就是：

扫描那些被声明为 Feign Clients (只要有 orgspringframeworkcloudopenfeignFeignClient 注解修饰的接口都是Feign Clients接口)的接口

下面我们继续追踪源码，看看到底什么地方用到了这个注解

利用IDEA的查找调用链快捷键，可以发现在class类型的文件中只有一个文件用到了这个注解

OK，下面主要就是看这个类做了什么

通过UML图我们发现该类分别实现了 ImportBeanDefinitionRegistrar ， ResourceLoaderAware 以及 EnvironmentAware 接口

这三个接口均是spring-framework框架的spring-context模块下的接口，都是和spring上下文相关，具体作用下文会分析

总结下来就是利用这两个重要属性，一个获取应用配置属性，一个可以加载classpath下的文件，那么FeignClientsRegistrar持有这两个东西之后要做什么呢？

上面将bean配置类包装成 FeignClientSpecification ，注入到容器。该对象非常重要，包含FeignClient需要的 重试策略 ， 超时策略 ， 日志 等配置，如果某个FeignClient服务没有设置独立的配置类，则读取默认的配置，可以将这里注册的bean理解为整个应用中所有feign的默认配置

由于 FeignClientsRegistrar 实现了 ImportBeanDefinitionRegistrar 接口，这里简单提下这个接口的作用

我们知道在spring框架中，我们如果想注册一个bean的话主要由两种方式：自动注册/手动注册

知道了 ImportBeanDefinitionRegistrar 接口的作用，下面就来看下 FeignClientsRegistrar 类是何时被加载实例化的

通过IDEA工具搜索引用链，发现该类是在注解@EnableFeignClients上被import进来的，文章开始的中有

这里提下@Import注解的作用

该注解仅有一个属性value，使用该注解表明导入一个或者多个@Configuration类，其作用和xml文件中的<import>等效，其允许导入@Configuration类，ImportSelector接口/ImportBeanDefinitionRegistrar接口的实现，也同样可以导入一个普通的组件类

注意，如果是XML或非@Configuration的bean定义资源需要被导入的话，需要使用@ImportResource注解代替

这里我们导入的FeignClientsRegistrar类正是一个ImportBeanDefinitionRegistrar接口的实现

FeignClientsRegistrar重写了该接口的 registerBeanDefinitions 方法，该方法有两个参数注解元数据 metadata 和bean定义注册表 registry

该方法会由spring负责调用，继而注册所有标注为@FeignClient注解的bean定义

下面看registerBeanDefinitions方法中的第二个方法，在该方法中完成了所有@FeignClient注解接口的扫描工作，以及注册到spring中，注意这里注册bean的类型为 FeignClientFactoryBean ，下面细说

总结一下该方法，就是扫描@EnableFeignClients注解上指定的basePackage或clients值，获取所有@FeignClient注解标识的接口，然后将这些接口一一调用以下 两个重要方法 完成 注册configuration配置bean 和注册 FeignClient bean

断点位置相当重要

BeanDefinitionBuilder definition = BeanDefinitionBuildergenericBeanDefinition(FeignClientFactoryBeanclass);

这里是利用了spring的代理工厂来生成代理类，即这里将所有的 feignClient的描述信息 BeanDefinition 设定为 FeignClientFactoryBean 类型，该类继承自FactoryBean，因此这是一个代理类，FactoryBean是一个工厂bean，用作创建代理bean，所以得出结论，feign将所有的 feignClient bean定义的类型包装成 FeignClientFactoryBean

最终其实就是存入了BeanFactory的beanDefinitionMap中

那么代理类什么时候会触发生成呢？ 在spring 刷新容器时 ，会根据beanDefinition去实例化bean，如果beanDefinition的beanClass类型为代理bean，则会调用其 T getObject() throws Exception; 方法生成代理bean，而我们实际利用注入进来的FeignClient接口就是这些一个个代理类

这里有一个需要注意的点，也是开发中会遇到的一个 启动报错点

如果我们同时定义了两个不同名称的接口 （同一个包下/或依赖方指定全部扫描我们提供的 @FeignClient ），且这两个 @FeignClient 接口注解的 value/name/serviceId 值一样的话，依赖方拿到我们的提供的spi依赖，启动类上 @EnableFeignClients 注解扫描能同时扫描到这两个接口，就会 启动报错

原因就是Feign会为每个@FeignClient注解标识的接口都注册一个以serviceId/name/value为key，FeignClientSpecification类型的bean定义为value去spring注册bean定义，又默认不允许覆盖bean定义，所以报错

官方提示给出的解决方法要么改个@FeignClient注解的serviceId，name，value属性值，要么就开启spring允许bean定义覆写

至此我们知道利用在springboot的启动类上添加的@EnableFeignClients注解，该注解中import进来了一个手动注册bean的 FeignClientsRegistrar注册器 ，该注册器会由spring加载其 registerBeanDefinitions方法 ，由此来扫描所有@EnableFeignClients注解定义的basePackages包路径下的所有标注为@FeignClient注解的接口，并将其注册到spring的bean定义Map中，并实例化bean

下一篇博文中，我会分析为什么我们在调用（@Resource）这些由@FeignClient注解的bean的方法时会发起 远程调用

这里可以在客户端单独提供一个API进行描述，客户端可以直接引入，无需再定义。服务端也同样引入，直接实现即可。

OpenFeign底层也是通过>

以上就是关于记一次多线程调用Feign接口失败问题全部的内容，包括:记一次多线程调用Feign接口失败问题、Feign踩坑记录：JSON parse error、Feign 与 Hystrix等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！