如何通过Rebus向Azure Service Bus DLQ发消息？QueueError迁移方法

直接发送消息到Azure Service Bus原生死信队列 #

你调用的bus.Advanced.TransportMessage.Deadletter()是Rebus内置的错误队列机制，仅会将消息路由到Rebus专属的QueueError队列，而非Azure Service Bus（ASB）原生的死信队列。要直接将消息送入ASB的DLQ，需借助Rebus对ASB传输的原生支持，在消息处理上下文内操作ASB的原生对象：

// 在消息处理程序中，通过IMessageContext获取ASB原生消息和接收器
var asbMessage = messageContext.TransportMessage.GetNativeMessage<Azure.Messaging.ServiceBus.ServiceBusReceivedMessage>();
var receiver = messageContext.TransportMessage.GetNativeReceiver<Azure.Messaging.ServiceBus.ServiceBusReceiver>();

// 调用ASB原生死信方法
await receiver.DeadLetterMessageAsync(
    asbMessage,
    deadLetterReason: "消息处理失败",
    deadLetterErrorDescription: "详细错误详情"
);

该方式依赖Rebus.AzureServiceBus传输包，且必须在消息处理流程中执行，因为需要绑定当前消息的ASB接收器实例。

迁移Rebus QueueError队列消息到ASB原生DLQ #

若已有消息积压在Rebus的QueueError队列，可通过两种方式迁移：

方式1：借助Rebus消费后触发死信 #

• 搭建临时Rebus消费者，订阅QueueError队列；
• 消费每条消息时，将其转发至原始业务队列，随后在该消息的处理逻辑中调用上述ASB原生死信方法，将其移入对应队列的DLQ。

方式2：使用ASB SDK直接迁移 #

编写轻量工具，通过ASB官方SDK直接操作队列：

var connectionString = "你的ASB连接字符串";
var queueErrorName = "QueueError";
var originalQueueName = "原始业务队列名称";

await using var client = new ServiceBusClient(connectionString);
await using var receiver = client.CreateReceiver(queueErrorName);
await using var sender = client.CreateSender(originalQueueName);

// 批量接收QueueError中的消息
var messages = await receiver.ReceiveMessagesAsync(maxMessages: 10);
foreach (var message in messages)
{
    // 将消息死信到原始队列的DLQ
    await receiver.DeadLetterMessageAsync(
        message,
        deadLetterReason: "迁移自Rebus QueueError",
        deadLetterErrorDescription: "原错误信息"
    );
    // 确认消息已处理完成
    await receiver.CompleteMessageAsync(message);
}

注意：需确保工具有权限访问目标队列和DLQ，同时根据实际情况调整批量处理的消息数量。

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