场景:
在做运营平台调用AIID项目接口,需要将header里面的语言传递给AIID项目。但是AIID里面取不到header里面的数据
解决:
1、修改hytrix配置,配置hytrix的 strategy为 SEMAPHORE。
Hystrix 提供两种执行隔离策略( ExecutionIsolationStrategy ) :SEMAPHORE
、THREAD
SEMAPHORE
:信号量,命令在调用线程执行。THREAD
:线程池,命令在线程池执行
如果不修改配置,默认配置的为THREAD,因为不在同一个线程中,无法获得请求的上下文对象,无法执行第二步操作
feign:
httpclient:
enabled: false
okhttp:
enabled: true
hystrix:
enabled: true
hystrix:
command:
default:
execution:
timeout:
enabled: true
isolation:
strategy: SEMAPHORE
thread:
timeoutInMilliseconds: 30000
2、增加拦截器
feign提供的 RequestInterceptor 接口会默认拦截feign发出去所有请求,所以在这里拦截运营平台的服务operation发送给AIID服务的请求,然后再请求头中添加language
如果再第一步没有修改 hystrix 的 strategy,则这一步中 RequestContextHolder.getRequestAttributes()的结果无法获取到,结果为null
拦截器写在operation项目中
@Slf4j
@Component
public class FeignTokenInterceptor implements RequestInterceptor {
@Override
public void apply(RequestTemplate template) {
HttpServletRequest request = getServletRequest();
if (null == request){
return;
}
template.header("language", getHeaders(request));
}
private HttpServletRequest getServletRequest() {
RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
return ((ServletRequestAttributes) requestAttributes).getRequest();
}
private String getHeaders(HttpServletRequest request){
String lang = request.getHeader("lang");
if("cn".equals(lang)){
lang="zh";
}
log.info("lang:{}",lang);
return lang;
}
}
这样 在运营平台operation项目里面添加了拦截器并且更改Hystrix策略,这样B项目里面就可以直接取到header里面的参数了。