加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Java > 正文

java – 将上下文从一个flux / mono传递给另一个

发布时间:2020-12-15 01:09:23 所属栏目:Java 来源:网络整理
导读:有趣的事情发生在webflux包内.但是,我在源头的旅程没有解决以下问题. 假设我有以下单声道(或声音): Mono hello = Mono.empty() .subscriberContext(ctx - ctx.put("message","hello")); 我在webfilter中使用类似的构造来丰富具有租户和用户数据的管道.然后

有趣的事情发生在webflux包内.但是,我在源头的旅程没有解决以下问题.

假设我有以下单声道(或声音):

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

我在webfilter中使用类似的构造来丰富具有租户和用户数据的管道.然后在控制器中使用这样的结构:

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

hello mono的上下文填充在世界单声道中.我试图弄清楚这是如何完成的,也是为了进行单元测试.

最后它仍然是一个谜.我尝试使用mono / flux对象上的常规方法执行此操作,但是我没有成功地将hello上下文提供给world mono.如何融合助焊剂和单体并将上下文传递给上游运算符?

最佳答案
WebFlux采用您的世界Mono并在其上构建一个反应链,在reactor-netty中的HTTP请求作为最终源. WebFilter是链构造的一部分,因此它们可以丰富整个链的Context.

IIRC Mono.subscriberContext()将在flatMap中使用,这使得主序列Context可用于其内部,因此它可以看到hello的Context.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读