dubbo 隐式传参+过滤器
- dubbo,web(消费端)与service(提供端)rpc通信,要传递的实体类必须序列化;有着不同的上下文,web的session,service无法获取。
- 方案:web获取当前登录人名称,传入RpcContext上下文,隐式传参到service端。通过调用拦截器拦截消费断调用方法,调用前传。
- 因项目需要,service模块无法获取session,无法获取当前登陆账户。临时采取这种方案,将web端当前登陆用户名传递给RpcContext上下文,供service使用。
- 先配置调用拦截器,传入用户名到上下文。
@Activate(group={CommonConstants.CONSUMER},order = -10000)
public class RpcContextFilter implements Filter{
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException{
if(PrcContext.getContext.isConsumerSide()){
String name = LoginUser.getLoginUserName();
if(null != name){
RpcContext.getContext().setAttachment("userName",name);
}
}
return invoker.invoke(invocation);
}
}
- 然后配置文件(spi方式):配置文件META-INF下创建dubbo文件夹,然后创建纯文件org.apache.dubbo.rpc.Filter。内容xxx = com.xx.x.x.RpcContextFilter,xxx为自定义名称。
dubbo配置文件需要。
dubbo.consumer.filter = xxx
- 注意!2.7阿里捐赠apache后Filter是这个文件名,2.6和之前到可能还是com.alibab.xxx。
|