MassTransit消费者无法从Azure Service Bus队列消费消息排查

1. Azure Service Bus Host配置缺少认证信息 #

你的cfg.Host仅指定了endpoint，未提供Azure Service Bus所需的认证凭证，这会导致无法建立有效连接。

修复方式：

• 使用完整连接字符串配置Host：

cfg.Host("Endpoint=sb://<endpoint>.servicebus.windows.net/;SharedAccessKeyName=<key-name>;SharedAccessKey=<key-value>");

• 推荐从配置文件读取连接字符串（更安全）：
  在appsettings.json中添加：

"ConnectionStrings": {
  "AzureServiceBus": "Endpoint=sb://<endpoint>.servicebus.windows.net/;SharedAccessKeyName=<key-name>;SharedAccessKey=<key-value>"
}

然后修改Host配置：

cfg.Host(hostContext.Configuration.GetConnectionString("AzureServiceBus"));

2. 未注册MassTransit托管服务（旧版本适配） #

如果使用MassTransit v7及更早版本，需要手动添加托管服务来启动消费者，否则消费者不会运行。在ConfigureServices中补充：

services.AddMassTransitHostedService();

MassTransit v8+版本会自动注册该服务，无需手动添加。

3. 消息类型匹配问题 #

确保ConsumerData的命名空间、类型名称、字段结构和发送到队列的消息完全一致。MassTransit依赖消息的类型元数据进行路由，类型不匹配会导致消息被直接忽略。

• 检查发送方与消费者使用相同的序列化方式（默认是Json）
• 消息类型需为可序列化的POCO类（无循环引用，字段为公共属性）
• 避免使用匿名类型或动态类型定义消息

4. 队列权限与存在性验证 #

• 确认队列名称<queue>拼写完全正确，且已在Azure Service Bus控制台中创建
• 验证消费者使用的凭证（SharedAccessKey或服务主体）拥有该队列的Listen权限
• 查看Azure Portal的队列监控面板，确认是否有消息进入死信队列，或存在未被处理的消息

5. 启用详细日志排查 #

添加日志配置，查看MassTransit的运行细节，帮助定位问题：

Host.CreateDefaultBuilder(args)
    .ConfigureLogging(logging =>
    {
        logging.SetMinimumLevel(LogLevel.Debug);
        logging.AddConsole();
    })
    // ... 原有配置

启动程序后，控制台会输出连接状态、消费者注册情况、消息处理日志，通过这些信息可以快速定位连接失败、路由错误等问题。

修改后的Program.cs示例 #

public static IHostBuilder CreateHostBuilder(string[] args) =>
    Host.CreateDefaultBuilder(args)
        .ConfigureLogging(logging =>
        {
            logging.SetMinimumLevel(LogLevel.Debug);
            logging.AddConsole();
        })
        .ConfigureServices((hostContext, services) =>
        {
            services.AddMassTransit(x =>
            {
                x.AddConsumer<TestConsumer>();
                x.UsingAzureServiceBus((context, cfg) =>
                {
                    cfg.Host(hostContext.Configuration.GetConnectionString("AzureServiceBus"));

                    cfg.ReceiveEndpoint("<queue>", ec =>
                    {
                        ec.ConfigureConsumer<TestConsumer>(context);
                    });
                });
            });
            // 仅针对MassTransit v7及更早版本添加
            // services.AddMassTransitHostedService();
        });

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