dubbo解析-RpcContext解析

109 阅读 0 评论 72 点赞

我是靠谱客的博主感动时光，这篇文章主要介绍dubbo解析-RpcContext解析，现在分享给大家，希望可以做个参考。

本文基于dubbo 2.7.5版本代码

dubbo提供了RpcContext上下文对象。我们可以使用该对象传递隐式参数，同时该对象也记录了一次调用的状态数据。
先介绍如何传递隐式参数。
RpcContext提供了attachments属性，客户端调用时，使用：

复制代码

1
2
3
4
5
RpcContext contentx=RpcContext.getContext();
contentx.setAttachment("isTest","测试");
//调用远程服务
remoteService.service();

服务端使用RpcContext接收数据：

复制代码

1
2
RpcContext.getContext().getAttachments("isTest");

注意，使用attachments属性只能传递字符串对象，因为attachments的定义是：

复制代码

1
2
private final Map<String, String> attachments = new HashMap<String, String>();

隐式参数只在当次调用中有效，下一次调用时必须重新塞入参数。这是因为ConsumerContextClusterInterceptor对象的after方法在收到响应后，会执行RpcContext.removeContext();。
服务端收到请求后，在过滤器ContextFilter中，创建服务端的RpcContext对象，并将消费端传递的attachments属性值添加到服务端的RpcContext对象中。
我们在使用RpcContext时，必须使用RpcContext.getContext()获取RpcContext对象，不能使用new RpcContext()的方式创建。
另外，RpcContext是线程私有的，所以在多线程环境下可以放心使用。