0

我们的要求: SAP 将为 N 个订阅者发布消息,并且这些订阅者将在各自的时间间隔内获取发布的消息。

我们设计的解决方案是这样的:在一个交换机下创建 N 个标准队列。将来自 SAP 的每条消息广播到所有这 N 个队列。为每个订阅者发布 API,以从他们各自的队列中获取消息。对于任何要添加的订阅,都会使用注册 API 生成队列,并且队列的名称具有与订阅者名称相同的模式。到此为止就OK了。但是,我们看到来自 SAP 的消息具有维护顺序的依赖性,但标准队列无法维护顺序。如果我们切换到 FIFO 队列,我们​​不能像通过交换那样将 SAP 消息一起广播到所有队列。

我的问题是我们如何仍然能够为所有队列生成 SAP 消息,以便每个订阅者都可以从他们的个人空间中读取,以及我们可以保持先进先出的消息序列?

4

0 回答 0