在业务开发中,有时会将一些通用参数放在Header中进行传递,后端可以通过http的getHeader()方法来获取所需的公共参数。但当该A服务调用RPC接口请求B服务时,http请求中的Header并不会随RPC请求带入到B服务中,这时可以通过dubbo的RpcContext进行统一参数传递。
RpcContext本质上是一个ThreadLocal,当接收到RPC请求或发起RPC请求时,RpcContext的状态会变化。比如A调用B,B再调用C,则B机器上,在B调用C之前,RpcContext记录的是A调用B的信息,在B调用C之后,RpcContext记录的是B调用C。
public class HeaderFilter implements Filter {
@Override
public Result invoke(Invoker> invoker, Invocation invocation) throws RpcException {
String value = RpcContext.getContext().getAttachment("key");
//根据业务存储数据
if (StringUtils.isNotEmpty(value)){
RpcContext.getContext().setAttachment("key",value);
}
Result invoke = invoker.invoke(invocation);
return invoke;
}
}
在B服务中就可以通过
RpcContext.getContext().getAttachment("key")
获取到公共参数了。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)