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

相关文章

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件: 2.调用utility bar api的方式有两种: 方法一,通过lwc调用: import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca

如何解决线上平台抽佣高 线下门店客流少的痛点!

目前,许多传统零售店铺正遭遇客源下降的难题。尽管广告推广能带来一定的客流,但其费用昂贵。鉴于此,众多零售商纷纷选择加入像美团、饿了么和抖音这样的大型在线平台,但这些平台的高佣金率导致了利润的大幅缩水。在这样的市场环境下,商家之间的合作网络逐渐成为一种有效的解决方案,通过资源和客户基础的共享,实现共同的利益增长。 以最近在上海兴起的一个跨行业合作平台为例,该平台融合了环保消费积分系统,在短

AI基础 L9 Local Search II 局部搜索

Local Beam search 对于当前的所有k个状态,生成它们的所有可能后继状态。 检查生成的后继状态中是否有任何状态是解决方案。 如果所有后继状态都不是解决方案,则从所有后继状态中选择k个最佳状态。 当达到预设的迭代次数或满足某个终止条件时,算法停止。 — Choose k successors randomly, biased towards good ones — Close

pip-tools:打造可重复、可控的 Python 开发环境,解决依赖关系,让代码更稳定

在 Python 开发中,管理依赖关系是一项繁琐且容易出错的任务。手动更新依赖版本、处理冲突、确保一致性等等,都可能让开发者感到头疼。而 pip-tools 为开发者提供了一套稳定可靠的解决方案。 什么是 pip-tools? pip-tools 是一组命令行工具,旨在简化 Python 依赖关系的管理,确保项目环境的稳定性和可重复性。它主要包含两个核心工具:pip-compile 和 pip

【VUE】跨域问题的概念,以及解决方法。

目录 1.跨域概念 2.解决方法 2.1 配置网络请求代理 2.2 使用@CrossOrigin 注解 2.3 通过配置文件实现跨域 2.4 添加 CorsWebFilter 来解决跨域问题 1.跨域概念 跨域问题是由于浏览器实施了同源策略,该策略要求请求的域名、协议和端口必须与提供资源的服务相同。如果不相同,则需要服务器显式地允许这种跨域请求。一般在springbo

Thread如何划分为Warp?

1 .Thread如何划分为Warp? https://jielahou.com/code/cuda/thread-to-warp.html  Thread Index和Thread ID之间有什么关系呢?(线程架构参考这里:CUDA C++ Programming Guide (nvidia.com)open in new window) 1维的Thread Index,其Thread

速盾高防cdn是怎么解决网站攻击的?

速盾高防CDN是一种基于云计算技术的网络安全解决方案,可以有效地保护网站免受各种网络攻击的威胁。它通过在全球多个节点部署服务器,将网站内容缓存到这些服务器上,并通过智能路由技术将用户的请求引导到最近的服务器上,以提供更快的访问速度和更好的网络性能。 速盾高防CDN主要采用以下几种方式来解决网站攻击: 分布式拒绝服务攻击(DDoS)防护:DDoS攻击是一种常见的网络攻击手段,攻击者通过向目标网

Jenkins 插件 地址证书报错问题解决思路

问题提示摘要: SunCertPathBuilderException: unable to find valid certification path to requested target...... 网上很多的解决方式是更新站点的地址,我这里修改了一个日本的地址(清华镜像也好),其实发现是解决不了上述的报错问题的,其实,最终拉去插件的时候,会提示证书的问题,几经周折找到了其中一遍博文

线程的四种操作

所属专栏:Java学习        1. 线程的开启 start和run的区别: run:描述了线程要执行的任务,也可以称为线程的入口 start:调用系统函数,真正的在系统内核中创建线程(创建PCB,加入到链表中),此处的start会根据不同的系统,分别调用不同的api,创建好之后的线程,再单独去执行run(所以说,start的本质是调用系统api,系统的api

Redis中使用布隆过滤器解决缓存穿透问题

一、缓存穿透(失效)问题 缓存穿透是指查询一个一定不存在的数据,由于缓存中没有命中,会去数据库中查询,而数据库中也没有该数据,并且每次查询都不会命中缓存,从而每次请求都直接打到了数据库上,这会给数据库带来巨大压力。 二、布隆过滤器原理 布隆过滤器(Bloom Filter)是一种空间效率很高的随机数据结构,它利用多个不同的哈希函数将一个元素映射到一个位数组中的多个位置,并将这些位置的值置