dubbo隐式传参

dubbo隐式传参

1、预备知识

说明：以下只使用于使用 InternalThread 的情况，使用Thread的不建议使用InternalThreadLocal

1. InternalThreadLocalMap

常用属性：

Object[] indexedVariables： 对象数据用于数据存储；

static final AtomicInteger NEXT_INDEX：用于记录InternalThreadLocal实例位于数组中的位置。

2. InternalThread

常用属性：

InternalThreadLocalMap threadLocalMap ： 用于存储当前线程中的InternalThreadLocal实例内容。

3. InternalThreadLocal

一个类似ThreadLocal的类。

InternalThreadLocal实例的index用于判断线程内 InternalThreadLocalMap 属性的内部数组的位置。

2、RpcContext 类

全类名：org.apache.dubbo.rpc.RpcContext ；

作用：一个线程共享数据的处理类，使用静态的**InternalThreadLocal**的实例属性 LOCAL 存储入参内容， SERVER_LOCAL存储出参内容。

3、ConsumerContextFilter类

全类名：org.apache.dubbo.rpc.filter.ConsumerContextFilter

作用：

a. 服务作为消费者调用其他生产者时，会执行其**invoke(Invoker<> invoker, Invocation invocation)**方法，调用RpcContext设置调用地址等信息，remove当前线程的SERVER_LOCAL实例对应的map，处理结束后remove当前线程的LOCAL实例对应的map。

b. 内部类ConsumerContextListener负责将传回来的隐性参数添加到当前线程的LOCAL实例对应的map中。

3、ContextFilter 类

全类名： org.apache.dubbo.rpc.filter.ContextFilter

作用：

a. 服务作为生产者被调用时会执行其**invoke(Invoker<> invoker, Invocation invocation)**方法，接收隐性参数并设置到当前服务的线程的InternalThreadLocalMap中。

b. 内部类ContextListener负责将传递过来的map添加到当前线程的LOCAL实例对应的map中。

4、目前公司方案

1. 自定义ConsumerFilter类

全类名：com.casstime.saas.dubbo.filter.ConsumerFilter extends ListenableFilter

作用：invoke(Invoker<> invoker, Invocation invocation)方法中实现session、crm session、链路跟踪和客户端信息 传递，从而实现登录信息隐性传递。

内部类：ConsumerResultListener 暂未使用，部分代码注释

2. 自定义ProviderFilter类

全类名：com.casstime.saas.dubbo.filter.ProviderFilter extends ListenableFilter

作用：invoke(Invoker<> invoker, Invocation invocation) 方法中实现 session、crm session、链路跟踪和客户端信息 接收，从而获取来自消费者的用户信息。

内部类：ProviderResultListener 暂未使用，部分代码已注释

3. 自定义DubboConfig类

全类名：com.casstime.saas.dubbo.config.DubboConfig

作用：

a. 将上述两个自定义类配置到配置文件com.alibaba.dubbo.rpc.Filter后，采用此配置类 实例化 到bean容器中。

b. 定义了dubbo生产者和消费者的xml文件路径。

c. 其他（暂未了解）