MassTransit消费者无法消费Azure Service Bus主题消息求助

排查方向与解决方案 #

1. 确保消息类型与生产者完全一致 #

MassTransit依赖消息类型的完全限定名（包括命名空间、类名）进行路由，若生产者与消费者的ICrmCatalogCreatedEvent存在差异，会直接导致消息无法匹配：

• 检查两端的消息契约是否完全相同（属性名称、类型、嵌套结构）；
• 确认生产者是否也通过SetEntityName设置了与消费者一致的Topic名称，而非使用默认的类型名作为Topic。

2. 对齐生产者与消费者的序列化配置 #

序列化配置不匹配是消费失败的高频原因，必须保证两端使用完全相同的序列化器及规则：

• 同时在生产者和消费者端配置NewtonsoftJsonSerializer，并统一序列化参数：

  // 生产者和消费者的Azure Service Bus配置中都添加
  cfg.UseNewtonsoftJsonSerializer();
  cfg.ConfigureNewtonsoftJsonSerializer(settings => {
      settings.DateFormatString = "yyyy-MM-ddTHH:mm:ss.fffZ";
      settings.NullValueHandling = NullValueHandling.Ignore;
      settings.ContractResolver = new CamelCasePropertyNamesContractResolver(); // 若生产者采用驼峰命名
      return settings;
  });
  

• 避免混合使用System.Text.Json和Newtonsoft.Json，两者的类型标识、序列化逻辑存在本质差异。

3. 验证Topic与订阅配置的正确性 #

• 检查GetTopicName<TMessageType>返回的Topic名称，与生产者发送消息的Topic名称完全一致（Azure Service Bus的名称大小写敏感）；
• 确认订阅名称_subscriptionName唯一，无重复订阅拦截消息；若存在订阅过滤规则，需验证规则是否允许当前消息通过。

4. 检查消费者实现与注册 #

• 确认CrmCatalogCreatedEventConsumer正确实现IConsumer<ICrmCatalogCreatedEvent>，且Consume方法内有明确的日志输出（方便调试）：

  public class CrmCatalogCreatedEventConsumer : IConsumer<ICrmCatalogCreatedEvent>
  {
      private readonly ILogger<CrmCatalogCreatedEventConsumer> _logger;
  
      public CrmCatalogCreatedEventConsumer(ILogger<CrmCatalogCreatedEventConsumer> logger)
      {
          _logger = logger;
      }
  
      public Task Consume(ConsumeContext<ICrmCatalogCreatedEvent> context)
      {
          _logger.LogInformation("Received CrmCatalogCreatedEvent: {EntityId}", context.Message.Entity?.Id);
          return Task.CompletedTask;
      }
  }
  

• 确保AddMassTransit中注册消费者时无拼写错误，且消费者类已被正确注入到DI容器。

5. 开启详细日志排查隐藏问题 #

默认日志级别可能无法捕获MassTransit的内部细节，需开启Debug级别日志：

• 配置Serilog或其他日志框架输出Debug日志：

  builder.Host.UseSerilog((ctx, lc) => lc
      .MinimumLevel.Debug()
      .WriteTo.Console());
  

• 在MassTransit配置中添加日志集成：

  cfg.UseLogging();
  

• 查看日志中是否存在消息类型匹配失败、序列化错误、订阅连接异常等信息。

6. 验证消息内容与契约的兼容性 #

当使用UseRawJsonSerializer能触发消费但message.entity为空，说明消息JSON结构与消费者契约不匹配：

• 使用Azure Service Bus Explorer查看Topic中消息的原始JSON内容，对比消费者ICrmCatalogCreatedEvent的属性结构；
• 检查是否存在属性名大小写不一致、嵌套对象结构不匹配、属性类型不兼容（如生产者发送字符串，消费者期望对象）等问题。

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