在我之前的文章服務(wù)網(wǎng)關(guān)Spring Cloud Zuul中，將用戶的登錄id放在了請(qǐng)求頭中傳遞給內(nèi)部服務(wù)。但是當(dāng)內(nèi)部服務(wù)之間存在feign調(diào)用時(shí)，那么請(qǐng)求頭信息會(huì)在feign請(qǐng)求的時(shí)候傳遞嗎？不會(huì)，請(qǐng)求的頭信息和請(qǐng)求參數(shù)都不會(huì)進(jìn)行傳遞。但是我們可以通過(guò)通過(guò)實(shí)現(xiàn)RequestInterceptor接口,完成對(duì)所有的Feign請(qǐng)求,傳遞請(qǐng)求頭和請(qǐng)求參數(shù)。

1. 實(shí)現(xiàn)RequestInterceptor接口

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;

/**
 * Feign請(qǐng)求攔截器（設(shè)置請(qǐng)求頭，傳遞登錄信息）
 *
 * @author simon
 * @create 2018-09-07 9:51
 **/
public class FeignBasicAuthRequestInterceptor implements RequestInterceptor {
  @Override
  public void apply(RequestTemplate requestTemplate) {
    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);
        requestTemplate.header(name, values);
      }
    }
  }
}

這里只設(shè)置了請(qǐng)求頭，如果想傳遞請(qǐng)求參數(shù)，可以參考如下代碼：

public class FeignBasicAuthRequestInterceptor implements RequestInterceptor {
  @Override
  public void apply(RequestTemplate requestTemplate) {
    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);
        requestTemplate.header(name, values);
      }
    }
    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());
    }
  }
}

2. 注冊(cè)配置

package com.southgis.ibase.personalConfigure.config;

import com.southgis.ibase.utils.FeignBasicAuthRequestInterceptor;
import com.southgis.ibase.utils.FeignSpringFormEncoder;
import feign.RequestInterceptor;
import feign.codec.Encoder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Feign配置注冊(cè)（全局）
 *
 * @author simon
 * @create 2018-08-20 11:44
 **/
@Configuration
public class FeignSupportConfig {
  /**
   * feign請(qǐng)求攔截器
   *
   * @return
   */
  @Bean
  public RequestInterceptor requestInterceptor(){
    return new FeignBasicAuthRequestInterceptor();
  }
}

這個(gè)文件放在項(xiàng)目的掃描目錄下，所有的feign調(diào)用都會(huì)使用此配置。如果只有某個(gè)feign調(diào)用則可以這樣設(shè)置(但配置類不能在掃描目錄下)：

@FeignClient(name = "organ",path = "/organ/OrganInfo",configuration = FeignSupportConfig.class)