Spring Boot Feign服务调用之间带token问题

import feign.RequestInterceptor;

import feign.RequestTemplate;

import org.springframework.context.annotation.Configuration;

import org.springframework.web.context.request.RequestContextHolder;

import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;

/**

  * Feign配置

  * 使用FeignClient进行服务间调用，传递headers信息

  */

@Configuration

public class FeignConfig implements RequestInterceptor {

     @Override

     public void apply(RequestTemplate requestTemplate) {

         ServletRequestAttributes attributes = (ServletRequestAttributes)RequestContextHolder.getRequestAttributes();

         HttpServletRequest request = attributes.getRequest();

         //添加token

         requestTemplate.header( "Access-Token" , request.getHeader( "Access-Token" ));

     }

}

import org.apache测试数据mons.lang3.StringUtils;

import javax.servlet.*;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletRequestWrapper;

import java.io.IOException;

/**

  * 每次请求过滤器拦截加Token

  */

public class AddTokenFilter implements Filter {

     /**

      * superAdmin

      */

     private static final String DEFAULT_TOKEN = "你的token" ;

     private String profilesActive;

     public AddTokenFilter(String profilesActive) {

         super ();

         this .profilesActive = profilesActive;

     }

     @Override

     public void init(FilterConfig filterConfig) throws ServletException {

     }

     @Override

     public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {

      //判断是开发模式（dev）还是生产坏境（pro）

      //如果不是开发坏境，不做任何操作，是开发坏境，往本地测试的request加请求头

         if (profilesActive == null || !EnumEnvType.DEV.toString().equalsIgnoreCase(profilesActive)) {

             filterChain.doFilter(servletRequest, servletResponse);

             return ;

         }

         filterChain.doFilter( new CustomeizedRequest((HttpServletRequest) servletRequest), servletResponse);

     }

     @Override

     public void destroy() {

     }

//继承HttpServletRequestWrapper ，重写getHeader获取请求头的值

     private class CustomeizedRequest extends HttpServletRequestWrapper {

         /**

          * Constructs a request object wrapping the given request.

          *

          * @param request

          * @throws IllegalArgumentException if the request is null

          */

         public CustomeizedRequest(HttpServletRequest request) {

             super (request);

         }

         @Override

         public String getHeader(String name) {

             if (!Constant.HTTP_HEADER_ACCESS_TOKEN.equalsIgnoreCase(name)) {

                 return super .getHeader(name);

             }

             String token = super .getHeader(name);

             return StringUtils.isNotBlank(token) ? token : DEFAULT_TOKEN;

         }

     }

}

import com.alibaba.fastjson.serializer.SerializerFeature;

import com.alibaba.fastjson.support.config.FastJsonConfig;

import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;

import com.uhope.rl.watersource.filter.AddTokenFilter;

import com.uhope.rl.watersource.filter.ServiceFilter;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.boot.autoconfigure.web.HttpMessageConverters;

import org.springframework.boot.web.servlet.FilterRegistrationBean;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.http.converter.HttpMessageConverter;

import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;

import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;

import java.nio.charset.Charset;

/**

  * Spring MVC 配置

  * @author chenbin on 2017/12/25

  * @version 3.0.0

  */

@Configuration

public class WebMvcConfig extends WebMvcConfigurerAdapter {

     private final Logger logger = LoggerFactory.getLogger(WebMvcConfig. class );

     /**

      * 当前激活的配置文件

      */

     @Value ( "${spring.profiles.active}" )

     private String env;

     /**

      * 解决路径资源映射问题

      *

      * @param registry

      */

     @Override

     public void addResourceHandlers(ResourceHandlerRegistry registry) {

         registry.addResourceHandler( "swagger-ui.html" ).addResourceLocations( "classpath:/META-INF/resources/" );

         registry.addResourceHandler( "/webjars/**" ).addResourceLocations( "classpath:/META-INF/resources/webjars/" );

         registry.addResourceHandler( "/static/**" ).addResourceLocations( "classpath:/static/" );

     }

     /**

      * 使用fastJson代替Jackjson解析JSON数据

      *

      * @return

      */

     @Bean

     public HttpMessageConverters fastJsonHttpMessageConverters() {

         FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();

         FastJsonConfig fastJsonConfig = new FastJsonConfig();

         /*

          * 转换为JSON字符串，默认:

          * WriteNullListAsEmpty    List字段如果为null,输出为[],而非null

          * WriteNullStringAsEmpty  字符类型字段如果为null,输出为][,而非null

          * WriteMapNullValue       是否输出值为null的字段,默认为false

          */

         fastJsonConfig.setSerializerFeatures(SerializerFeature.WriteNullListAsEmpty, SerializerFeature.WriteNullStringAsEmpty, SerializerFeature.WriteMapNullValue, SerializerFeature.WriteDateUseDateFormat);

         fastConverter.setFastJsonConfig(fastJsonConfig);

         fastConverter.setDefaultCharset(Charset.forName( "UTF-8" ));

         HttpMessageConverter<?> converter = fastConverter;

         return new HttpMessageConverters(converter);

     }

     /**

      * 这个Filter 解决页面跨域访问问题

      */

     @Bean

     public FilterRegistrationBean omsFilter() {

         FilterRegistrationBean registration = new FilterRegistrationBean();

         registration.setFilter( new ServiceFilter());

         registration.addUrlPatterns( "/*" );

         registration.setName( "MainFilter" );

         registration.setAsyncSupported( true );

         registration.setOrder( 1 );

         return registration;

     }

     /**

      * 这个Filter 添加token

      */

     @Bean

     public FilterRegistrationBean addTokenFilter(){

         FilterRegistrationBean registration = new FilterRegistrationBean();

         registration.setFilter( new AddTokenFilter(env));

         registration.addUrlPatterns( "/*" );

         registration.setName( "addTokenFilter" );

         registration.setAsyncSupported( true );

         registration.setOrder( 2 );

         return registration;

     }

}

/**

  * Feign请求拦截器配置.

  *

  * @author linzp

  * @version 1.0.0

  * @date 2021/4/16 21:19

  */

@Configuration

public class FeignInterceptorConfig implements RequestInterceptor {

     public FeignInterceptorConfig() {}

     @Override

     public void apply(RequestTemplate template) {

         ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();

         HttpServletRequest request = attributes.getRequest();

         //设置token到请求头

         template.header(ConstantCommon.HEADER_TOKEN_KEY, request.getHeader(ConstantCommon.HEADER_TOKEN_KEY));

     }

}

# 更换hystrix策略，解决无法传递threadLocal变量问题

hystrix:

     command:

         default :

             execution:

                 isolation:

                     strategy: SEMAPHORE