.NET微服务中MassTransit+Azure服务总线Topic消费方法未触发问题

问题背景 #

我知道这类问题被多次提及，但查阅大量相关问题后仍毫无头绪。我用两个独立应用分别作为生产者和消费者，采用主题-订阅模式，使用MassTransit v8（默认注入托管服务自动运行总线）。生产者发布消息后，Azure中看不到消息记录，消费者也接收不到消息，已确认CreateEvent的命名空间一致，怀疑是双方配置问题，求排查思路。

生产者配置代码 #

services.AddMassTransit(serviceCollectionConfigurator =>
{
    serviceCollectionConfigurator.AddBus(registrationContext => Bus.Factory.CreateUsingAzureServiceBus(configurator =>
        {
            configurator.Host("connectionString");

            configurator.Message<CreateEvent>(configTopology =>
            {
                configTopology.SetEntityName("topic1");
            });    
        }
    ));    
});

消费者配置代码 #

services.AddMassTransit(x =>
{
    x.AddConsumer<CreateConsumer>(); //Consumer class
    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("connectionString");

        cfg.Message<CreateEvent>(configTopology =>
        {
            configTopology.SetEntityName("topic1");
        });

        cfg.SubscriptionEndpoint<CreateEvent>("subscription1", e =>
        {
            e.PrefetchCount = 100;
            e.MaxConcurrentCalls = 100;
            e.LockDuration = TimeSpan.FromMinutes(5);
            e.MaxAutoRenewDuration = TimeSpan.FromMinutes(30);

            e.UseMessageRetry(r => r.Intervals(100, 200, 500, 800, 1000));
            e.UseInMemoryOutbox();

            e.ConfigureConsumer<CreateConsumer>(context);
        });
    });
});

public class CreateConsumer: IConsumer<CreateEvent>
{
    public Task Consume(ConsumeContext<CreateEvent> context)
    {
        //breakpoint here
    }
}

排查思路 #

• 验证连接字符串有效性：确认生产者和消费者使用的Azure Service Bus连接字符串权限足够（生产者需Send权限，消费者需Listen权限），且指向同一个命名空间。可在Azure门户生成对应权限的SAS密钥测试。
• 确认生产者实际发布消息：在生产者调用Publish方法的位置添加日志，确保方法被执行且无异常抛出。示例：

  await _bus.Publish<CreateEvent>(new CreateEvent(...));
  // 添加日志记录发布操作完成
  

• 检查消息拓扑匹配度：
  • 除命名空间一致外，需确保CreateEvent的完整类型名（包括程序集名称）完全匹配——MassTransit默认用类型完整名称作为消息契约标识。可通过Azure门户查看主题消息的属性，对比生产者发送与消费者订阅的类型标识是否一致。
  • 排查生产者是否将消息发送到了指定的topic1：启用MassTransit调试日志，查看消息发送的目标主题信息，确认未被路由到默认生成的主题。
• 检查Azure Service Bus资源状态：
  • 确认topic1和关联的subscription1已成功创建（MassTransit默认自动创建，但权限不足会导致创建失败）。
  • 查看主题的死信队列和未送达队列，排查是否有消息因过滤规则、格式错误等被路由至此。
• 启用MassTransit调试日志：在双方应用中设置日志级别为Debug，查看总线启动、消息发送/接收的详细流程，定位是否存在连接失败、拓扑创建异常、序列化错误等日志信息。
• 验证消费者总线启动状态：确认消费者应用的MassTransit托管服务正常启动，无启动异常。可在应用启动时添加日志，记录总线初始化完成状态。
• 检查序列化配置一致性：MassTransit默认使用Json序列化，确认生产者与消费者的序列化配置完全一致，避免因自定义序列化设置导致消息无法反序列化。

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