【问题标题】:Data bus with Java Flux API带有 Java Flux API 的数据总线
【发布时间】:2018-09-06 06:49:05
【问题描述】:

当我从一些教程中注意到您只能订阅一个发布者时,我正在研究 Java Flux API。然而,我看到一个用例让多个发布者对一个订阅很有用:某种数据/消息总线。

我找到的唯一解决方案是在总线内封装一组订阅者和 1 个发布者。

我的问题是,从被动的角度来解决这个问题,哪种方法是正确的?


我有兴趣通过实现我自己的发布者/订阅者等(使用 Java 9 java.util.concurrent.Flow API)来解决这个问题。这个项目用于学习目的,而不是用于生产。

【问题讨论】:

  • 您似乎想合并流。有很多运营商允许您这样做。
  • @abetteroliver 我想将多个发布者合并为一个。哪些运营商允许您专门执行此操作?使用java.util.concurrent.Flow 接口。谢谢!

标签: reactive-programming java-9 project-reactor


【解决方案1】:

您可以使用 Spring Reactor,它是 Java Publishers API 的一种实现。它具有 concat()、merge() 等运算符来组合给定订阅者的流。 https://projectreactor.io/docs/core/release/api/

【讨论】:

    猜你喜欢
    • 2016-06-29
    • 1970-01-01
    • 2015-12-08
    • 1970-01-01
    • 2022-10-19
    • 2015-10-13
    • 1970-01-01
    • 1970-01-01
    • 2020-08-17
    相关资源
    最近更新 更多