有没有办法设置一个发布/订阅系统(1 个发布者,0..* 订阅者),保证每个订阅者都能准确地接收每条消息一次,并且按照消息发送的相同顺序?大多数总线系统(例如 NServiceBus)不能保证这一点。
我不在乎我是否必须自己实现系统,但至少事务异步通信(例如队列或类似的)应该能够做到这一点。
任何提示/建议?
有没有办法设置一个发布/订阅系统(1 个发布者,0..* 订阅者),保证每个订阅者都能准确地接收每条消息一次,并且按照消息发送的相同顺序?大多数总线系统(例如 NServiceBus)不能保证这一点。
我不在乎我是否必须自己实现系统,但至少事务异步通信(例如队列或类似的)应该能够做到这一点。
任何提示/建议?
在我(有限的)经验中,您可以通过 RabbitMQ 来实现这一点:
具体来说,我推荐他们拥有的发布/订阅者教程:
请注意,具体教程不涉及确认的概念,这将是确保消息传递给消费者的下一步。
至于消息排序,它也可能是可以实现的,具体取决于您的用例,如此 stackoverflow 帖子中所述:
希望能帮助到你。