将上下文从一个 flux/mono 传递到另一个

Question

webflux 包中发生了一些有趣的事情。但是，我的源代码之旅并没有解决以下问题。

假设我有以下单声道（或通量）：

Mono hello = Mono.empty()
            .subscriberContext(ctx -> ctx.put("message", "hello"));

我在 webfilter 中使用类似的构造来丰富包含租户和用户数据的管道。然后在控制器中使用这样的构造：

Mono world = Mono.subscriberContext()
            .map(ctx -> (String)ctx.get("message"));

hello mono 的上下文填充在 world mono 中。我试图弄清楚这是如何完成的，也用于单元测试目的。

到头来还是个谜。我尝试使用两个 mono/flux 对象上可用的常规方法来执行此操作，但我没有成功地使 hello 上下文对 world mono 可用。您如何融合通量和单声道并将上下文传递给上游运算符？

Answer 1

WebFlux 采用您的 world Mono 并在其之上构建反应链，并以 reactor-netty 中的 HTTP 请求作为最终来源。 WebFilter是链建设的一部分，因此可以丰富整个链的Context。

IIRC Mono.subscriberContext() 将在 flatMap 中使用，这使得主序列 Context 对其内部可用，因此它可以看到 Context 17=].

Answer 2

您想做几件事：

1.) 发布订阅者上下文

mono.subscriberContext({ Context context ->
    context.put("key", "value")
})

2.) Subscribe/access 订户上下文

mono.flatMap({ def r ->
    return Mono.subscriberContext().map({ Context context ->
        context.get("key")
        context.get("keyOrMapOrStateObject").put("someKey", "someData")
        return r
    })
})

3.) 可能将数据从一个事件传递到下游事件

mono.flatMap({ def r ->
    return Mono.subscriberContext().map({ Context context ->
        def someData = context.get("keyOrMapOrStateObject").get("someKey")
        return r
    })
})

整体看起来像这样：（这是 groovy 语法）

mono.flatMap({ def r ->
    return Mono.subscriberContext().map({ Context context ->
        context.get("key")
        context.get("keyOrMapOrStateObject").put("someKey", "someData")
        return r
    })
}).flatMap({ def r ->
    return Mono.subscriberContext().map({ Context context ->
        def someData = context.get("keyOrMapOrStateObject").get("someKey")
        return r
    })
}).subscriberContext({ Context context ->
    context.put("key", "value")
    context.put("keyOrMapOrStateObject", new HashMap())
})

这是一个粗略的大纲 - 尚未准备好 'as is' 但它应该可以帮助您理解模式。

祝你好运！

将上下文从一个 flux/mono 传递到另一个

Pass a context from one flux/mono to another

java

project-reactor

spring-webflux