MassTransit订阅Azure Service Bus死信队列无消息接收问题求助

问题原因 #

直接将work-request/$DeadLetterQueue作为接收端点名称配置时，MassTransit无法正确识别这是原队列的附属死信队列，会将其解析为独立队列$DeadLetterQueue，导致端点名称截断，消费者无法绑定到目标死信队列。

修正方案 #

使用MassTransit为Azure Service Bus提供的ConfigureDeadLetterQueueReceiveEndpoint扩展方法，配合正确的重试策略配置，即可解决该问题。

修正后的Program.cs配置代码 #

builder.Services.AddMassTransit(config =>
{
    config.SetKebabCaseEndpointNameFormatter();

    config.AddConsumer<NormalHandler>();
    config.AddConsumer<DeadletterHandler>();

    config.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host(builder.Configuration.GetConnectionString("ServiceBus"));

        // 配置主工作队列
        cfg.ReceiveEndpoint("work-request", e =>
        {
            e.ConfigureConsumer<NormalHandler>(context);
            
            // 设置重试策略：3次重试，每次间隔5秒
            e.UseMessageRetry(r => r.Interval(3, TimeSpan.FromSeconds(5)));
            
            // 配置异常后将消息转入死信队列
            e.ConfigureDeadLetterQueueErrorTransport();
            e.ConfigureDeadLetterQueueDeadLetterTransport();

            // 绑定当前队列的死信队列到消费者
            e.ConfigureDeadLetterQueueReceiveEndpoint(context, dlqConfig =>
            {
                dlqConfig.ConfigureConsumer<DeadletterHandler>(context);
            });
        });

        cfg.ConfigureEndpoints(context);
    });
});

关键说明 #

1. 重试策略配置：UseMessageRetry指定消息重试次数和间隔，确保消息在N次重试失败后才进入死信队列，符合业务需求。
2. 死信队列绑定：ConfigureDeadLetterQueueReceiveEndpoint是MassTransit针对Azure Service Bus死信队列的专属配置方法，会自动处理死信队列的命名规则，避免名称截断问题，确保消费者正确绑定到目标死信队列。
3. 清理旧队列：如果之前已生成独立的$DeadLetterQueue队列，建议手动删除，避免对新配置产生干扰。

修正后启动日志会显示正确的死信队列端点名称：

[xx:xx:xx INF] Configured endpoint work-request, Consumer: Hahah.NormalHandler
[xx:xx:xx INF] Configured endpoint work-request/$DeadLetterQueue, Consumer: Hahah.DeadletterHandler

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