Azure Service Bus Queue：消息排序机制是如何工作的？

让我来详细拆解Azure Service Bus Queue的消息排序逻辑，结合你提供的代码示例帮你理清运作方式：

一、普通非会话队列的排序规则 #

默认情况下，普通Service Bus Queue遵循**严格的FIFO（先进先出）**原则——消息按照发送到队列的先后顺序被接收者获取。但有几种场景会打破这个顺序：

• 消息被设置了ScheduledEnqueueTimeUtc（延迟发送），或者进入死信队列后被重新移回主队列；
• 接收者用PeekLock模式处理消息时，超过锁超时时间未调用CompleteAsync，消息会重回队列，此时它会被放到队列末尾；
• 启用了分区的队列：分区队列会把消息分发到多个独立分区，不同分区的消息顺序无法保证，只有同一分区内的消息才会保持FIFO。

二、会话队列的排序逻辑（你的代码用到的场景） #

如果你的队列启用了会话（创建队列时需勾选「启用会话」选项），排序规则会基于SessionId来分组：

• 同一个SessionId下的所有消息，会严格按照发送顺序保持FIFO，接收者必须通过SessionClient来接收该会话的消息，确保顺序处理；
• 不同SessionId的消息之间没有固定顺序，Service Bus会并行处理不同会话的消息。

结合你的代码分析 #

你给每个消息设置了不同的SessionId（message.SessionId = i.ToString();），这意味着每个消息都属于独立的会话。这种情况下，这些消息不会按照你发送的顺序被接收——因为Service Bus会同时处理多个会话的消息。

如果想要让一批消息保持严格的顺序，只需要给它们设置相同的SessionId即可，比如给同一订单的所有消息用同一个SessionId，确保它们按顺序被处理。

补全后的代码示例（修正了截断部分）：

using System;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Azure.ServiceBus;

public class ServiceBusQueueDemo
{
    private static QueueClient _queueClient;
    private const string _connectionString = "你的Service Bus连接字符串";
    private const string _sessionEnabledQueueName = "已启用会话的队列名称";

    public static async Task RunMessageDemo()
    {
        const int numberOfMessages = 10;
        _queueClient = new QueueClient(_connectionString, _sessionEnabledQueueName);
        await SendOrderedMessagesAsync(numberOfMessages);
        await _queueClient.CloseAsync();
    }

    private static async Task SendOrderedMessagesAsync(int numOfMessages)
    {
        try
        {
            // 给所有消息设置同一个SessionId，保证这批消息严格按发送顺序处理
            var sharedSessionId = "order-processing-session-001";
            
            for (var i = 0; i < numOfMessages; i++)
            {
                var messageBody = $"Order Update {i}: Item processed";
                var message = new Message(Encoding.UTF8.GetBytes(messageBody))
                {
                    SessionId = sharedSessionId
                };
                
                await _queueClient.SendAsync(message);
                Console.WriteLine($"Sent: {messageBody}");
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"Error sending messages: {ex.Message}");
            throw;
        }
    }
}

三、接收端如何保证会话消息的顺序 #

对于会话队列，接收端需要使用SessionClient来接收指定会话的消息，确保同会话内的消息按顺序处理：

private static async Task ReceiveSessionMessagesAsync()
{
    var sessionClient = new SessionClient(_connectionString, _sessionEnabledQueueName);
    
    // 接收第一个可用的会话，也可以指定SessionId接收特定会话
    var session = await sessionClient.AcceptMessageSessionAsync();
    
    try
    {
        while (true)
        {
            var message = await session.ReceiveAsync(TimeSpan.FromSeconds(5));
            if (message == null) break;

            var messageContent = Encoding.UTF8.GetString(message.Body);
            Console.WriteLine($"Received from session {session.SessionId}: {messageContent}");
            
            // 处理完成后标记消息为已完成
            await session.CompleteAsync(message.SystemProperties.LockToken);
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"Error receiving messages: {ex.Message}");
        throw;
    }
    finally
    {
        await session.CloseAsync();
        await sessionClient.CloseAsync();
    }
}

关键总结 #

• 普通队列默认FIFO，但分区、消息重试/延迟等场景会打破顺序；
• 会话队列通过SessionId实现分组排序，同组内严格FIFO，不同组无顺序约束；
• 要保证消息顺序，要么用普通非分区队列（且避免触发重试/延迟），要么用会话队列并给需要顺序的消息设置相同SessionId。

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