使用Feign傳遞請求頭信息(Finchley版本)

更新時間：2022年03月07日 10:39:15 作者：AaronSimon

這篇文章主要介紹了使用Feign傳遞請求頭信息(Finchley版本)，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

Feign傳遞請求頭信息

在我之前的文章服務(wù)網(wǎng)關(guān)Spring Cloud Zuul中，將用戶的登錄id放在了請求頭中傳遞給內(nèi)部服務(wù)。

但是當(dāng)內(nèi)部服務(wù)之間存在feign調(diào)用時，那么請求頭信息會在feign請求的時候傳遞嗎？不會，請求的頭信息和請求參數(shù)都不會進(jìn)行傳遞。

但是我們可以通過通過實現(xiàn)RequestInterceptor接口,完成對所有的Feign請求,傳遞請求頭和請求參數(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請求攔截器（設(shè)置請求頭，傳遞登錄信息）
?*
?* @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è)置了請求頭，如果想傳遞請求參數(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());
? ? }
? }
}

注冊配置

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配置注冊（全局）
?*
?* @author simon
?* @create 2018-08-20 11:44
?**/
@Configuration
public class FeignSupportConfig {
? /**
? ?* feign請求攔截器
? ?*
? ?* @return
? ?*/
? @Bean
? public RequestInterceptor requestInterceptor(){
? ? return new FeignBasicAuthRequestInterceptor();
? }
}

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

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

Feign調(diào)用微服務(wù)傳遞header請求頭

package com.chitic.module.core.config;
import feign.RequestInterceptor;
import org.springframework.context.annotation.Bean;
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;
import java.util.Enumeration;
 
@Configuration
public class FeignConfig {
    @Bean
    public RequestInterceptor headerInterceptor() {
        return template -> {
            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
            if (null != attributes) {
                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);
                    }
                }
            }
        };
    }
}

需注意，feign調(diào)用時不能調(diào)用含有HttpServletResponse參數(shù)（比如常用的數(shù)據(jù)導(dǎo)出），以下就不能遠(yuǎn)程調(diào)用，目前沒找到解決辦法