.NET6集成MassTransit时RabbitMQ交换机未自动创建、总线未启动如何解决

1. 修复端口为0的配置问题 #

你遇到的端口显示为0是URI解析错误导致的，MassTransit的RabbitMQ Host配置更推荐使用拆分参数的重载，避免URI格式问题引发的解析失败：

// 先在RabbitMqOptions中新增Host、Port字段，拆分配置避免URI解析错误
cfg.Host(RabbitMqOptions.Host, RabbitMqOptions.Port, RabbitMqOptions.VHost, credentials =>
{
    credentials.Username(RabbitMqOptions.UserName);
    credentials.Password(RabbitMqOptions.Password);
});

如果坚持用URI配置，需要确保URI格式正确：如果使用非默认VHost，完整格式为rabbitmq://{host}:{port}/{vhost}，默认VHost为/时需要转义为%2f，即rabbitmq://myurl:5672/%2f。

2. 解决BusControl为null、总线未启动问题 #

• 如果你使用的是MassTransit v8及以上版本，不需要手动调用services.AddMassTransitHostedService()，AddMassTransit方法已经自动注册了托管服务，重复注册会导致启动异常，直接删除该行即可。
• 不要在应用启动流程完成前（也就是host.Run()/app.Run()执行前）尝试获取IBus实例，此时托管服务还未初始化，BusControl必然为null。如果需要启动后立刻执行发布操作，可以自定义托管服务，在StartAsync方法中注入IBus进行操作。
• 建议添加MassTransit日志输出，排查是否存在RabbitMQ连接失败的问题：比如账号密码错误、VHost无权限、网络不通、端口未开放等问题都会导致总线启动失败。

3. 自动创建交换机配置 #

MassTransit默认不会在总线启动时立刻创建交换机，会在第一次发布/消费对应消息时自动创建拓扑。如果你需要启动时就完成交换机创建，可以按以下方式配置：
如果是消费端，正常注册消费者并调用ConfigureEndpoints即可，启动时会自动创建所有关联的交换机、队列：

services.AddMassTransit(mt =>
{
    // 注册你的消费者
    mt.AddConsumer<YourNotificationConsumer>();
    
    mt.UsingRabbitMq((context, cfg) =>
    {
        // 上述Host配置省略
        cfg.AutoStart = true;
        cfg.Publish<IServerNotificationMessage>(e => e.ExchangeType = RabbitMQ.Client.ExchangeType.Direct);
        // 自动配置所有消费者的接收端点，启动时会创建对应拓扑
        cfg.ConfigureEndpoints(context);
    });
});

如果是纯发布端没有消费者，可以在应用启动完成后，调用一次空消息发布预热，触发拓扑创建：

// 应用启动完成后执行
var bus = app.Services.GetRequiredService<IBus>();
await bus.Publish<IServerNotificationMessage>(new {});

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