Feign呼叫中的兩種Header傳參方式小結

2023-01-04 14:00:41

Feign呼叫中的兩種Header傳參方式

在Spring Cloud Netflix棧中，各個微服務都是以HTTP介面的形式暴露自身服務的，因此在呼叫遠端服務時就必須使用HTTP使用者端。

我們可以使用JDK原生的URLConnection、Apache的Http Client、Netty的非同步HTTP Client, Spring的RestTemplate。公司目前使用的是Feign。

下面來和大家一起學習下feign呼叫中兩種Header傳參方式。

在請求攔截器中統一設定

每次Feign呼叫中，需要傳遞一些安全校驗引數，比如說token，bizId啥的，如果單獨在每次呼叫的時候去設定這些重複的邏輯，顯然不合適。所以我們可以在Feign的攔截器中統一設定這些許可權引數。

如何設定呢？其實很簡單。

import org.springframework.context.annotation.Configuration;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import feign.RequestInterceptor;
import feign.RequestTemplate;
import javax.servlet.http.HttpServletRequest;
import java.util.Enumeration;
 
@Configuration
public class FeignConfiguration implements RequestInterceptor {
    @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);
            }
        }
    }
}

然後再feignClient中設定自定義的設定類，覆蓋預設的設定

@Component
@FeignClient(value = "feignTest" ,configuration = FeignConfiguration.class)
public interface FeignTestService {
}

這樣就所有的Feign呼叫都會在Header呼叫中加上request中傳遞過來的引數。不需要單獨在每次Feign呼叫重複新增引數。

通過@RequestHeader註解

上面也說到，我們在攔截器中獲取request傳遞過來的引數，然後再放到header中。在攔截器中設定的一般都是公用的一些引數。

但是如果一個服務介面，需要一些特殊引數。但是其他服務不需要這個引數，這時候我們不必在攔截器中設定其他服務不需要的引數，只需在需要的服務介面上加上@RequestHeader註解，然後在feign呼叫的時候把引數傳過來就ok了。

@PostMapping(value = "/orderDetails")
public ReturnInfo getOrderDetail(@RequestHeader(name = "id") String orderId);

比如說之前在quartz中通過Feign呼叫其他服務獲取優惠券資訊，專案中封裝的方法獲取的attributes 是空的。

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

這時候就不用攔截器了，直接在方法入參上加上 @RequestHeader註解。

這裡簡單介紹下Feign呼叫的傳參，實際在專案中，大家對Feign呼叫方法都有自己的封裝，程式碼和上面的可能不一樣，但是原理都是差不多的。

呼叫feign介面時，如何往header中新增引數

Controller接收到請求後，我們可以在service中通過feign直接呼叫其它服務的介面，但是，controller接收到的請求和通過feign呼叫其它服務，其它服務接收到的請求，是不一樣的。例如我們往往習慣於在header中放入使用者的token資訊，在不做處理的情況下，其它服務接收到的請求，可能就是無使用者資訊狀態，這種請求應該判定為無效狀態。

在服務的提供方或者呼叫方定義一個攔截器，將當前請求的token資訊手動新增到feign請求的header中。

@Configuration
public class FeignRequestInterceptorConfig implements RequestInterceptor {
	@Bean
	public RequestContextListener requestContextListener() {
		return new RequestContextListener();
	}

	@Override
	public void apply(RequestTemplate requestTemplate) {
		ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
		if (ObjectUtils.isEmpty(attributes)) {
			return;
		}
		HttpServletRequest request = attributes.getRequest();
		String token = request.getHeader("token");
		requestTemplate.header("token", token);
	}
}

在使用過程中，可能會涉及到在請求方獲取自己的token資訊都是為空的，檢視一下是否是Hystrix策略導致的，如下設定可以解決該問題。

hystrix:
  command:
    default:
      execution:
        timeout:
          #如果enabled設定為false，則請求超時交給ribbon控制
          enabled: true
        isolation:
          # 隔離策略
          strategy: SEMAPHORE
          thread:
            timeoutInMilliseconds: 100000

總結

以上為個人經驗，希望能給大家一個參考，也希望大家多多支援it145.com。

Feign呼叫中的兩種Header傳參方式小結

目錄