RabbitMQ中teacherQueue队列未在队列列表显示且消费者未触发的问题排查

DevOps 小满

2026-4-30

问题：MassTransit配置后RabbitMQ队列不显示且消费者未触发

我有两个独立服务Teacher.API和Process.API，Teacher服务需要通过POST请求把Teacher详情发送给Process服务。我按照以下方式配置了MassTransit，但遇到了问题：RabbitMQ管理界面里看不到teacherQueue队列，只有对应的交换器，而且消费者也没被触发。

我的配置和代码

Teacher.API的MassTransit配置：

services.AddMassTransit(x => { 
  x.UsingRabbitMq((context, config) => { 
    config.Host(new Uri("rabbitmq://localhost"), h => { 
      h.Username("guest"); 
      h.Password("guest"); 
    }); 
  }); 
});

Process.API的MassTransit配置：

services.AddMassTransit(x => { 
  x.AddConsumer<TeacherConsumer>(); 
  x.UsingRabbitMq((context, cfg) => { 
    cfg.Host(new Uri("rabbitmq://localhost"), h => { 
      h.Username("guest"); 
      h.Password("guest"); 
    }); 
    cfg.ReceiveEndpoint("teacherQueue", ep => { 
      ep.PrefetchCount = 16; 
      ep.UseMessageRetry(r => r.Interval(2, 100)); 
      ep.ConfigureConsumer<TeacherConsumer>(context); 
    }); 
  }); 
});

Teacher控制器的POST实现：

[HttpPost] 
public async Task<IActionResult> Registraion(Teacher Teacher) { 
  if (Teacher != null) { 
    Teacher.BookedOn = DateTime.Now; 
    Uri uri = new Uri("rabbitmq://localhost/teacherQueue"); 
    var endPoint = await _bus.GetSendEndpoint(uri); 
    await endPoint.Send(Teacher); 
    return Ok(); 
  } 
  return BadRequest(); 
}

消费者代码：

public class TeacherConsumer : IConsumer<Teacher> { 
  public Task Consume(ConsumeContext<Teacher> context) { 
    var data = context.Message; 
    return Task.CompletedTask; 
  } 
}

问题原因分析

咱们来拆解下问题的根源：

Teacher.API的配置不完整，发送方式不符合MassTransit设计：你直接通过_bus.GetSendEndpoint指定队列URI发送消息，但如果Process.API没有先启动创建队列，RabbitMQ只会自动创建对应的交换器，不会创建队列——发送消息时若目标队列不存在，消息会进入交换器但没有队列绑定，最终丢失。
消息类型可能不匹配：如果两个服务中的Teacher类不是完全一致的（比如命名空间不同、属性差异），MassTransit会因为消息类型全名称不匹配，导致消费者无法识别消息。
Process.API的端点配置可能存在绑定问题：手动配置ReceiveEndpoint时，若没有正确关联消费者和消息类型，也会导致队列无法正确绑定交换器。

解决方案

1. 修正Teacher.API的MassTransit配置和发送逻辑

不要直接指定队列URI发送，改用MassTransit推荐的基于消息契约的发送方式，让框架自动管理交换器和队列的绑定：

首先修改MassTransit配置：

services.AddMassTransit(x => { 
  // 可选：统一端点命名格式，避免大小写或命名风格不一致
  x.SetKebabCaseEndpointNameFormatter();
  x.UsingRabbitMq((context, config) => { 
    config.Host(new Uri("rabbitmq://localhost"), h => { 
      h.Username("guest"); 
      h.Password("guest"); 
    });
    // 让MassTransit自动配置发送端的端点和路由
    config.ConfigureEndpoints(context);
  }); 
});

然后修改控制器代码，注入IPublishEndpoint来发布消息（推荐发布/订阅模式）：

private readonly IPublishEndpoint _publishEndpoint;

// 通过构造函数注入IPublishEndpoint
public TeacherController(IPublishEndpoint publishEndpoint)
{
    _publishEndpoint = publishEndpoint;
}

[HttpPost] 
public async Task<IActionResult> Registraion(Teacher teacher) { 
  if (teacher != null) { 
    teacher.BookedOn = DateTime.Now; 
    // 发布消息，MassTransit会自动处理交换器和队列的绑定
    await _publishEndpoint.Publish(teacher); 
    return Ok(); 
  } 
  return BadRequest(); 
}

2. 确保消息类型完全一致

把Teacher类放到一个共享类库中，让Teacher.API和Process.API都引用这个类库，保证两个服务中的Teacher类命名空间、属性、访问修饰符完全相同——MassTransit是通过消息类型的全名称（包括命名空间）来匹配消费者的，类型不一致会导致消息无法被消费。

3. 优化Process.API的MassTransit配置

可以让MassTransit自动配置消费者端点，避免手动配置的错误：

services.AddMassTransit(x => { 
  x.AddConsumer<TeacherConsumer>(); 
  x.SetKebabCaseEndpointNameFormatter();
  x.UsingRabbitMq((context, cfg) => { 
    cfg.Host(new Uri("rabbitmq://localhost"), h => { 
      h.Username("guest"); 
      h.Password("guest"); 
    });
    // 自动配置所有消费者的端点，包括TeacherConsumer对应的队列
    cfg.ConfigureEndpoints(context);
    // 如果一定要手动指定队列名称，可以保留这段代码，但要确保和路由匹配
    // cfg.ReceiveEndpoint("teacherQueue", ep => { 
    //   ep.PrefetchCount = 16; 
    //   ep.UseMessageRetry(r => r.Interval(2, 100)); 
    //   ep.ConfigureConsumer<TeacherConsumer>(context); 
    // }); 
  }); 
});

4. 注意启动顺序

一定要先启动Process.API，让它先创建teacherQueue队列并绑定对应的交换器，然后再启动Teacher.API发送消息——这样RabbitMQ管理界面就能看到队列，消息也能被消费者正常接收。

额外检查点

确认RabbitMQ服务正在运行，两个服务都能正常连接到rabbitmq://localhost，用户名和密码正确。
检查TeacherConsumer是否被正确注册到MassTransit中，没有拼写错误。
确保Teacher类可以被正常序列化/反序列化（比如没有循环引用、所有属性都是公共的）。

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