.NET Minimal Web API中RabbitMQ配置及AMQP连接复用方案咨询

1. 安装依赖包 #

首先安装官方的RabbitMQ客户端包：

Install-Package RabbitMQ.Client
# 或者用.NET CLI
dotnet add package RabbitMQ.Client

2. 配置AMQP连接字符串 #

在appsettings.json中添加RabbitMQ连接配置：

{
  "RabbitMQ": {
    "ConnectionString": "amqp://用户名:密码@RabbitMQ地址:端口/虚拟主机"
  }
}

3. 注册单例连接与作用域通道 #

在Program.cs中配置服务，将RabbitMQ连接注册为单例（全局共享，避免频繁创建销毁），通道注册为作用域（每个请求/服务实例一个，规避线程安全问题）：

var builder = WebApplication.CreateBuilder(args);

// 注册RabbitMQ单例连接
builder.Services.AddSingleton<IConnection>(sp =>
{
    var config = sp.GetRequiredService<IConfiguration>();
    var connStr = config["RabbitMQ:ConnectionString"] 
                   ?? throw new InvalidOperationException("未配置RabbitMQ连接字符串");
    
    var factory = new ConnectionFactory { Uri = new Uri(connStr) };
    return factory.CreateConnection();
});

// 注册作用域通道（每个请求一个，解决通道线程不安全问题）
builder.Services.AddScoped<IModel>(sp =>
{
    var connection = sp.GetRequiredService<IConnection>();
    return connection.CreateModel();
});

注意：RabbitMQ的IModel（通道）不是线程安全的，单例通道会导致多线程操作冲突，因此推荐用作用域模式。如果必须使用应用生命周期的单例通道，需手动加锁保证同步，但不建议这么做。

4. 在业务服务中使用 #

创建业务服务类，注入IModel进行消息操作：

public class OrderMessageService
{
    private readonly IModel _channel;
    private const string OrderQueue = "order_notifications";

    public OrderMessageService(IModel channel)
    {
        _channel = channel;
        // 提前声明队列（确保队列存在）
        _channel.QueueDeclare(
            queue: OrderQueue,
            durable: true, // 持久化队列
            exclusive: false,
            autoDelete: false,
            arguments: null
        );
    }

    public void SendOrderCreatedMessage(string orderId)
    {
        var messageBody = Encoding.UTF8.GetBytes($"订单 {orderId} 已创建");
        var properties = _channel.CreateBasicProperties();
        properties.Persistent = true; // 持久化消息

        _channel.BasicPublish(
            exchange: "",
            routingKey: OrderQueue,
            basicProperties: properties,
            body: messageBody
        );
    }
}

注册这个业务服务：

builder.Services.AddScoped<OrderMessageService>();

5. 在API端点中调用 #

在Minimal API的端点中注入业务服务：

var app = builder.Build();

app.MapPost("/orders/{orderId}/notify", (string orderId, OrderMessageService messageService) =>
{
    messageService.SendOrderCreatedMessage(orderId);
    return Results.Ok("订单通知已发送");
});

// 应用停止时释放RabbitMQ连接
app.Lifetime.ApplicationStopping.Register(() =>
{
    using var scope = app.Services.CreateScope();
    var connection = scope.ServiceProvider.GetRequiredService<IConnection>();
    if (connection.IsOpen)
    {
        connection.Close();
    }
});

app.Run();

关键注意事项 #

• 单例连接：RabbitMQ连接是线程安全的，全局单例复用能避免频繁建立TCP连接导致的资源耗尽。
• 作用域通道：通道非线程安全，每个请求一个通道能避免多线程操作的冲突问题。
• 资源清理：在应用停止时手动关闭连接，避免资源泄漏。

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