如何处理远程主机强制关闭SQL连接的长时运行进程问题？

针对你遇到的Azure SQL连接被强制关闭、重试策略失效的问题，结合ADO.NET特性，提供以下可落地的解决方案：

1. 优化连接管理：避免长连接持有 #

Azure SQL的防火墙、负载均衡节点会主动断开长时间闲置的连接（默认闲置超时30分钟），长时运行进程若持续持有打开的连接，大概率触发这类错误。解决思路：

• 遵循ADO.NET短连接模式：仅在执行数据库操作时打开连接，操作完成后立即关闭（依托连接池自动复用，无额外性能开销）。
• 绝对不要在整个进程生命周期内保持同一个SqlConnection实例处于打开状态，每次批次处理前重新创建连接对象。

2. 修复Polly重试策略：重建连接再重试 #

当前重试策略失效的核心原因是复用了已被断开的连接，调整策略如下：

• 精准捕获传输级错误：匹配SqlException中对应连接强制关闭的错误码（如10054、233）。
• 重试前必须销毁旧连接，创建全新的SqlConnection实例，确保重试使用有效连接。
• 示例代码片段：

var retryPolicy = Policy
    .Handle<SqlException>(ex => ex.Number is 10054 or 233) // 匹配强制关闭的错误码
    .WaitAndRetry(5, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)),
        (exception, timeSpan, retryCount, context) =>
        {
            // 日志记录重试信息
            Console.WriteLine($"连接被强制关闭，第{retryCount}次重试，等待{timeSpan.TotalSeconds}s");
            // 销毁旧连接
            if (context["SqlConnection"] is SqlConnection conn && conn.State != ConnectionState.Closed)
            {
                conn.Close();
                conn.Dispose();
            }
        });

// 执行带重试的数据库操作
retryPolicy.Execute(context =>
{
    var conn = new SqlConnection(yourConnectionString);
    context["SqlConnection"] = conn;
    conn.Open();
    // 执行批次查询/处理逻辑
    // ...
    conn.Close();
    return true;
}, new Context());

3. 通用断点续传方案：摆脱整数主键限制 #

实现基于**书签（Bookmark）**的断点续传，支持任意类型主键（字符串、GUID、复合主键等）：

• 选择表的唯一键（单键或复合键）作为书签字段，每次处理完一批数据后，将最后一条记录的书签值持久化到本地文件或状态数据库表中。
• 进程启动时读取上次保存的书签值，查询时通过WHERE子句过滤，仅处理书签之后的记录：
  • 单主键（如GUID）：SELECT * FROM YourTable WHERE Id > @LastProcessedId ORDER BY Id OFFSET 0 ROWS FETCH NEXT 1000 ROWS ONLY
  • 复合主键：SELECT * FROM YourTable WHERE (Col1 > @LastCol1) OR (Col1 = @LastCol1 AND Col2 > @LastCol2) ORDER BY Col1, Col2 OFFSET 0 ROWS FETCH NEXT 1000 ROWS ONLY
• 持久化书签时用原子操作（如先写临时文件，成功后替换原文件），避免进程崩溃导致书签丢失。

4. 批次化处理：降低连接压力 #

将全表枚举改为分批拉取+处理：

• 每次仅拉取固定数量的行（如1000-5000行，根据数据大小调整），处理完一批后再拉取下一批。
• 这种方式既减少了单次数据库操作时间，降低连接被断开的概率，还能控制进程内存占用，避免OOM问题。

5. Azure SQL连接字符串优化 #

在连接字符串中添加内置重试配置，与Polly策略形成双层防护：

Server=tcp:your-server.database.windows.net,1433;Initial Catalog=your-db;Persist Security Info=False;User ID=your-user;Password=your-pass;MultipleActiveResultSets=False;Encrypt=True;TrustServerCertificate=False;Connection Timeout=30;ConnectRetryCount=10;ConnectRetryInterval=5;

• ConnectRetryCount：连接失败时的重试次数
• ConnectRetryInterval：重试间隔（秒）

总结 #

通过短连接管理+修复后的Polly重试+通用断点续传+批次处理的组合方案，可实现能应对瞬时网络故障、连接强制关闭的高韧性长时运行进程。其中断点续传是核心保障，确保进程在任何故障后都能从断点恢复，无需重新处理全量数据。

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