0

我设计了一种 Publish/Subscribe Observer/Listener 设计模式,我的业务系统订阅以收听一种类型的消息 A,然后取消订阅以便订阅以收听另一种类型的消息 B。

问题是我收到消息 A 和 B 真的一个接一个地很短,如此之快以至于我的系统在已经收到 B 消息时还没有订阅收听 B 消息: 结果是,在我当前的系统中,我的听众永远不会通知。

我正在考虑使用队列来存储所有传入消息,并在通知侦听器后使用它们。

但我想知道是否有针对此类问题的通用实现。

4

0 回答 0