嗨,我有图像中拍摄的系统。我计划采用一个可靠的消息传递系统,但我有点搞不清楚该用哪一个。下面解释了详细的数据流和我的要求。
Step 1: data from System is given to Publisher.
Step 2: Publisher simply pushes the data to the Topic based Messaging
system.
Step 3: There will be more than one subscribers for each topic and
subscribers should get notified as soon there are some entries in
messaging system.
Step 4: Subscribers process the data and update the status back to messaging
system.
Step 5: Publisher should get notified for the processed messages and
acknowledge the System which gave the data.
所以,我的问题是,我可以使用rabbitmq或kafka作为“基于主题的消息传递系统”吗?我这里的主要要求是从订阅者那里更新状态,而且发布者应该得到状态更新的通知(我不太在意吞吐量、性能和可扩展性)。我的另一个关注点是数据恢复/ha。
1条答案
按热度按时间fnvucqvd1#
不如有一个n+1主题系统,一个用于发布消息,该消息将被n个订阅者使用,而n个主题用于确认,每个订阅者一个。您的“系统”可以订阅所有这n个确认主题,并可以验证是否所有订阅者都处理了生产者发布的原始消息。例如,kafka中的每条消息都有一个消息密钥,同一消息密钥可用于将原始消息与其特定于订阅者的确认信息关联起来。
这是否实现了您在系统中想要的功能?