Dubbo秘密传递:让你的代码行云流水

在Dubbo使用过程中,有一些通用参数如果显式的在接口参数中传递,使用起来会有一些不方便。

比如:经常使用的用户信息、token等上下文信息,如果都放入参数中传递,这样会耦合到业务逻辑中了,这时隐式传参就是一种比较好的处理方式了。

隐式传参

Dubbo提供了RpcContext隐式传参的方式:

//消费侧传入参数
RpcContext.getContext().setAttachment(String key, String value);//服务提供侧接收参数
RpcContext.getContext().getAttachment(String key);

通过上面两个方法,我们可以在消费端传入参数,然后在提供侧就可以接收到参数了,类似于线程变量ThreadLocal

为了更好的兼顾Dubbo多重调用导致隐式传参丢失的问题,我们可以在每个Dubbo服务程序中加入两个filter可解决问题

创建Filter

消费侧:

import java.util.HashMap;
import java.util.Map;import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;
import com.alibaba.dubbo.rpc.RpcContext;
import com.alibaba.dubbo.rpc.RpcException;
import com.alibaba.fastjson.JSONObject;@Activate(group = {Constants.CONSUMER})
public class DubboConsumerContextFilter implements Filter {@Overridepublic Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {RpcContext.getContext().setAttachment("token", "tokenvalue");return invoker.invoke(invocation);}
}

服务提供侧:

