当我从一些教程中注意到你只能订阅一个发布者时，我正在研究Java Flux API。然而，我看到一个用例，在一个订阅中有多个发布者是有用的：某种数据/消息总线。
我找到的唯一解决方案是在总线内封装一组订户和一个发布者。
我的问题是，从反应的观点到这个问题，这是正确的方法吗？
我有兴趣通过实现我自己的发布者/订阅者等来解决这个问题。（使用Java 9 java.util.concurrent.Flow API）这个项目用于学习purpouses，而不是用于生产。
您可以使用Spring Reactor，它是Java Publishers API的一种实现。它有像concat（），merge（）等运算符来组合给定订阅服务器的Streams。 https://projectreactor.io/docs/core/release/api/