Azure Service Bus消息有序处理

Question

如果对于Azure服务总线主题，则存在带有某个筛选器的单个订阅。有一个微服务a为订阅创建了SubscriptionClient,并发度为1,用于读取消息。此外，如果存在该服务A的2个这样的副本，并且比方说，在t1、t2和t3时间插入到主题的unpartitioned服务总线主题中有3条消息。

T1

注意：与kafka相比，它确保一个分区的消息只传递给一个副本和一个侦听该分区的线程，从而保证了消息的有序处理。但不确定W.R.T服务总线主题，如Azure服务总线，如果多个副本使用不同的subscriptionClients侦听相同的订阅，它们是否可以接收/处理顺序混乱的消息？




Answer 1

如果您想要使用Azure服务总线启用有序消息处理，那么就必须使用会话。

您可以使用消息的sessionid作为Kafka中可能使用的partitionId的等价物。通过这种方式，您仍然可以扩展您的使用者，但在任何给定时间都要受到不同的sessionid值的数量的限制。

消息会话。实现需要消息排序或消息延迟的工作流。

分区意味着已分区实体的总体吞吐量不再受单个消息代理或消息传递存储的性能限制。此外，消息存储的临时中断不会使分区队列或主题不可用。