多独立解决方案下MassTransit+RabbitMQ消费者未触发问题排查

原本在同一解决方案中，通过2个微服务（API）+1个共享模型层，使用MassTransit和RabbitMQ实现了微服务间消息通信，逻辑正常，消息可成功发布且消费者能触发。

现调整为3个独立解决方案（各含API项目），共享模型独立为单独解决方案，各微服务通过程序集引用访问。当前问题：消息可成功发布，但消费者无法触发，且所有NuGet包版本一致。

相关代码 #

消费者微服务依赖注入代码 #

public static IServiceCollection AddMessageBroker(this IServiceCollection services, ConfigurationManager configuration)
{
    MessageBrokerSettings messageBrokerSettings = new();

    configuration.Bind(MessageBrokerSettings.SectionName, messageBrokerSettings);

    services.AddSingleton(Options.Create(messageBrokerSettings));

    services.AddMassTransit(busConfigurator =>
    {
        busConfigurator.AddConsumer<GetCompanyIdsConsumer>();

        busConfigurator.AddBus(provider => Bus.Factory.CreateUsingRabbitMq(cur =>
        {
            cur.Host(new Uri(messageBrokerSettings.Host), h =>
            {
                h.Username(messageBrokerSettings.UserName);
                h.Password(messageBrokerSettings.Password);
            });

            cur.ReceiveEndpoint("companyQueue2", oq =>
            {
                oq.PrefetchCount = 20;
                oq.UseMessageRetry(r => r.Interval(2, 100));
                oq.ConfigureConsumer<GetCompanyIdsConsumer>(provider);
            });
        }));
    });

    services.AddTransient<IEventBus, EventBus>();

    return services;
}

发布者微服务依赖注入代码 #

public static IServiceCollection AddMessageBroker(this IServiceCollection services, ConfigurationManager configuration)
{
    MessageBrokerSettings messageBrokerSettings = new();

    configuration.Bind(MessageBrokerSettings.SectionName, messageBrokerSettings);

    services.AddSingleton(Options.Create(messageBrokerSettings));

    services.AddMassTransit(busConfigurator =>
    {
        busConfigurator.AddBus(provider => Bus.Factory.CreateUsingRabbitMq(cur =>
        {
            cur.Host(new Uri(messageBrokerSettings.Host), h =>
            {
                h.Username(messageBrokerSettings.UserName);
                h.Password(messageBrokerSettings.Password);
            });
        }));

        services.AddMassTransitHostedService();
    });

    services.AddTransient<IEventBus, EventBus>();

    return services;
}

消费者类代码 #

public class GetCompanyIdsConsumer : IConsumer<Message>
{
    public async Task Consume(ConsumeContext<Message> context)
    {
        await Task.Run(() => { var obj = context.Message; });
    }
}

发布者方法 #

await _eventBus.PublishAsync(message, uri, cancellationToken);

一、消费者无法触发的排查方向 #

• 消息类型一致性验证
  检查共享模型程序集的版本、强名称、命名空间是否在发布者和消费者端完全一致。MassTransit依赖消息的完全限定名（含程序集信息）匹配消费者，哪怕命名空间相同但程序集版本/签名不同，都会导致路由不匹配。可登录RabbitMQ管理后台查看消息的type属性，对比消费者端Message类型的完全限定名。

• 队列与消息路由匹配检查
  确认发布者的uri是否正确指向rabbitmq://{host}/companyQueue2，检查RabbitMQ后台companyQueue2的消息堆积情况：有堆积说明消费者未正确绑定队列；无消息说明发布者未将消息发至该队列。

• MassTransit配置修正

  • 消费者端缺失services.AddMassTransitHostedService()调用，这会导致MassTransit总线未启动，消费者无法监听队列，需添加该代码。
  • 发布者端services.AddMassTransitHostedService()写在AddMassTransit委托内部，属于错误写法，应移至委托外部，否则服务注册不生效。

• 消费者注册与日志排查
  确认GetCompanyIdsConsumer是否被正确注册，查看消费者微服务日志，排查是否有MassTransit启动失败、RabbitMQ连接失败（如权限、主机地址错误）等报错。

• EventBus实现检查
  核对IEventBus.PublishAsync内部逻辑，确认是否正确使用MassTransit总线发布，是否指定了正确的目标队列/交换器，有无不当的序列化/反序列化处理。

二、独立解决方案架构的合理性 #

将每个API放在独立解决方案中是合理且符合微服务设计原则的：

• 支持独立部署与迭代，单个服务变更不会影响其他服务，提升开发运维效率；
• 每个解决方案聚焦单一业务领域，代码边界清晰，降低维护复杂度；
• 具备技术栈灵活性，后续单个服务更换技术栈不会影响整体系统；
• 实现资源隔离，单个服务故障不会拖垮整个系统。

需注意的配套措施：做好共享模型的版本管理，避免兼容性问题；统一配置管理，减少重复配置；搭建完善的日志与监控体系，便于跨服务问题排查。

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