Spring Cloud之Feign 轉發請求頭(header參數)

在作接口請求時,咱們常常會在header頭中增長一些鑑權信息,如token 或 jwt,那麼在經過fegin從A server去調用B server的接口時,若是B server的接口須要header信息,咱們須要將A sever獲取的header轉發到B上。
java

解決方式

咱們須要實現Feign提供的一個接口RequestInterceptorbootstrap

@Configuration
public class FeignConfiguration implements RequestInterceptor{
    private final Logger logger = LoggerFactory.getLogger(getClass());

            @Override
            public void apply(RequestTemplate template) {
                ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder
                        .getRequestAttributes();
                HttpServletRequest request = attributes.getRequest();
                Enumeration<String> headerNames = request.getHeaderNames();
                if (headerNames != null) {
                    while (headerNames.hasMoreElements()) {
                        String name = headerNames.nextElement();
                        String values = request.getHeader(name);
                        template.header(name, values);

                    }
                    logger.info("feign interceptor header:{}",template);
                }
               /* Enumeration<String> bodyNames = request.getParameterNames();
                StringBuffer body =new StringBuffer();
                if (bodyNames != null) {
                    while (bodyNames.hasMoreElements()) {
                        String name = bodyNames.nextElement();
                        String values = request.getParameter(name);
                        body.append(name).append("=").append(values).append("&");
                    }
                }
                if(body.length()!=0) {
                    body.deleteCharAt(body.length()-1);
                    template.body(body.toString());
                    //logger.info("feign interceptor body:{}",body.toString());
                }*/
            }
        }

@FeignClient註解裏面的屬性加上configuration = FeignConfiguration.class就能夠了。如app

@FeignClient(name = "a-server",  configuration = FeignConfiguration.class)
public interface AServer{
}

 

bootstrap.yml增長ide

hystrix: command: default: execution: timeout: enabled: false isolation: strategy: SEMAPHORE
相關文章
相關標籤/搜索