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

核心配置修正 #

• SubscriptionEndpoint参数顺序错误：你当前代码里SubscriptionEndpoint的两个参数搞反了——MassTransit中该方法第一个参数是订阅名称，第二个参数是主题名称。正确写法应该是：

  config.SubscriptionEndpoint(
      "employee-changed", // 订阅名称
      "search-service",   // 主题名称
      endpoint =>
      {
          endpoint.ConcurrentMessageLimit = 1;
          endpoint.UseConsumeFilter<CustomerDataPropagationFilter<UpdateEmployeeMessage>>(context);
          endpoint.ConfigureConsumer<UpdateEmployeeConsumer>(context);
      }
  );
  

  参数顺序错误会导致MassTransit找不到预定义的订阅资源，直接引发连接异常进而停止Bus。

权限验证 #

• 确认serviceBusConnectionString对应的Service Bus账号拥有主题监听权限和订阅读取权限。权限不足时，MassTransit无法建立持久连接，会触发Bus停止。
• 去Azure Portal查看Service Bus的访问策略，确保该策略包含Listen权限。

过滤器与消费者检查 #

• 排查自定义过滤器是否存在未处理异常：MessageLoggingFilter和CustomerDataPropagationFilter<UpdateEmployeeMessage>如果抛出未捕获的异常，会直接导致MassTransit启动失败。可以临时注释掉过滤器配置，重启服务测试，若Bus正常运行，说明过滤器存在问题。
• 确认UpdateEmployeeConsumer实现正确：检查是否继承了IConsumer<UpdateEmployeeMessage>接口，构造函数的依赖是否能被DI容器正常解析（比如没有缺失注入的服务）。

日志与异常深挖 #

• 开启MassTransit详细日志：在appsettings.json中添加日志级别配置，获取更具体的错误信息：

  "Logging": {
      "LogLevel": {
          "MassTransit": "Debug"
      }
  }
  

  详细日志会明确显示连接失败的根因，比如订阅不存在、网络不通、资源配置不兼容等。

预定义订阅兼容性验证 #

• 如果你的预定义订阅启用了会话（Session），需要在SubscriptionEndpoint配置中添加会话支持：

  endpoint.UseSession();
  

• 检查订阅的死信队列、消息过期策略是否存在异常配置，比如死信队列权限不足也可能导致启动失败。

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