如何在工程反应堆中传递线程局部变量 [英] How to pass thread local variable in Project Reactor
本文介绍了如何在工程反应堆中传递线程局部变量的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我开始使用项目反应堆。有人知道如何将线程局部变量从一个线程传递到另一个线程吗?我在Hooks.java
上看到了一些方法,但不知道推荐的方法是什么。谁能给我一些文档或代码片段告诉我如何做到这一点。谢谢。
推荐答案
我在这个giHub存储库中有一个基于spring-cloud-sleuth实现的工作示例:https://github.com/gumartinm/JavaForFun/tree/master/SpringJava/WebReactive/spring-webreactive-reactor-context-enrich
关键类有:ContextCoreSubscriber.java、SubscriberContext.java、ThreadContextEnrichmentAutoConfiguration.java和UsernameFilter.java
- ContextCoreSubscriber.java:
使您能够填充映射的诊断上下文:MDC - SubscriberConext.java:
用于在反应器的上下文中插入数据的帮助器类。 - ThreadContextEnrichmentAutoConfiguration.java:
负责配置反应堆挂钩:Hooks.onEachOperator - UsernameFilter.java:
我们希望根据某个HTTP标头注册用户名信息的示例。
这篇关于如何在工程反应堆中传递线程局部变量的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文