当前位置: 首页 > news >正文

reactor的Hooks.enableAutomaticContextPropagation();不生效解决方案

1. pom中需要先增加如下的内容

<dependency><groupId>io.micrometer</groupId><artifactId>context-propagation</artifactId><version>1.1.2</version>
</dependency>

2. 注意,要看idea是否将context-propagation引入了。我的idea就是不知道为什么,虽然pom中添加了这个maven,mvn clean install 也通过了,但是在idea中的三方库就是没有。我进行了手动引入

3. 编写类继承ThreadLocalAccessor<String>。这个编写类的内容在官方文档中没有,坑人。因此按照官方文档,是不可能得到预期结果的

import io.micrometer.context.ThreadLocalAccessor;
import io.micrometer.context.ContextRegistry;public class CustomThreadLocalAccessor implements ThreadLocalAccessor<String> {public static final ThreadLocal<String> TL = new ThreadLocal<>();@Overridepublic Object key() {return "TLKEY";}@Overridepublic String getValue() {return TL.get();}@Overridepublic void setValue(String value) {TL.set(value);}@Overridepublic void reset() {TL.remove();}
}

4. 使用

   public static void main(String[] args) throws ClassNotFoundException {// 注册 ThreadLocalAccessorContextRegistry.getInstance().registerThreadLocalAccessor(new CustomThreadLocalAccessor());// 启用自动 Context 传播Hooks.enableAutomaticContextPropagation();// 假设 TL 是注册的 ThreadLocalCustomThreadLocalAccessor.TL.set("HELLO");String TLKEY = "TLKEY";String x =Mono.just(1).flatMap(v -> Mono.deferContextual(ctx->Mono.just(Thread.currentThread().getName()+"-"+"delayed ctx[" + TLKEY + "]=" + ctx.getOrDefault(TLKEY, "not found") + ", " +"TL=" + CustomThreadLocalAccessor.TL.get()))).contextWrite(ctx -> ctx.put(TLKEY, "HELLO")).flatMap(v -> Mono.deferContextual(ctx->Mono.just(Thread.currentThread().getName()+"-"+"delayed ctx[" + TLKEY + "]=" + ctx.getOrDefault(TLKEY, "not found") + ", " +"TL=" + CustomThreadLocalAccessor.TL.get()))).contextWrite(ctx -> Context.empty()).subscribeOn(Schedulers.boundedElastic()).block();System.out.println(x);}

相关文章:

reactor的Hooks.enableAutomaticContextPropagation();不生效解决方案

1. pom中需要先增加如下的内容 <dependency><groupId>io.micrometer</groupId><artifactId>context-propagation</artifactId><version>1.1.2</version> </dependency> 2. 注意&#xff0c;要看idea是否将context-propagati…...

DS复习提纲模版

数组的插入删除 int SeqList::list_insert(int i, int item) { //插入if (i < 1 || i > size 1 || size > maxsize) {return 0; // Invalid index or list is full}for (int j size-1; j > i-1; j--) { // Shift elements to the rightlist[j1] list[j];}li…...

蓝桥杯备赛:C++基础,顺序表和vector(STL)

目录 一.C基础 1.第一个C程序&#xff1a; 2.头文件&#xff1a; 3.cin和cout初识&#xff1a; 4.命名空间&#xff1a; 二.顺序表和vector&#xff08;STL&#xff09; 1.顺序表的基本操作&#xff1a; 2.封装静态顺序表&#xff1a; 3.动态顺序表--vector&#xff1a;…...

【LLM】概念解析 - Tensorflow/Transformer/PyTorch

背景 本文将从算法原理、适用范围、强项、知名大模型的应用、python 调用几个方面&#xff0c;对深度学习框架 TensorFlow、PyTorch 和基于深度学习的模型 Transformer 进行比较。主要作用是基础概念扫盲。 一、 算法原理对比 Transformer Transformer 是一种基于深度学习的…...

对一段已知行情用python中画出K线图~

1. 已知行情: 2024/09/05 ~ 2025/1/3 date open high low close 0 2024-09-05 2785.2635 2796.0186 2777.4710 2788.3141 1 2024-09-06 2791.7645 2804.0932 2765.6394 2765.8066 2 2024-09-09 2754.7237 2756.5560 2726.9667 2736.…...

Rocky Linux下安装meld

背景介绍&#xff1a; meld是一款Linux系统下的用于 文件夹和文件的比对软件&#xff0c;非常常用&#xff1b; 故障现象&#xff1a; 输入安装命令后&#xff0c;sudo yum install meld&#xff0c;报错。 12-31 22:12:17 ~]$ sudo yum install meld Last metadata expirat…...

DVWA靶场Insecure CAPTCHA(不安全验证)漏洞所有级别通关教程及源码审计

目录 Insecure CAPTCHA(不安全验证)low源码审计 medium源码审计 high源码审计 impossible源码审计 Insecure CAPTCHA(不安全验证) Insecure CAPTCHA&#xff08;不安全验证&#xff09;漏洞指的是在实现 CAPTCHA&#xff08;完全自动化公共图灵测试区分计算机和人类&#xff0…...

JavaScript HTML DOM 实例

JavaScript HTML DOM 实例 JavaScript 的 HTML DOM(文档对象模型)允许您通过脚本来控制 HTML 页面。DOM 是 HTML 文档的编程接口,它将 Web 页面与编程语言连接起来,使得开发者可以改变页面中的内容、结构和样式。在这篇文章中,我们将通过一系列实例来探讨如何使用 JavaSc…...

软件架构和软件体系结构的关系

软件架构&#xff08;Software Architecture&#xff09;和软件体系结构&#xff08;Software System Architecture&#xff09;这两个术语在日常使用中经常被交替使用&#xff0c;但它们在严格意义上有所区别&#xff1a; 1. **软件架构**&#xff1a; - 软件架构主要关注软件…...

C++并发:在线程间共享数据

1 线程间共享数据的问题 1.1 条件竞争 条件竞争&#xff1a;在并发编程中&#xff1a;操作由两个或多个线程负责&#xff0c;它们争先让线程执行各自的操作&#xff0c;而结果取决于它们执行的相对次序&#xff0c;这样的情况就是条件竞争。 诱发恶性条件竞争的典型场景是&am…...

GaussDB逻辑解码技术原理深度解析

GaussDB逻辑解码技术原理深度解析 一、背景介绍 在数字化转型的大潮中&#xff0c;异构数据库之间的数据同步需求日益增长。异构数据库同步指的是将不同类型、不同结构的数据库之间的数据进行同步处理&#xff0c;以确保数据在不同数据库之间的一致性。华为云提供的DRS服务&a…...

JAVA构造方法练习

要求在Student类中&#xff0c;&#xff08;task1&#xff09;添加一个有name和ID两个参数的构造方法&#xff0c;对成员变量name和ID进行初始化&#xff0c;&#xff08;task2&#xff09;实例化一个Student对象&#xff0c;学生姓名&#xff1a;Yaoming&#xff0c;ID&#x…...

Pytorch 三小时极限入门教程

一、引言 在当今的人工智能领域&#xff0c;深度学习占据了举足轻重的地位。而 Pytorch 作为一款广受欢迎的深度学习框架&#xff0c;以其简洁、灵活的特性&#xff0c;吸引了大量开发者投身其中。无论是科研人员探索前沿的神经网络架构&#xff0c;还是工程师将深度学习技术落…...

Rockect基于Dledger的Broker主从同步原理

1.前言 此文章是在儒猿课程中的学习笔记&#xff0c;感兴趣的想看原来的课程可以去咨询儒猿课堂 这篇文章紧挨着上一篇博客来进行编写&#xff0c;有些不清楚的可以看下上一篇博客&#xff1a; RocketMQ原理简述&#xff08;二&#xff09;-CSDN博客 2.Broker的高可用 如果…...

面向对象分析与设计Python版 面向对象的核心特征

文章目录 一、封装二、继承三、多态四、聚合/组合五、接口/实现六、抽象 一、封装 封装 Encapsulation 封装是隐藏对象实现细节的过程内部状态通常不能被其他对象访问对象的数据只能通过接口去访问封装使得对象可以被看成一个“黑盒子”它保护对象的内部状态不被其他对象破坏…...

CDP集群安全指南-静态数据加密

[一]静态数据加密的架构 CDP 支持两种加密组件&#xff0c;这些组件可以组合成独特的解决方案。在选择密钥管理系统&#xff08;KMS&#xff09;时&#xff0c;您需要决定哪些组件能够满足企业的密钥管理和加密需求。 CDP 加密组件 以下是 Cloudera 用于静态数据加密的组件描…...

RSA密码的安全性分析(简化版本)

RSA的安全性是基于分解大整数的困难性假定&#xff0c;之所以认为是假定是因为至今还未能证明大整数就是NP问题&#xff0c;也许有尚未发现的多项式时间分解算法。随着人类计算能力的不断提高&#xff0c;原来被认为是不可能分解的大数已经被成功分解。对于大整数的威胁除了人类…...

嵌入式linux系统中CMake的基本用法

第一:CMake的基本使用 在上篇文章中,我们聊了聊 Makefile。虽然它是 C/C++ 项目编译的“老司机”,但写起来真的是让人头大。尤其是当项目文件一多,手写依赖就像在搬砖,费时又费力。 那么问题来了,难道我们就没有更优雅的工具了吗?答案是:有! 这时候,CMake 就像一个…...

若依修改超级管理员admin的密码

通过接口方式或者页面 /system/user/resetPwd 需改其他用户的密码 修改其他用户的加密的密码&#xff0c;然后通过数据库将admin更新为这个密码就修改好了...

matlab中高精度计算函数vpa与非厄米矩阵本征值的求解

clear;clc;close all tic %并行设置% delete(gcp(nocreate));%关闭之前的并行 cparcluster(local); c.NumWorkers50;%手动设置线程数(否则默认最大线程为12) parpool(c, c.NumWorkers); %并行设置%w1; u2.5;N30;valstozeros(2*N2,100); v10linspace(-3,3,100).;parfor jj1:leng…...

3分钟掌握Fideo:跨平台直播录制的终极解决方案

3分钟掌握Fideo&#xff1a;跨平台直播录制的终极解决方案 【免费下载链接】fideo-live-record A convenient live broadcast recording software! Supports Tiktok, Youtube, Twitch, Bilibili, Bigo!(一款方便的直播录制软件! 支持tiktok, youtube, twitch, 抖音&#xff0c;…...

biliTickerBuy终极指南:5分钟掌握B站会员购抢票技巧

biliTickerBuy终极指南&#xff1a;5分钟掌握B站会员购抢票技巧 【免费下载链接】biliTickerBuy b站会员购购票辅助工具 项目地址: https://gitcode.com/GitHub_Trending/bi/biliTickerBuy 在B站会员购的热门演出和限量周边抢购中&#xff0c;你是否总是因为手速不够快、…...

k8s PDB(Pod Disruption Budget)介绍(集群维护或调度时,确保足够Pod)minAvailable、maxUnavailable、自愿中断、kubectl drain、HPA

文章目录Kubernetes PDB&#xff08;Pod Disruption Budget&#xff09;详解一、什么是 PDB&#xff1f;二、什么是“自愿中断”&#xff1f;1. 自愿中断&#xff08;PDB 可控制&#xff09;2. 非自愿中断&#xff08;PDB 无法控制&#xff09;三、PDB 的核心字段1. minAvailab…...

群晖Docker部署Calibre Web踩坑全记录:从权限报错到Kindle推送,一篇讲透所有常见问题

群晖Docker部署Calibre Web全流程避坑指南&#xff1a;从权限配置到Kindle推送实战 每次打开硬盘里堆积如山的电子书却无从下手时&#xff0c;一个得力的书库管理系统就显得尤为重要。作为电子书爱好者的终极解决方案&#xff0c;Calibre Web以其优雅的界面和强大的功能赢得了众…...

Windows 11经典游戏兼容性终极指南:5分钟快速修复方案

Windows 11经典游戏兼容性终极指南&#xff1a;5分钟快速修复方案 【免费下载链接】dxwrapper Fixes compatibility issues with older games running on Windows 10/11 by wrapping DirectX dlls. Also allows loading custom libraries with the file extension .asi into ga…...

避坑指南:用System Generator生成FPGA滤波代码,为什么我劝你谨慎?

警惕图形化工具陷阱&#xff1a;FPGA数字滤波开发的硬核真相 在FPGA开发领域&#xff0c;图形化设计工具如System Generator常被宣传为"快速实现复杂算法"的银弹。许多初入行的工程师会被其直观的拖拽界面和自动代码生成功能所吸引&#xff0c;尤其是在处理数字滤波这…...

WindowsCleaner终极指南:3步解决C盘爆红,让系统重获新生

WindowsCleaner终极指南&#xff1a;3步解决C盘爆红&#xff0c;让系统重获新生 【免费下载链接】WindowsCleaner Windows Cleaner——专治C盘爆红及各种不服&#xff01; 项目地址: https://gitcode.com/gh_mirrors/wi/WindowsCleaner 你是否经常遇到C盘空间不足的警告…...

从零到一:用CH32V103和逐飞库搞定智能车循迹(附完整代码和避坑指南)

从零到一&#xff1a;基于CH32V103的智能车循迹系统全流程实战 第一次接触智能车循迹项目时&#xff0c;面对琳琅满目的硬件和复杂的控制算法&#xff0c;很多初学者都会感到无从下手。本文将带你完整走一遍从硬件选型到PID调参的全过程&#xff0c;使用CH32V103R8T6作为主控芯…...

别再只会用默认设置了!Matplotlib contourf画等高线图,这5个美化技巧让你的论文配图秒变高级

科研制图进阶&#xff1a;5个Matplotlib等高线图精修技巧 在学术论文写作中&#xff0c;一张精心设计的图表往往比千言万语更能清晰传达研究成果。Matplotlib作为Python生态中最主流的科学绘图工具&#xff0c;其contourf函数生成的等高线填充图在气象学、地质学、工程仿真等领…...

高效PCB逆向分析:OpenBoardView专业电路板查看器深度实战指南

高效PCB逆向分析&#xff1a;OpenBoardView专业电路板查看器深度实战指南 【免费下载链接】OpenBoardView View .brd files 项目地址: https://gitcode.com/gh_mirrors/op/OpenBoardView 面对复杂的电路板设计文件&#xff0c;你是否曾因无法直接查看.brd文件而束手无策…...