同一服务器Dev/Demo环境下MassTransit服务总线启动异常求助

问题背景 #

同一服务器部署dev和demo两个环境，分别对应RabbitMQ的dev和demo虚拟主机。dev环境服务总线正常启动，消息收发功能正常；但demo环境仅显示端点配置完成，无总线启动日志，消息无法发布或消费。

环境配置 #

dev环境appsettings.json #

"RabbitMqSettings": {
 "Uri": "rabbitmq://localhost/dev",
 "UserName": "guest",
 "Password": "guest"
}

demo环境appsettings.json #

"RabbitMqSettings": {
 "Uri": "rabbitmq://localhost/demo",
 "UserName": "guest",
 "Password": "guest"
}

Program.cs配置 #

builder.Services.AddMassTransit(mt => mt.AddMassTransit(x => {
    mt.AddConsumer<OrderCreatedConsumer>();
    
    x.UsingRabbitMq((cntxt, cfg) => {
        cfg.Host(uri, c => {
            c.Username(rabbitMqSettings.UserName);
            c.Password(rabbitMqSettings.Password);
        });           
        cfg.ConfigureEndpoints(cntxt);
    });        
})    
);

日志信息 #

dev环境日志 #

2024-04-26 13:34:06.9383|0|INFO|MassTransit|Configured endpoint OrderCreated, Consumer: OrderAPI.Services.OrderCreatedConsumer
2024-04-26 13:34:07.2920|0|INFO|MassTransit|Bus started: rabbitmq://localhost/dev

demo环境日志 #

2024-04-27 13:34:06.9383|0|INFO|MassTransit|Configured endpoint OrderCreated, Consumer: OrderAPI.Services.OrderCreatedConsumer

排查与解决方案 #

• 检查RabbitMQ虚拟主机权限：登录RabbitMQ管理后台，确认demo虚拟主机已为guest用户分配配置、写入、读取权限。dev环境正常说明guest用户有dev主机权限，但demo主机可能未配置对应权限。
• 验证虚拟主机连接有效性：通过RabbitMQ管理后台的Connections页面查看demo环境的连接失败记录，或用CLI命令测试权限：

  rabbitmqctl authenticate_user guest guest -v demo
  

  若返回失败，需为demo虚拟主机添加guest用户的权限。
• 确认配置加载正确性：在demo环境启动时输出rabbitMqSettings.Uri的值，验证是否正确指向rabbitmq://localhost/demo，避免配置文件未正确加载。
• 添加错误捕获日志：在Program.cs的RabbitMQ配置中增加连接失败的异常处理，捕获具体错误信息：

  x.UsingRabbitMq((cntxt, cfg) => {
      cfg.Host(uri, c => {
          c.Username(rabbitMqSettings.UserName);
          c.Password(rabbitMqSettings.Password);
      });
      cfg.OnConnectFailure(ex => {
          cntxt.GetService<ILoggerFactory>().CreateLogger("MassTransit").LogError(ex, "Failed to connect to RabbitMQ demo host");
          return Task.CompletedTask;
      });
      cfg.ConfigureEndpoints(cntxt);
  });
  

• 确认MassTransit启动配置：检查Program.cs中是否添加了builder.Services.AddMassTransitHostedService()，这是MassTransit自动启动服务总线的必要配置，缺失会导致总线无法自动启动。

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