.NET通用宿主运行MassTransit时消费者未被调用的原因排查

.NET通用宿主模式下配置MassTransit时，未注册MassTransit对应的托管服务，总线生命周期没有和宿主生命周期绑定，消费端不会随宿主启动初始化，因此不会创建接收队列，也不会触发消费逻辑。

逻辑差异说明 #

你编写的第二个独立消费者控制台程序中，是手动解析IBusControl实例后显式调用StartAsync()启动总线，才完成了接收端点初始化、队列创建的流程。
而在.NET通用宿主模式下，总线的启动、停止、健康检查等生命周期动作默认由托管服务自动完成，你当前的配置只注册了MassTransit的服务和自定义的Worker，没有注册MassTransit自带的托管服务，因此宿主启动时只会初始化消息发布相关的链路（也就是你能在RabbitMQ后台看到交换器活跃的原因），不会启动消费端配置，自然不会创建队列、消费消息。

修复方案 #

在AddMassTransit配置块后追加一行托管服务注册即可，修改后的服务注册代码片段如下：

services.AddMassTransit(x =>
{
    x.AddConsumer<RedeliveryTest.MessageConsumer>(typeof(RedeliveryTest.MessageConsumerDefinition));
    x.SetKebabCaseEndpointNameFormatter();
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("rabbitmq://localhost");
        cfg.ConfigureEndpoints(context);
    });
});
// 追加以下行，将MassTransit总线生命周期交由.NET通用宿主托管
services.AddMassTransitHostedService();

services.AddHostedService<Worker>();

注意事项 #

• AddMassTransitHostedService是你已经安装的MassTransit.Extensions.DependencyInjection包内提供的扩展方法，不需要额外引入其他依赖。
• 修复后重新运行程序，RabbitMQ后台会正常生成test-message-queue队列，消费者可以正常消费Worker发布的消息。
• 你在MessageConsumerDefinition中手动指定的EndpointName优先级高于全局配置的KebabCase端点命名规则，不会出现端点名称不匹配、消息路由错误的问题。

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