【发布时间】: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