transmittable-thread-local在slf4j中解决MDC线程池中上下文传递

本文主要是介绍transmittable-thread-local在slf4j中解决MDC线程池中上下文传递,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

TTL描述了四种场景

TTL在日志收集系统的两种实现

TTL在snowball-common中的应用

应用升级snowball-common


 

直接我球docs粘过来的,我不用写两份,欢迎投递简历:https://github.com/singgel  

transmittable-thread-local以下简称:TTL

根据InheritableThreadLocal在线程池中上下文传递的问题可以知道这个threadLocal的值传递,在父子线程之间若使用了线程池的技术,会导致子线程的threadLocal信息错乱。

根据分布式追踪系统场景下,如何使用TTL 知道ttl的实现原理,通过线程池的封装,threadLocal的继承实现了traceId的传递,采用weakHashMap取代引用计数的方法实现了GC的回收防止内存泄漏。

 

以下具体问题具体分析,给出的是以agent方式代码无侵入接入

 

TTL描述了四种场景

  1. 分布式跟踪系统
  2. 日志收集记录系统上下文
  3. SessionCache
  4. 应用容器或上层框架跨应用代码给下层SDK传递信息

分布式跟踪系统

snowball-common里的traceId是不是TTL推荐的分布式追踪系统场景下,如何使用TTL ,根据issue的描述,文章讲的是分布式追踪相关的设计和ttl在其中的应用,而在snowball-common的问题里,是关于slf4j的MDC问题,若继续探究请进入:APM 模块

日志收集记录系统

根据InheritableThreadLocal在线程池中上下文传递的问题,知道InheritableThreadLocal这个类完成了上下文传递,但是由于池的存在,当线程被下一次重复使用的时候,由于Map的内容没有更新,出现了traceId的重复(也就是不对应)

Session级Cache、应用容器给下层SDK传递信息

这两个不属于本次所讨论内容。。。

 

TTL在日志收集系统的两种实现

  • log4j2-ttl-thread-context-map
    pom.xml

    <dependency>

        <groupId>com.alibaba</groupId>

        <artifactId>log4j2-ttl-thread-context-map</artifactId>

        <version>1.3.0</version>

        <scope>runtime</scope>

    </dependency>

    只需将此依赖项添加到您的项目中即可激活Log4j2 TTL ThreadContextMap

    通过log4j2.threadContextMap=com.alibaba.ttl.log4j2.TtlThreadContextMap的方式将MDC的adapter实现进行替换
     

  •  logback-mdc-ttl
    pom.xml

    <dependency>

        <groupId>com.ofpay</groupId>

        <artifactId>logback-mdc-ttl</artifactId>

        <version>1.0.2</version>

    </dependency>

    在Java的启动参数加上:

    -Xbootclasspath/a:/path/to/transmittable-thread-local-2.x.x.jar

    -javaagent:/path/to/transmittable-thread-local-2.x.x.jar

    在logback配置文件中增加TtlMdcListener

    <?xml version="1.0" encoding="UTF-8"?>

    <configuration >

    <!-- ...(略) -->

    <contextListener class="com.ofpay.logback.TtlMdcListener"/>

    <!--例子: %X{uuid} 支持在跨线程池时传递-->

    <property scope="context" name="APP_PATTERN"

    value='%d{yyyy-MM-dd HH:mm:ss.SSS}|%X{uuid}|%level|%M|%C\:%L|%thread|%replace(%.-2000msg){"(\r|\n)","\t"}|"%.-2000ex{full}"%n'/>

    </configuration>

    通过将contextListener的方式,将MDC的adapter实现进行替换

TTL在snowball-common中的应用

snowball-common在webFilter中将应用接收的请求,采用Twitter的finagle框架自带的TraceID放入到MDC中,而且整个采用了slf4j的日志框架

 

因此,就基于logback-mdc-ttl的方案对snowball-common进行升级

pom.xml引入

<dependency>

    <groupId>com.ofpay</groupId>

    <artifactId>logback-mdc-ttl</artifactId>

    <version>1.0.2</version>

    <exclusions>

        <exclusion>

            <groupId>com.alibaba</groupId>

            <artifactId>transmittable-thread-local</artifactId>

        </exclusion>

    </exclusions>

</dependency>

<dependency>

    <groupId>com.alibaba</groupId>

    <artifactId>transmittable-thread-local</artifactId>

    <version>2.11.0</version>

</dependency>

至此,升级工作完毕

 

应用升级snowball-common

pom.xml

在snowball-common的version版本>-5.0.3

<dependency>

    <groupId>com.xueqiu.snowball</groupId>

    <artifactId>snowball-common</artifactId>

    <!-- version 大于等于5.0.3 -->

    <version>5.0.3</version>

</dependency>

pom引入agent的依赖包

<dependency>

    <groupId>com.alibaba</groupId>

    <artifactId>transmittable-thread-local</artifactId>

    <version>2.11.0</version>

