从反应流中保留上下文

问题描述

有人能帮我理解上下文是如何在响应式流中传递的吗？ 参见下面的代码示例：

Flux<Integer> expectedFluxWithContext = Flux.just(1,2,3,4)
        .flatMap(item -> Mono.just(item).contextWrite(Context.of("traceId",item)))
        .doOnEach(signal -> System.out.println(signal.getContextView()));

当我运行上述代码时，我得到了预期的正确数据，但在 doOnEach 运算符中，上下文为空。

任何人都可以帮助我了解流中的上下文是如何共享的，以及我可以进行哪些更改以使其工作。

解决方法

上下文仅在管道中“向上”可用，因为它在订阅时附加，并且不知道下游的任何内容。它并不意味着传递在管道执行期间获得的东西，如果您想“传递”它，您可能需要使用元组。

有关更多信息，我建议阅读 Reactor 参考指南的相应部分： https://projectreactor.io/docs/core/release/reference/#context