spring boot feign在多线程中丢失request headers

1. 问题描述
在使用Spring Boot Feign进行微服务调用时，如果在多线程环境下，会发现部分请求头信息丢失的情况。这是因为默认情况下，Feign的请求是通过Java的线程池来处理的，而线程池中的线程是被复用的，如果不进行特殊处理，每次请求都会复用上一次请求的线程，导致请求头信息丢失。

2. 解决方案
为了解决这个问题，我们可以通过自定义的方式来处理Feign的请求线程池，确保每个请求都能够拥有独立的线程，并保留请求头信息。

2.1. 整体流程
下面是解决该问题的整体流程：

步骤    操作
1    创建一个自定义的Feign配置类
2    在配置类中创建一个自定义的线程池
3    将自定义的线程池添加到Feign的配置中
4    使用自定义的Feign配置进行微服务调用
接下来，我们将逐步详细说明每个步骤需要做什么，并给出相应的代码示例。

2.2. 创建自定义的Feign配置类
首先，我们需要创建一个自定义的Feign配置类，用来配置Feign的相关参数。

@Configuration
public class CustomFeignConfig {

}

2.3. 创建自定义的线程池
在自定义的Feign配置类中，我们需要创建一个自定义的线程池，确保每个请求都能够拥有独立的线程。可以使用ThreadPoolExecutor来创建一个线程池，并设置一些相关的参数。

@Configuration
public class CustomFeignConfig {

    @Bean
    public Executor feignExecutor() {
        return new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<Runnable>());
    }
}

以上代码创建了一个核心线程数和最大线程数均为10的线程池，并使用了一个无界的阻塞队列来保存任务。

2.4. 将自定义的线程池添加到Feign的配置中
接下来，我们需要将自定义的线程池添加到Feign的配置中，以便Feign能够使用这个线程池进行请求的处理。

@Configuration
public class CustomFeignConfig {

    @Autowired
    private ObjectFactory<HttpMessageConverters> messageConverters;

    @Bean
    public Executor feignExecutor() {
        return new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<Runnable>());
    }

    @Bean
    @Scope("prototype")
    public Feign.Builder feignBuilder() {
        return Feign.builder();
    }

    @Bean
    public RequestInterceptor requestInterceptor() {
        return new CustomRequestInterceptor();
    }

    @Bean
    public Decoder feignDecoder() {
        return new ResponseEntityDecoder(new SpringDecoder(this.messageConverters));
    }

    @Bean
    public Encoder feignEncoder() {
        return new SpringEncoder(this.messageConverters);
    }

    @Bean
    public Retryer feignRetryer() {
        return Retryer.NEVER_RETRY;
    }

    @Bean
    public Logger.Level feignLoggerLevel() {
        return Logger.Level.BASIC;
    }
}

以上代码中，我们通过@Scope("prototype")注解将Feign.Builder的作用域设置为原型模式，确保每个请求都会创建一个新的Feign.Builder实例。同时，我们在配置类中添加了其他一些Feign所需的配置，例如请求拦截器、解码器、编码器、重试策略和日志级别等。

2.5. 使用自定义的Feign配置进行微服务调用
最后，我们需要使用自定义的Feign配置进行微服务调用。在使用@FeignClient注解定义Feign客户端时，指定configuration属性为自定义的配置类即可。

@FeignClient(name = "example-service", configuration = CustomFeignConfig.class)
public interface ExampleServiceClient {

    @GetMapping("/example")
    String example();
}

在上面的示例中，我们通过@FeignClient注解定义了一个名为
-----------------------------------
©著作权归作者所有：来自51CTO博客作者mob649e81673fa5的原创作品，请联系作者获取转载授权，否则将追究法律责任
spring boot feign在多线程中丢失request headers
https://blog.51cto.com/u_16175512/7183769