feign传递token

港控/mmm° 2023-07-04 12:35 16阅读 0赞

**feign之间调用服务需要加token怎么办呢，解决办法实现RequestInterceptor接口**

package com.java.common.config;
    
    import feign.RequestInterceptor;
    import feign.RequestTemplate;
    import org.springframework.web.context.request.RequestContextHolder;
    import org.springframework.web.context.request.ServletRequestAttributes;
    
    import javax.servlet.http.HttpServletRequest;
    import java.util.Enumeration;
    import java.util.LinkedHashMap;
    import java.util.Map;
    import java.util.Objects;
    
    public class FeignInterceptor implements RequestInterceptor {
    
    	/**
    	 * feign调用之前进行拦截
    	 * 获取用户的令牌,再将令牌封装到请求头中传递到下个微服务
    	 */
    	@Override
    	public void apply(RequestTemplate requestTemplate) {
    		HttpServletRequest request = getHttpServletRequest();
    
    		if (Objects.isNull(request)) {
    			return;
    		}
    
    		Map<String, String> headers = getHeaders(request);
    		if (headers.size() > 0) {
    			for (Map.Entry<String, String> entry : headers.entrySet()) {
    				// 把请求过来的header请求头 原样设置到feign请求头中
    				// 包括token
    				requestTemplate.header(entry.getKey(), entry.getValue());
    				System.out.println("请求"+entry.getKey()+":"+ entry.getValue());
    			}
    		}
    	}
    
    
    	/**
    	 * ServletRequestAttributes 记录了当前用户请求的所有数据,包括请求头和请求参数等
    	 * 用户当前请求的时候对应,如果开启了feign的熔断后会用新的线程,需要将熔断策略换成信号量,此时不会开启新的线程
    	 *
    	 */
    	private HttpServletRequest getHttpServletRequest() {
    
    		try {
    			// 这种方式获取的HttpServletRequest是线程安全的
    			return ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
    		} catch (Exception e) {
    
    			return null;
    		}
    	}
    
    	private Map<String, String> getHeaders(HttpServletRequest request) {
    
    		Map<String, String> map = new LinkedHashMap<>();
    
    		Enumeration<String> enums = request.getHeaderNames();
    		while (enums.hasMoreElements()) {
    			String key = enums.nextElement();
    			String value = request.getHeader(key);
    			map.put(key, value);
    		}
    
    		return map;
    
    	}
    }

加入spring容器

package com.java.sa.content.config;
    
    import com.java.sa.content.interceptor.FeignBasicAuthRequestInterceptor;
    import feign.Logger;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class FeignConfiguration {
        /**
         * 日志级别
         */
        @Bean
        Logger.Level feignLoggerLevel() {
            return Logger.Level.FULL;
        }
    
        /**
         * 创建 Feign 请求拦截器, 在发送请求前设置认证的 Token, 各个微服务将 Token 设置 到环境变量中来达到通用的目的
         */
        @Bean
        public FeignBasicAuthRequestInterceptor basicAuthRequestInterceptor() {
            return new FeignBasicAuthRequestInterceptor();
        }
    }

将默认的线程隔离修改为信号量隔离

# 开启feign的熔断:默认是线程隔离
      hystrix:
       enabled: true
    
    #hystrix 配置  采用信号量模式
    hystrix:
      command:
        default:
          execution:
            isolation:
              thread:
                timeoutInMilliseconds: 10000
              strategy: SEMAPHORE