ASP.NET Core 5.0结合MassTransit使用Service Bus队列无法消费消息问题

问题1：消息成功入队但无法消费的核心原因及解决 #

• 最常见原因：消息契约Test类的命名空间在生产者和消费者项目中不统一
  MassTransit默认通过消息类的完整名称（命名空间+类名）匹配消息类型，哪怕两个项目的Test类字段完全一致，只要命名空间不同，就会被识别为不同类型，消费者不会处理对应消息。
  解决方法：将Test类提取到共享的类库项目中，生产者和消费者都引用这个公共类库，保证消息契约完全一致。
• 次要排查点：检查消费者侧Azure Service Bus连接字符串的权限
  确认连接字符串至少拥有Azure Service Bus Data Receiver角色权限，或者包含Listen声明，避免因权限不足无法拉取队列消息。
• 次要排查点：检查队列中的消息是否被移入死信队列
  若消息进入死信队列，可查看死信原因：如果死信原因是No matching subscription，即可确认是上述消息契约不匹配的问题。

问题2：自动生成额外Topic的原因及解决 #

MassTransit默认启用消费拓扑配置，会为每个消费的消息类型自动创建对应的Topic用于发布/订阅场景，即便你只用队列模式也会默认生成。
解决方法：在消费者的ReceiveEndpoint配置中关闭消费拓扑自动配置，修改代码如下：

cfg.ReceiveEndpoint("test", endpoint =>
{
    // 新增这行，关闭自动拓扑配置，禁止自动创建Topic
    endpoint.ConfigureConsumeTopology = false;
    endpoint.ConfigureConsumer<MessageConsumer>(context);
});

额外优化建议 #

• 移除生产者代码中的空catch块，添加异常日志输出，避免发送端报错被吞，排查问题时无法定位根因。
• 生产者调用GetSendEndpoint时建议使用标准的队列Uri格式，避免自定义Uri格式异常：

// 格式为 queue:队列名，MassTransit会自动拼接正确的服务Bus地址
var sendEndpoint = await _serviceEndPointProvider.GetSendEndpoint(new Uri("queue:test"));

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