Azure Service Bus会话队列/订阅死信时如何保障消息有序投递？

针对你使用Azure Service Bus主题订阅+会话+Azure Functions的场景，要在重试死信消息时保证同一用户的消息顺序，核心思路是复用会话机制，按会话分组处理死信并按原顺序重发，具体实践如下：

1. 死信队列的会话特性复用 #

Azure Service Bus的死信队列会完整保留原消息的SessionId（即你设置的user-id），且死信队列本身支持会话功能。你需要确保处理死信的Azure Function启用会话感知，这样同一用户的死信消息会被串行处理，避免并行导致的顺序混乱。

2. 按原消息顺序排序死信消息 #

每条Service Bus消息都有全局唯一的SequenceNumber，这个编号由Service Bus在消息发布时生成，严格按发布顺序递增。死信消息会保留原消息的SequenceNumber属性，你可以基于这个值对同一会话下的死信消息排序，确保重发时的顺序和原发布顺序完全一致。

3. 死信重试的具体实现步骤 #

步骤1：配置死信处理Function #

创建一个Azure Function，使用Service Bus触发器监听目标订阅的死信队列，并开启会话支持：

• 在function.json中设置isSessionsEnabled: true
• 触发器路径格式为：{TopicName}/subscriptions/{SubscriptionName}/$DeadLetterQueue

步骤2：按会话排序并重发死信消息 #

在死信处理函数中，按以下逻辑处理：

1. 针对当前会话（user-id）的所有死信消息，按SequenceNumber升序排序
2. 为每条消息添加重试计数属性（如RetryCount），避免无限循环死信
3. 保留原SessionId，将消息重新发送回原主题
4. 完成死信消息的锁定，避免重复处理

示例C#代码：

[FunctionName("UserSessionDeadLetterRetry")]
public static async Task ProcessDeadLetters(
    [ServiceBusTrigger("UserUpdatesTopic/subscriptions/UserProcessingSub/$DeadLetterQueue", 
        Connection = "ServiceBusConnString", 
        IsSessionsEnabled = true)]
    Message[] deadLetterMsgs,
    string sessionId,
    ILogger log)
{
    // 按原消息发布顺序排序
    var sortedMsgs = deadLetterMsgs.OrderBy(msg => msg.SequenceNumber);
    var maxRetryCount = 3;

    var client = new ServiceBusClient(Environment.GetEnvironmentVariable("ServiceBusConnString"));
    var sender = client.CreateSender("UserUpdatesTopic");

    foreach (var msg in sortedMsgs)
    {
        // 控制重试次数，避免循环死信
        var retryCount = msg.UserProperties.ContainsKey("RetryCount") 
            ? (int)msg.UserProperties["RetryCount"] 
            : 0;
        
        if (retryCount >= maxRetryCount)
        {
            log.LogError($"Message {msg.MessageId} for user {sessionId} exceeded max retries, skipping.");
            continue;
        }

        // 更新重试计数
        msg.UserProperties["RetryCount"] = retryCount + 1;
        // 保留原会话ID，确保回到同一用户的会话流
        msg.SessionId = sessionId;

        // 重发回原主题
        await sender.SendMessageAsync(msg);
        log.LogInformation($"Retried message {msg.MessageId} for user {sessionId}, retry count: {retryCount + 1}");
    }
}

步骤3：原处理函数的顺序保障 #

原订阅的Azure Function已经启用会话支持，重发的消息会进入对应用户的会话队列，Service Bus会严格按消息进入会话的顺序（即你重发的排序后的顺序）投递，确保和该用户的其他未处理消息保持正确的先后关系。

4. 关键注意事项 #

• 避免直接移回原队列：不要使用DeadLetterReceiver.MoveMessageAsync直接移回原队列，这种方式无法保证顺序；必须按SequenceNumber排序后重新发送。
• 死信原因排查：对于超过重试次数的消息，要配置Azure Monitor告警，通知开发人员排查死信原因（如业务逻辑错误、资源不可用等），避免消息永久丢失。
• 会话锁定超时：确保死信处理函数的会话锁定时间足够覆盖排序和重发的操作，避免因锁定超时导致消息被重新投递。

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