使用Npgsql实现PostgreSQL连接池时遭遇‘客户端过多’错误排查

一、立即修复：释放数据库资源避免连接泄漏 #

你的代码中调用ExecuteReader后未释放NpgsqlDataReader，这会导致底层数据库连接长期被占用，无法回到连接池。必须用using语句自动释放资源，同时替换SQL拼接为参数化查询（避免注入风险的同时优化连接使用）：

修改OnTrackerData方法 #

public async Task<string?> OnTrackerData(List<TrackerData> trackerData)
{
    // 替换循环单条插入为批量操作（见下文优化建议）
    foreach (var data in trackerData)
    {
        await StoreData(data);
    }

    if (trackerData.Count > 0 && this.TrackerId > 0)
    {
        string sql = "SELECT id, command FROM tracker_commands WHERE tracker_id = @trackerId AND processed_at IS NULL ORDER BY requested_on ASC LIMIT 1";
        using var command = DB.GetInstance().CreateCommand(sql);
        command.Parameters.AddWithValue("@trackerId", this.TrackerId);
        
        // 使用using自动释放DataReader，底层连接会归还连接池
        using var reader = await command.ExecuteReaderAsync();
        if (reader.Read())
        {
            var commandId = reader.GetInt32(0);
            var commandText = reader.GetString(1);
            
            string updateSql = "UPDATE tracker_commands SET processed_at = @timestamp WHERE id = @id";
            using var updateCommand = DB.GetInstance().CreateCommand(updateSql);
            updateCommand.Parameters.AddWithValue("@timestamp", Utilities.GetCurrentTimeStamp(330));
            updateCommand.Parameters.AddWithValue("@id", commandId);
            
            await updateCommand.ExecuteNonQueryAsync();
            return commandText;
        }
    }
    return "";
}

给DB类添加CreateCommand方法 #

public NpgsqlCommand CreateCommand(string sql)
{
    return _DataSource.CreateCommand(sql);
}

二、优化连接池配置与操作模式 #

1. 完善连接字符串参数
   在现有连接字符串基础上补充以下参数，优化连接池行为：

   Host=***;Database=***;Username=***;Password=***;Maximum Pool Size=50;Connection Idle Lifetime=300;Connection Timeout=15;
   

   • Connection Idle Lifetime：设置空闲连接的最大存活时间（单位：秒），避免连接长期闲置占用资源。
   • Connection Timeout：设置从连接池获取连接的超时时间，防止因等待连接导致的阻塞。

2. 批量操作减少连接请求
   循环调用StoreData会频繁申请连接，改用Npgsql的批量复制功能可以大幅降低连接占用频率：

   public async Task BulkStoreData(List<TrackerData> trackerData)
   {
       using var writer = await _DataSource.BeginBinaryImportAsync(
           "COPY tracker_data (col1, col2, col3) FROM STDIN (FORMAT BINARY)");
       
       foreach (var data in trackerData)
       {
           await writer.StartRowAsync();
           await writer.WriteAsync(data.Col1);
           await writer.WriteAsync(data.Col2);
           await writer.WriteAsync(data.Col3);
       }
       
       await writer.CompleteAsync();
   }
   

   然后在OnTrackerData中替换循环为批量调用：

   await BulkStoreData(trackerData);
   

三、排查其他连接泄漏点 #

• 检查所有数据库操作代码，确保NpgsqlDataReader、NpgsqlCommand、NpgsqlTransaction都用using包裹，自动释放资源。
• 避免在DataReader未关闭时执行耗时逻辑，防止连接被长时间占用。

四、监控连接状态 #

可以通过PostgreSQL命令查看当前连接数：

SELECT count(*) FROM pg_stat_activity;

也可以通过Npgsql自带的统计信息监控连接池状态：

var stats = _DataSource.ConnectionPoolStatistics;
Console.WriteLine($"活跃连接数: {stats.ActiveConnections}, 空闲连接数: {stats.IdleConnections}");

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