将上下文从一个通量/单声道传递到另一个通量/单声道

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中。我试图弄清楚这是如何做到的，也是为了单元测试的目的。

最后，这仍然是一个谜。我试图用单声道/通量对象上可用的常规方法来做到这一点，但是我没有成功地使你好上下文对世界单声道可用。你如何融合通量和单声道，并将上下文传递给上游操作符？

Answer 1

WebFlux利用你的世界Mono并在其上构建一个反应链，以reactor netty中的HTTP请求作为最终源。WebFilter是链构造的一部分，因此它们可以丰富整个链的上下文。

IIRCMono.subscriberContext（）将在一个平映射中使用，这使得主序列Context对其内部人员可用，因此它可以看到Hello的Context。

Answer 2

你想做几件事：

1.）发布订阅服务器上下文

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

2.）订阅/访问用户上下文

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())
})

这是一个粗略的大纲——还没有准备好“原样”，但它应该有助于你理解模式。

祝你好运