【Dubbo】Dubbo简单自定义链路传递traceId

需求

因为服务器内存不足,没有引入链路追踪的框架,项目使用到了Dubbo,所有通过self4j的MDC和Dubbo的RpcContext实现简单的traceId 的多服务模块的传递

解决思路

  1. 在第一个模块生成traceId(比如网关模块),生成traceId,并存入MDC,RpcContext,请求头等地方,使用完在响应时进行删除
  2. 如果是Dubbo的Rpc调用则能将traceId传递到服务提供者模块,服务端通过过滤器进行拦截,加入到自己的MDC,RpcContext,使用完后清除
  3. 如果是网关的转发请求,则通过请求头进行转发traceId,下游模块存入自己的MDC,RpcContext,使用完后清除
  4. 因为Dubbo的RpcContext每次调用服务端方法后,消费端的RpcContext就会被清除,所有通过MDC在每次rpc调用前通过调用前过滤器再加上traceId

版本

        <dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>3.1.6</version></dependency>

解决方案

Dubbo消费端过滤器

就是调用服务器提供者的接口前,在消费端先过滤,加一点参数啥的,再转发

以下默认已经配置好,并写好了Dubbo远程调用服务,并能够进行调用。在此基础上进行过滤器添加。

1 . 代码

@Activate(group = {CommonConstants.CONSUMER}, order = -30000)
@Slf4j
public class RemoteTraceIdFilter implements Filter {private static final String TRACE_ID = "traceId";@Overridepublic Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {// 消费者RpcServiceContext currentServiceContext = RpcContext.getCurrentServiceContext();boolean consumerSide = currentServiceContext.isConsumerSide();if (consumerSide) {String traceId = MDC.get(TRACE_ID);if(traceId==null){traceId = UUID.randomUUID().toString();}//消费者 将trace_id(业务流水号) set至上下文中RpcContext.getClientAttachment().setAttachment(TRACE_ID, traceId);} else {// 服务提供者
//            String traceId = RpcContext.getClientAttachment().getAttachment(TRACE_ID);String traceId = RpcContext.getServerAttachment().getAttachment(TRACE_ID);if (traceId == null) {traceId = UUID.randomUUID().toString();}//slf4j 中设置了日志打印格式用作日志链路追踪MDC.put(TRACE_ID, traceId);}try {return invoker.invoke(invocation);} finally {if (RpcContext.getCurrentServiceContext().isProviderSide()) {MDC.remove(TRACE_ID);}else{RpcContext.getClientAttachment().removeAttachment(TRACE_ID);}}}
}
  1. 配置
    在这里插入图片描述1. 创建Resource相关配置(可以参考官方文档 官网)
--META-INF
----dubbo
------org.apache.dubbo.rpc.Filter文件内容(traceId是自定义的,具体看官网)
traceId = 类路径

Dubbo服务提供端过滤器

一个样不赘述

问题

