Mass Transit无法向RabbitMQ发布消息问题求助

以下是几个排查和解决的关键点：

1. 确保MassTransit总线服务已启动 #

你的Program.cs配置缺少总线托管服务的注册，MassTransit需要这个服务来启动总线并处理消息发送。修改配置：

builder.Services.AddMassTransit(config => {
    config.UsingRabbitMq((ctx, cfg) => {
        cfg.Host("localhost", "/", h =>
        {
            h.Username("guest");
            h.Password("guest");
        });
    });
});
// 添加这行代码，启动MassTransit总线服务
builder.Services.AddMassTransitHostedService();

2. 检查IPublishService的实现正确性 #

你使用了自定义的IPublishService，但必须确保它正确依赖MassTransit的IPublishEndpoint来发布消息：

• 首先注册你的发布服务到DI容器：

// 在Program.cs中添加
builder.Services.AddScoped<IPublishService, PublishService>();

• 实现IPublishService：

public class PublishService(IPublishEndpoint publishEndpoint) : IPublishService
{
    public async Task Publish(AddStaffMessage message)
    {
        await publishEndpoint.Publish(message);
    }
}

3. 修正控制器中的异步调用 #

控制器的Get方法需改为异步，避免同步调用导致的消息发送阻塞或丢失：

[HttpGet]
public async Task<IActionResult> Get()
{
    await publishService.Publish(new AddStaffMessage 
    {
        ContactNumber = 9827279897,
        Name = "Prabesh Upreti"
    });
    return Ok();
}

4. 验证RabbitMQ服务状态 #

• 确认本地RabbitMQ服务正在运行：执行rabbitmqctl status命令（Windows可在RabbitMQ安装目录的sbin文件夹下运行）。
• 访问RabbitMQ管理界面（默认地址http://localhost:15672），用guest/guest登录，检查是否有消息交换器被创建，以及是否有消息进入队列。

5. 启用日志排查细节 #

在Program.cs中启用MassTransit的日志输出，查看具体错误：

// 配置日志级别为Debug
builder.Logging.SetMinimumLevel(LogLevel.Debug);

// 在RabbitMQ配置中添加日志
config.UsingRabbitMq((ctx, cfg) => {
    cfg.Host("localhost", "/", h =>
    {
        h.Username("guest");
        h.Password("guest");
    });
    cfg.UseSerilog(); // 如果使用Serilog，否则用默认日志
});

运行程序后查看日志，会显示连接错误、认证失败或其他消息发送失败的具体原因。

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