import java.util.Map;import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;
import com.alibaba.dubbo.rpc.RpcContext;
import com.alibaba.dubbo.rpc.RpcException;
import com.alibaba.fastjson.JSONObject;@Activate(group = {Constants.PROVIDER})
public class DubboProviderContextFilter implements Filter {@Overridepublic Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {// 处理tokenString token = RpcContext.getContext().getAttachment("token");//TODO 处理代码return invoker.invoke(invocation);}
}

其中@Activate注解指定了这个Filter是在消费端生效还是服务端生效。

配置filter到META-INF中

在/src/main/resources/META-INF/dubbo/下新建文件,文件名为com.alibaba.dubbo.rpc.Filter,没错,这就是文件的名称,而不是包路径。

文件内容:

dubboProviderContextFilter=com.xxx.DubboProviderContextFilter
dubboConsumerContextFilter=com.xxx.DubboConsumerContextFilter

总结

经过以上简单的几步,我们在对业务代码无侵入的情况下,通过Filter实现了Dubbo远程调用中的隐式传参。这可以方便地在服务调用链中传递一些公共的上下文信息,如登录信息、请求ID等。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/238695.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

学习鸿蒙开发需要报培训班吗?

学习鸿蒙开发是否需要报培训班&#xff0c;取决于个人的学习需求和实际情况。 对于初学者来说&#xff0c;参加培训班可以提供系统的学习资源&#xff0c;有专业的老师指导&#xff0c;能够帮助快速入门&#xff0c;掌握基本知识和技能。同时&#xff0c;培训班通常会提供实践…

Linux 磁盘空间占满故障解决方法

故障排查&#xff1a; 使用命令查看磁盘使用量 # 使用人类可读的格式(预设值是不加这个选项的...) df -h # --inodes 列出 inode 资讯&#xff0c;不列出已使用 block df -i # 查看当前目录下各个文件及目录占用空间大小 du -sh / 情况一&#xff1a;一般磁盘空间满了&a…

vue3 使用addRoute动态添加路由,页面刷新就白屏解决办法

问题&#xff0c;通过接口动态添加路由&#xff0c;第一次从登录页跳转还是正常的&#xff0c;说明路由添加成功了&#xff0c;但是刷新后就白屏了&#xff0c;且控制台报错路由匹配不到&#xff0c;在项目的main.js&#xff0c;router和路由拦截器中添加了一大堆打印后发现&am…

【前缀和】【单调栈】LeetCode2281:巫师的总力量和

作者推荐 map|动态规划|单调栈|LeetCode975:奇偶跳 涉及知识点 单调栈 C算法&#xff1a;前缀和、前缀乘积、前缀异或的原理、源码及测试用例 包括课程视频 题目 作为国王的统治者&#xff0c;你有一支巫师军队听你指挥。 给你一个下标从 0 开始的整数数组 strength &…

isp代理/双isp代理/数据中心代理的区别?如何选择?

本文我们来详细科普一下几种不同的代理类型&#xff1a;isp代理/双isp代理/数据中心代理&#xff0c;了解他们的区别&#xff0c;选择更适合自己的代理类型。 在讲述这几种代理类型之前&#xff0c;我们先复习一下代理大类有哪几种。 一、机房代理和非机房代理 在做代理ip选…

一文弄懂kubernetes之Service

目录 ServiceService工作流程kube-proxyuserspaceiptablesIPVS EndpointsService负载分发策略Service属性Service定义多端口Service外部服务ServiceHeadless Services Service 在 kubernetes 中&#xff0c;Pod 是有生命周期的&#xff0c;如果 Pod 重启 IP 很有可能会发生变化…

【玩转TableAgent数据智能分析】借助全球高校数据多维度分析案例,体验TableAgent如何助力用户轻松洞察数据,赋能企业高效数智化转型

目录 前言 一、TableAgent介绍及其优势&#xff1f; 1、会话式数据分析&#xff0c;所需即所得 2、私有化部署&#xff0c;数据安全 3、支持企业级数据分析,大规模&#xff0c;高性能 4、支持领域微调&#xff0c;专业化 5、透明化过程&#xff0c;审计部署 二、使用Ta…

一起免费玩XG24-EK2703A板卡开发板,还有额外奖励等你拿!

hello大家好&#xff0c;我是硬核王同学&#xff0c;今天又看到了一个适合嵌入式初学者的免费参加的活动&#xff0c;迫不及待地就来跟大家分享&#xff01; Funpack活动是硬禾学堂联合DigiKey发起的“玩成功就全额退”活动。第一季和第二季已圆满结束&#xff0c;现在是第三季…

用radis扩展websockets服务

Redis可以存储会话数据&#xff0c;这使得不同的服务器可以共享WebSocket连接的状态。这意味着如果用户连接到服务器 A 然后重新连接到服务器 B&#xff0c;服务器 B 将知道现有连接。 此外&#xff0c;Redis 提供发布/订阅功能&#xff0c;使其成为向所有连接的客户端广播消息…

【Vue】动态合并行

前言&#xff1a; 开发中会经常使用到表格例如el-table&#xff0c;还会经常用到合并行或合并列&#xff0c;el-table提供了对应的方法&#xff0c;但是官方文档中的方法是固定的行数或列数&#xff0c;如果我们想要根据接口获取到的动态数据去合并行或合并列应该怎么实现呢&am…

Vue中的插槽和自定义指令

目录 一、插槽 1.默认插槽 2.具名插槽 3.作用域插槽 二、自定义指令 全局注册自定义指令 执行一次性初始化设置 组件vnode更新触发 局部注册自定义指令 一、插槽 父组件传递模板给子组件&#xff0c;子组件使用插槽声明slot元素承载分发内容出口。 1.默认插槽 父组件…

maven限制内存使用峰值/最大内存

前言 通过设置虚拟机的内存大小&#xff0c;达到限制maven内存使用峰值的效果 方法1&#xff1a;修改mvn脚本 找到mvn脚本在MAVEN_OPTS参数值添加-Xms、-Xmx参数&#xff1a;MAVEN_OPTS"$MAVEN_OPTS -Xms512m -Xmx512m"效果图 windows系统下修改MAVEN_OPTS参数 …

STM32CubeMX配置HAL库输入捕获

STM32CubeMX配置HAL库输入捕获 STM32的输入捕获功能可以用来测量脉冲宽度或者频率。其工作原理是&#xff0c;通过检测TIMx_CHx上的边沿信号&#xff0c;在边沿信号发生跳变&#xff08;比如 上升沿/下降沿&#xff09;的时候&#xff0c;将当前定时器的值&#xff08;TIMx_C…

Open3D点云处理简明教程

推荐&#xff1a;用NSDT编辑器快速搭建可编程3D场景 这是“激光雷达入门”文章的延续。 在这篇文章中&#xff0c;我们将查看用于处理点云的 python 库和 Open3D 数据结构&#xff0c;执行可视化并操作点云数据&#xff0c;以便进行后续的分析处理。 如果你需要快速预览3D点云…

乐理基础-抽象的速度

通过 乐理基础-情绪与速度、具体的速度、BPM-CSDN博客 知道了具体的速度怎样去确定&#xff0c;通过 每分钟多少拍、音符等于多少、bpm方式&#xff0c;来精确形容每一拍的持续时间。 抽象的速度 或者说 不精确的速度&#xff1a; 抽象的速度一般有两种方式&#xff1a; 第一种…

vue组件,指令和自定义指令

本人详解 作者:王文峰,参加过 CSDN 2020年度博客之星,《Java王大师王天师》 公众号:JAVA开发王大师,专注于天道酬勤的 Java 开发问题中国国学、传统文化和代码爱好者的程序人生,期待你的关注和支持!本人外号:神秘小峯 山峯 转载说明:务必注明来源(注明:作者:王文峰…

modbus异常错误码说明

异常错误码说明 其中物理离散量输入和输入寄存器只能有I/O系统提供的数据类型&#xff0c;即只能是由I/O系统改变离散量输入和输入寄存器的数值&#xff0c;而上位机程序不能改变的数据类型&#xff0c;在数据读写上表现为只读&#xff0c;而内部比特或者物理线圈和内部寄存器或…

Fiddler抓包,怎么抓抓得好抓得快?

01.什么是 Fiddler? Fiddler 是一个 HTTP 协议调试代理工具&#xff0c;它能够记录并检查所有你的电脑和互联网之间的 HTTP 通讯。Fiddler 提供了电脑端、移动端的抓包、包括 http 协议和 https 协议都可以捕获到报文并进行分析&#xff1b;可以设置断点调试、截取报文进行请求…

虾皮广告怎么做:如何在虾皮平台上进行广告投放

在虾皮&#xff08;Shopee&#xff09;平台上进行广告投放可以帮助您提高产品的曝光度和销量。通过有针对性的广告&#xff0c;您可以在虾皮平台上吸引更多的潜在买家&#xff0c;提高产品的可见度并增加销售机会。本文将为您介绍在虾皮平台上创建和管理广告的一些建议&#xf…

058:vue组件引用外部js的方法

第058个 查看专栏目录: VUE ------ element UI 专栏目标 在vue和element UI联合技术栈的操控下&#xff0c;本专栏提供行之有效的源代码示例和信息点介绍&#xff0c;做到灵活运用。 &#xff08;1&#xff09;提供vue2的一些基本操作&#xff1a;安装、引用&#xff0c;模板使…