.NET6中RabbitMQ多连接异常排查：需实现单连接发送消息

你的核心问题在于每次请求都会新建RabbitMQ连接，原因是当前的IModel注册逻辑中，每个Scoped的IModel都会调用factory.CreateConnection()创建新连接——而AddScoped意味着每个HTTP请求都会生成一个新的IModel实例，最终导致连接数随请求量暴涨。

要实现单连接复用，需要将IConnection注册为单例（连接是线程安全的，适合全局复用），再基于单例连接创建IModel（Channel是轻量级、非线程安全的，适合每个请求单独创建）。

步骤1：修正Program.cs中的服务注册 #

// 1. 注册单例ConnectionFactory（原代码逻辑正确，补充连接恢复配置）
builder.Services.AddSingleton<ConnectionFactory>(provider =>
{
    var configuration = provider.GetRequiredService<IConfiguration>();
    var factory = new ConnectionFactory()
    {
        HostName = configuration.GetValue<string>("RabbitMQ:Server"),
        UserName = configuration.GetValue<string>("RabbitMQ:UserName"),
        Password = configuration.GetValue<string>("RabbitMQ:Password"),
        // 开启自动连接恢复，应对连接断开场景
        AutomaticRecoveryEnabled = true,
        NetworkRecoveryInterval = TimeSpan.FromSeconds(10)
    };
    return factory;
});

// 2. 注册单例IConnection，全局复用同一个连接
builder.Services.AddSingleton<IConnection>(provider =>
{
    var factory = provider.GetRequiredService<ConnectionFactory>();
    return factory.CreateConnection();
});

// 3. 注册Scoped IModel，基于单例连接创建Channel（每个请求一个Channel，避免线程安全问题）
builder.Services.AddScoped<IModel>(provider =>
{
    var connection = provider.GetRequiredService<IConnection>();
    return connection.CreateModel();
});

步骤2：优化队列声明逻辑 #

原代码中每次请求都调用QueueDeclare属于冗余操作，建议在应用启动时一次性声明队列：

var app = builder.Build();

// 启动时声明队列（仅执行一次）
using var scope = app.Services.CreateScope();
var connection = scope.ServiceProvider.GetRequiredService<IConnection>();
using var initChannel = connection.CreateModel();
initChannel.QueueDeclare(queue: "smpp_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);

// ...后续中间件配置、app.Run()代码

步骤3：简化控制器代码 #

移除重复的队列声明，保留消息发送逻辑：

private readonly IModel _channel;

public MyController(IModel channel)
{
    _channel = channel;            
}

[HttpPost("sendmessage")]
public async Task SendMessageAsync([FromBody] Model smppmessage)
{        
    string message = JsonSerializer.Serialize(smppmessage);
    var body = Encoding.UTF8.GetBytes(message);
    _channel.BasicPublish(exchange: "", routingKey: "smpp_queue", basicProperties: null, body: body);
}

关键说明 #

• Connection单例：RabbitMQ连接是重量级资源，创建/销毁成本高，且线程安全，全局复用能大幅降低连接数。
• Channel Scoped：Channel是轻量级资源，非线程安全，每个请求单独创建可避免多线程冲突，性能损耗可忽略。
• 自动恢复：开启AutomaticRecoveryEnabled能在连接意外断开时自动重建连接，提升系统可靠性。

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