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

相关文章

Linux线程之线程的创建、属性、回收、退出、取消方式

《Linux线程之线程的创建、属性、回收、退出、取消方式》文章总结了线程管理核心知识:线程号唯一、创建方式、属性设置(如分离状态与栈大小)、回收机制(join/detach)、退出方法(返回/pthr... 目录1. 线程号2. 线程的创建3. 线程属性4. 线程的回收5. 线程的退出6. 线程的取消7.

Linux下进程的CPU配置与线程绑定过程

《Linux下进程的CPU配置与线程绑定过程》本文介绍Linux系统中基于进程和线程的CPU配置方法,通过taskset命令和pthread库调整亲和力,将进程/线程绑定到特定CPU核心以优化资源分配... 目录1 基于进程的CPU配置1.1 对CPU亲和力的配置1.2 绑定进程到指定CPU核上运行2 基于

Java中读取YAML文件配置信息常见问题及解决方法

《Java中读取YAML文件配置信息常见问题及解决方法》:本文主要介绍Java中读取YAML文件配置信息常见问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录1 使用Spring Boot的@ConfigurationProperties2. 使用@Valu

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

SQL Server配置管理器无法打开的四种解决方法

《SQLServer配置管理器无法打开的四种解决方法》本文总结了SQLServer配置管理器无法打开的四种解决方法,文中通过图文示例介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的... 目录方法一:桌面图标进入方法二:运行窗口进入检查版本号对照表php方法三:查找文件路径方法四:检查 S

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因(调度随机、变量修改、非原子操作、内存可见性、指令重排序)及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操

Redis出现中文乱码的问题及解决

《Redis出现中文乱码的问题及解决》:本文主要介绍Redis出现中文乱码的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 问题的产生2China编程. 问题的解决redihttp://www.chinasem.cns数据进制问题的解决中文乱码问题解决总结

Python中Tensorflow无法调用GPU问题的解决方法

《Python中Tensorflow无法调用GPU问题的解决方法》文章详解如何解决TensorFlow在Windows无法识别GPU的问题,需降级至2.10版本,安装匹配CUDA11.2和cuDNN... 当用以下代码查看GPU数量时,gpuspython返回的是一个空列表,说明tensorflow没有找到

解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题

《解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题》:本文主要介绍解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4... 目录未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘打开pom.XM