如何用单声道的数据丰富Reactor的上下文？

Question

有可能在订阅时用以下一些数据丰富Reactor的序列上下文：

java prettyprint-override">Mono.just("Hello")
    .flatMap(s -> Mono.deferContextual(ctx -> Mono.just(s + " " + ctx.get(key)))) 
    .contextWrite(ctx -> ctx.put(key, "World")); 

然而，这里的World是一种在订阅时知道的静态数据。

我想从最初的Mono本身解析一个值，并将其放入上下文中，以便下游操作员可以通过上下文API访问它。

我怎样才能正确地做到这一点？

我正在研究的用例如下：

• 我通过异步SDK从AWS接收到一条SQS消息，该消息被解析为Reactor的单声道
• 一个消息有一个correlation_id在里面，我想提取它并把它放到Reactor上下文中，使它对所有下游操作员可见。

Answer 1

目前，用我找到的最初Mono中的数据来丰富Reactor上下文的唯一选择是用Mono将所有处理打包成flatMap。延迟上下文（）。。。contextWrite（）内部如下所示：

Mono.just("test")
        .flatMap(s ->
                Mono.deferContextual(ctx -> {
                    System.out.println("key1=" + ctx.getOrEmpty("key")); // Context in place
                    return Mono.just(s);
                }).contextWrite(ctx -> ctx.put("key", s)))
        .flatMap(s -> Mono.deferContextual(ctx -> {
            System.out.println("key2=" + ctx.getOrEmpty("key")); // No Context
            return Mono.just(s);
        }));

我希望有人能提出更好的解决方案。