Mass Transit消费者无法接收Azure Service Bus队列消息排查求助

1. 连接字符串拼写错误 #

你的代码里serviceBusConnectinString存在拼写错误，正确应为serviceBusConnectionString（少了字母o）。拼写错误会导致消费者无法正常连接Azure Service Bus，进而无法消费消息。

修正后的代码片段：

x.UsingAzureServiceBus((context, cfg) =>
{
    cfg.Host(serviceBusConnectionString); // 修正拼写
    cfg.ReceiveEndpoint(serviceBusQueueName, e =>
    {
        e.ConfigureConsumer<IndexConsumer>(context);
    });
});

2. 未注册MassTransit宿主服务 #

在ASP.NET Core环境中，必须添加MassTransitHostedService才能启动消费者后台服务，否则消费者不会被激活运行。需要在AddMassTransit配置后补充：

builder.Services.AddMassTransitHostedService();

3. 消费者类实现异常 #

确认IndexConsumer正确实现IConsumer<IndexMessage>接口，且Consume方法无静默异常：

public class IndexConsumer : IConsumer<IndexMessage>
{
    public async Task Consume(ConsumeContext<IndexMessage> context)
    {
        // 确保业务逻辑无未处理异常，否则消息可能被移入死信队列
        Console.WriteLine($"Received message: {context.Message}");
        await Task.CompletedTask;
    }
}

若Consume方法抛出未处理异常，MassTransit会按重试策略处理；未配置重试时，消息会直接进入死信队列，表现为“未消费”。

4. 队列权限不足 #

检查Azure Service Bus连接字符串对应的SAS政策是否包含Listen权限。若仅配置Send权限，消息可正常发布，但消费者无法监听队列。

5. 消息类型不匹配 #

确保发布端与消费端的IndexMessage类型完全一致（包括命名空间、类名、属性结构）。MassTransit依赖消息类型的完整名称进行路由匹配，类型不匹配会导致消费者无法识别消息。

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