  1. 每次RpcContext中存入值,在过滤器finally都要删除防止内存泄漏
  2. 每次RpcContext中存入值,并调用一次接口后,在消费端再次获取时会获取不到,因为已经被自动删除了,所有此处用了MDC配合RpcContext实现了traceId的保留。
    具体看官网: 链路传递
  3. 侵入性比较高,实现也比较粗糙,如果条件允许建议直接使用sentinel等专业高级好用的框架直接实现链路的追踪

总结

此方式只是一个简单的实现,真实场景允许条件下直接使用sentinel等专门框架完成的限流链路追踪的功能。

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

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

相关文章

python文件 成绩分析

‘’文件score.txt中存储了学生的考试信息,内容如下 小明,98 小刚,90 小红,91 小王,98 小刘,80 请写代码,读取文件数据,并进行如下分析 最高分和最低分分别是多少&#xff1f;得最高分的学生有几个&#xff1f; 得最低分的学生有几个平均分是多少&#xff1f; ‘’’ def rea…

【办公类-21-16】 20240410三级育婴师 344多选题(题目与答案合并word)

作品展示 背景需求&#xff1a; 前文将APP题库里的育婴师题目下载到EXCEL&#xff0c;并进行手动整理【办公类-21-14】 20240406三级育婴师 344道多选题 UIBOT下载整理-CSDN博客文章浏览阅读287次&#xff0c;点赞8次&#xff0c;收藏9次。【办公类-21-14】 20240406三级育婴师…

Spring AOP (一)

本篇主要介绍Spring AOP的基础概念和入门使用 一、AOP的基本概念 AOP是一种面向切面编程的思想&#xff0c;它与IOC并称为Spring 的两大核心思想。什么是面向切面编程呢&#xff0c;具体来说就是对一类事情进行集中统一处理。这听起来像不像前面篇章中所介绍的统一功能处理&am…

二叉树之AVL树

文章目录 1. AVL树的概念&#xff08;logN)1.1背景1.2规则 2.AVL树节点的定义3.AVL树的插入4. AVL树的旋转(重点&#xff09;4.1 新节点插入较高的右子树的右侧&#xff1a;左单璇&#xff1b;4.2 新节点插入较高左子树的左侧&#xff1a;右单璇&#xff1b;4.3&#xff08;双旋…

Axure引用ECharts图表 解决火狐浏览器出错

Axure原型添加Echarts图表&#xff0c;没耐心看文章的可以直接下载示例 Axure中使用ECharts图表示例 1. 打开Axure新建页面 2. 页面添加元件 元件类型随意&#xff0c;矩形、动态面板、热区、图片 甚至段落都可以3. 命名元件 随意命名&#xff0c;单个页面用到多个图表时名…

【读书笔记】 针对ICS的ATTCK矩阵详解(二)

三、持续控制&#xff08;Persistence&#xff09; 该阶段&#xff1a;攻击者试图在您的 ICS 环境中保持其立足点。 持久性包括攻击者用来在重启、更改凭据和其他可能切断其访问的中断时保持对 ICS 系统和设备的访问的技术。用于持久性的技术包括任何访问、操作或配置更改&…

imx6ull设备树驱动--pinctl、ioctl

添加pinctl节点 进入arch/arm/boot/dts目录下dts文件 在iomuxc下添加pinctlled节点 将 GPIO1_IO03 这个 PIN 复用为 GPIO1_IO03&#xff0c;电气属性&#xff08;配置GPIO一些列寄存器&#xff09;值为 0X10B0 添加led设备节点 与上一节一样&#xff0c;在 / 下面添加设备节…

知攻善防应急靶场-Windows(Web1-2-3)

知攻善防应急靶场-Web1 1.要求 2.过程 直接扫网站根目录 发现后门 <?php error_reporting(0); session_start();$key"e45e329feb5d925b"; //该密钥为连接密码32位md5值的前16位&#xff0c;默认连接密码rebeyond$_SESSION[k]$key;session_write_close();$postf…

Pytest精通指南(24)钩子函数-随机执行(pytest-random-order)

文章目录 前言应用场景插件安装参数分析使用方法 前言 pytest-random-order 是一个pytest插件&#xff0c;用于在每次运行测试套件时随机化测试用例的执行顺序。 它可以帮助识别和避免依赖于特定测试执行顺序的问题&#xff0c;从而提高测试的健壮性和可靠性。 应用场景 测试无…

遇到you-get下载报错问题解决

pip3 install you-get安装这里就不赘述了&#xff0c;如果你还不会安装&#xff0c;说明这篇文章不适合你&#xff0c;这篇文章主要解决当执行you-get的报错&#xff1a; 当然你可以加选项–debug具体看一下到底报什么错。 第一步 替换文件 首先&#xff0c;我们下载仓库最新…

https协议的加密方式详解

各位大佬能多多点赞关注评论收藏&#xff0c;球球各位大佬们了&#xff01;&#xff01; &#xff01; 目录 1.为什么要加密&#xff1f; 2.如何加密 1.密钥&#xff08;yue,第四声&#xff09; 2.对称加密 3.非对称加密 4.公证机构 3.总结 1.为什么要加密&#xff1f;…

探索通过GPT和云平台搭建网安实战培训环境

项目背景 网络安全是一个不断演变的领域&#xff0c;面临着日益复杂的挑战和不断扩大的威胁。数字化时代&#xff0c;随着勒索攻击、数据窃取、网络钓鱼等频频出现&#xff0c;网络攻击的威胁指数和影响范围进一步增加&#xff0c;如何防范网络攻击&#xff0c;确保数据安全&a…