java - Reactor 多路复用：仅向一个订阅者发送事件

Question

我现在正在玩 Reactor。在尝试构建一个小型演示游戏（只是为了习惯该框架）时，我需要能够让多个“实体”订阅一个发布者。但我还需要每个已发布的事件都能准确地到达一个订阅者。现在，他们总是能得到它。我知道我可以在这个事件中构建一些“锁存器”，以便除一个订阅者之外的所有订阅者都丢弃它。

但我认为在功能的海洋中，可能有一个运营商或已经在做这件事的东西......

单个发布者的多个订阅者。不过，每个订阅者也需要应用不同的过滤器。来自发布者的每个事件仅以无特定顺序发送给单个订阅者...（过滤器不保证唯一性，可能有多个订阅者使用相同的过滤器）。

随机性很酷但不是必需的（因为订阅者将在收到此事件后取消订阅）。您可能已经猜到这将是实体的终止信号；）。

谢谢！

标签： javaproject-reactor

Answer 1

看起来UnicastProcessor可以解决问题。