Azure Service Bus单主题单发布者消息顺序不符预期问题咨询

原因：异步调用未等待 #

你的代码里调用SendMessageAsync时没有等待异步操作完成，连续调用这个方法会让多个发送任务并行调度执行，实际发送到Service Bus的顺序由任务调度时机决定，所以出现乱序是必然的——这不是Service Bus的默认行为，是客户端异步处理的问题。

解决办法 #

1. 等待每个发送操作完成 #

修改Publish方法为异步并等待发送完成：

public async Task Publish<T>(T messageObject)
{
    var jsonString = JsonSerializer.Serialize(messageObject);
    var message = new ServiceBusMessage(jsonString);
    message.ApplicationProperties["messageType"] = typeof(T).Name;

    await serviceBusSender.SendMessageAsync(message);
}

调用时依次等待：

await Publish(message1);
await Publish(message2);
await Publish(message3);

2. 处理分区影响（可选） #

如果你的topic启用了分区（默认开启），即使按顺序发送，未指定分区键的消息可能被分配到不同分区，分区间的消息顺序不保证。要严格保证全局顺序，二选一：

• 重建topic时关闭分区（创建时设置EnablePartitioning=false，已创建的topic无法修改）
• 给所有需要保序的消息指定相同的分区键：

  message.PartitionKey = "same-key-for-ordered-group";
  

同一分区键的消息会进入同一个分区，Service Bus会保证分区内的消息顺序。

3. 批量发送替代（可选） #

如果消息数量较多，用SendMessagesAsync批量发送，批量内的消息顺序会被Service Bus保证：

var messages = new List<ServiceBusMessage>
{
    new ServiceBusMessage(JsonSerializer.Serialize(message1)) { ApplicationProperties = { ["messageType"] = message1.GetType().Name } },
    new ServiceBusMessage(JsonSerializer.Serialize(message2)) { ApplicationProperties = { ["messageType"] = message2.GetType().Name } },
    new ServiceBusMessage(JsonSerializer.Serialize(message3)) { ApplicationProperties = { ["messageType"] = message3.GetType().Name } }
};
await serviceBusSender.SendMessagesAsync(messages);

内容的提问来源于stack exchange，提问作者havij