</dependency>

start_server.sh

在启动脚本上添加JVM参数,将agent的路径换成自己的

-javaagent:../lib/transmittable-thread-local-2.11.0.jar

-Xbootclasspath/a:../lib/transmittable-thread-local/2.11.0/transmittable-thread-local-2.11.0.jar

logback.xml

在logback的配置问价中添加contextListener参数

<contextListener class="com.ofpay.logback.TtlMdcListener"/>

以上升级工作完毕

 

性能评估:

https://github.com/alibaba/transmittable-thread-local/blob/master/docs/performance-test.md

 

参考资料:

https://github.com/oldratlee/log4j2-ttl-thread-context-map

https://github.com/ofpay/logback-mdc-ttl

https://github.com/alibaba/transmittable-thread-local

https://www.infoq.cn/article/javaagent-illustrated

http://lovestblog.cn/blog/2014/06/18/jvm-attach/

这篇关于transmittable-thread-local在slf4j中解决MDC线程池中上下文传递的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/559017

相关文章

Springboot项目启动失败提示找不到dao类的解决

《Springboot项目启动失败提示找不到dao类的解决》SpringBoot启动失败,因ProductServiceImpl未正确注入ProductDao,原因:Dao未注册为Bean,解决:在启... 目录错误描述原因解决方法总结***************************APPLICA编

解决pandas无法读取csv文件数据的问题

《解决pandas无法读取csv文件数据的问题》本文讲述作者用Pandas读取CSV文件时因参数设置不当导致数据错位,通过调整delimiter和on_bad_lines参数最终解决问题,并强调正确参... 目录一、前言二、问题复现1. 问题2. 通过 on_bad_lines=‘warn’ 跳过异常数据3

解决RocketMQ的幂等性问题

《解决RocketMQ的幂等性问题》重复消费因调用链路长、消息发送超时或消费者故障导致,通过生产者消息查询、Redis缓存及消费者唯一主键可以确保幂等性,避免重复处理,本文主要介绍了解决RocketM... 目录造成重复消费的原因解决方法生产者端消费者端代码实现造成重复消费的原因当系统的调用链路比较长的时

深度解析Nginx日志分析与499状态码问题解决

《深度解析Nginx日志分析与499状态码问题解决》在Web服务器运维和性能优化过程中,Nginx日志是排查问题的重要依据,本文将围绕Nginx日志分析、499状态码的成因、排查方法及解决方案展开讨论... 目录前言1. Nginx日志基础1.1 Nginx日志存放位置1.2 Nginx日志格式2. 499

SpringBoot监控API请求耗时的6中解决解决方案

《SpringBoot监控API请求耗时的6中解决解决方案》本文介绍SpringBoot中记录API请求耗时的6种方案,包括手动埋点、AOP切面、拦截器、Filter、事件监听、Micrometer+... 目录1. 简介2.实战案例2.1 手动记录2.2 自定义AOP记录2.3 拦截器技术2.4 使用Fi

kkFileView启动报错:报错2003端口占用的问题及解决

《kkFileView启动报错:报错2003端口占用的问题及解决》kkFileView启动报错因office组件2003端口未关闭,解决:查杀占用端口的进程,终止Java进程,使用shutdown.s... 目录原因解决总结kkFileViewjavascript启动报错启动office组件失败,请检查of

SQL Server安装时候没有中文选项的解决方法

《SQLServer安装时候没有中文选项的解决方法》用户安装SQLServer时界面全英文,无中文选项,通过修改安装设置中的国家或地区为中文中国,重启安装程序后界面恢复中文,解决了问题,对SQLSe... 你是不是在安装SQL Server时候发现安装界面和别人不同,并且无论如何都没有中文选项?这个问题也

Java Thread中join方法使用举例详解

《JavaThread中join方法使用举例详解》JavaThread中join()方法主要是让调用改方法的thread完成run方法里面的东西后,在执行join()方法后面的代码,这篇文章主要介绍... 目录前言1.join()方法的定义和作用2.join()方法的三个重载版本3.join()方法的工作原

java内存泄漏排查过程及解决

《java内存泄漏排查过程及解决》公司某服务内存持续增长,疑似内存泄漏,未触发OOM,排查方法包括检查JVM配置、分析GC执行状态、导出堆内存快照并用IDEAProfiler工具定位大对象及代码... 目录内存泄漏内存问题排查1.查看JVM内存配置2.分析gc是否正常执行3.导出 dump 各种工具分析4.

Java中的xxl-job调度器线程池工作机制

《Java中的xxl-job调度器线程池工作机制》xxl-job通过快慢线程池分离短时与长时任务,动态降级超时任务至慢池,结合异步触发和资源隔离机制,提升高频调度的性能与稳定性,支撑高并发场景下的可靠... 目录⚙️ 一、调度器线程池的核心设计 二、线程池的工作流程 三、线程池配置参数与优化 四、总结:线程