集成Spring Reactor

[driventokill]

No description provided.

[driventokill]

看到 project reactor 已经集成了一个 ThreadLocal 的传递机制 enableAutomaticContextPropagation()：

public static void enableAutomaticContextPropagation() {
    if (ContextPropagation.isContextPropagationOnClasspath) {
        Hooks.addQueueWrapper(
                CONTEXT_IN_THREAD_LOCALS_KEY, ContextPropagation.ContextQueue::new
        );
        Schedulers.onScheduleHook(
                CONTEXT_IN_THREAD_LOCALS_KEY,
                ContextPropagation.scopePassingOnScheduleHook()
        );
        ContextPropagation.propagateContextToThreadLocals = true;
    }
}

具体的实现是通过micrometer-metrics/context-propagation