Azure Queue Storage与Service Bus死信队列、毒药消息差异及消息读取方法

一、两类服务死信队列、毒药消息机制核心区别 #

首先明确：毒药消息是死信消息的一类，特指重复投递后始终无法被正常处理的消息，两类服务的相关机制差异如下：

• 内置支持能力
  • Azure队列存储：无系统级内置的死信队列、毒药消息自动处理逻辑。所有相关规则完全由开发者自定义实现，需要手动编码判断消息重试次数、TTL状态等条件，符合条件的消息自行转移到预先创建的自定义队列（通常命名为原队列名-poison）作为毒药/死信队列使用，系统不会自动生成专用队列。
  • Azure服务总线：原生内置死信队列和毒药消息自动处理能力。每个队列/订阅默认自带独立的系统死信队列，无需手动创建，消息投递次数超过配置上限（默认10次，可自定义调整）后会被自动标记为毒药消息移入死信队列。
• 死信触发规则
  • Azure队列存储：无内置触发规则，所有死信场景（处理失败次数超限、消息过期、格式错误等）都需要开发者自行编码判断。
  • Azure服务总线：内置多类自动死信触发规则，除了毒药消息场景外，还支持消息TTL到期自动死信、会话超时死信、开发者主动调用API标记死信等场景，死信时会自动附加DeadLetterReason、DeadLetterErrorDescription等属性方便排查。
• 元数据保留
  • Azure队列存储：自定义转移的死信/毒药消息，需要开发者自行保留原消息的重试次数、入队时间、错误信息等元数据，系统不会自动附加相关字段。
  • Azure服务总线：死信消息会完整保留原消息的所有系统属性、自定义属性，同时自动补全死信原因、死信时间、投递次数等专用元数据。

二、死信/毒药消息的读取方法 #

2.1 Azure队列存储 #

因为死信/毒药队列是开发者自定义的普通队列，读取逻辑和普通队列完全一致，以.NET的Azure.Storage.Queues库为例：

// 连接字符串、自定义毒药队列名
var connectionString = "你的存储账号连接字符串";
var poisonQueueName = "原队列名-poison";

QueueClient poisonQueueClient = new QueueClient(connectionString, poisonQueueName);

// 单次最多拉取32条消息，自定义可见性超时时间
var messages = await poisonQueueClient.ReceiveMessagesAsync(maxMessages: 10, visibilityTimeout: TimeSpan.FromMinutes(5));
foreach (var msg in messages.Value)
{
    // 自定义消息处理逻辑
    Console.WriteLine($"消息ID：{msg.MessageId}，内容：{msg.Body}");
    // 处理完成后删除消息，否则消息到期后会重新可见
    await poisonQueueClient.DeleteMessageAsync(msg.MessageId, msg.PopReceipt);
}

2.2 Azure服务总线 #

直接通过内置的死信队列标识构建接收器即可，无需额外配置死信队列路径，以.NET的Azure.Messaging.ServiceBus库为例：

var connectionString = "你的服务总线连接字符串";
var queueName = "原队列名";

ServiceBusClient serviceBusClient = new ServiceBusClient(connectionString);
// 构建死信队列接收器，订阅场景替换为对应主题、订阅名即可
ServiceBusReceiver dlqReceiver = serviceBusClient.CreateReceiver(
    queueName, 
    new ServiceBusReceiverOptions { SubQueue = SubQueue.DeadLetter }
);

// 拉取消息，设置最长等待时间
var messages = await dlqReceiver.ReceiveMessagesAsync(maxMessages: 10, maxWaitTime: TimeSpan.FromSeconds(30));
foreach (var msg in messages)
{
    // 可直接读取系统附加的死信原因属性
    Console.WriteLine($"死信原因：{msg.DeadLetterReason}，消息内容：{msg.Body}");
    // 处理完成后确认删除消息，调用AbandonMessageAsync可将消息放回死信队列
    await dlqReceiver.CompleteMessageAsync(msg);
}

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