Parallel.ForEach中ODP.NET连接偶发提前关闭异常原因咨询

问题根因 #

• OracleConnection、OracleTransaction 均为非线程安全对象，若 Parallel.ForEach 多个执行单元共享同一个 SqlLog 实例，会出现某一线程执行完 Dispose 关闭连接后，另一线程仍在调用 Disconnect 的情况，直接触发该异常。
• 连接状态判断不可靠：Connection.State 属性仅缓存本地最后一次操作后的连接状态，若数据库端主动回收超时连接、网络出现闪断，State 可能仍显示为 Open，直到执行 SQL 时才会触发异常并隐式关闭连接，后续 Disconnect 执行时自然报错。
• 命令未关联事务：连接开启事务后，所有执行的 OracleCommand 必须显式绑定当前事务，否则执行命令时会抛出异常，可能导致连接被隐式关闭。
• 连接池回收触发：高并发场景下连接池可能主动回收长时间未活动的空闲连接，即便本地缓存的 State 为 Open，实际底层连接已经被释放，执行命令时直接报错。

修复方案 #

1. 确保连接对象不跨线程共享：每个 Parallel 执行单元必须使用独立的 SqlLog 实例，禁止多个线程操作同一个 OracleConnection、OracleTransaction 对象。
2. 优化 Disconnect 方法，增加状态校验和事务绑定：

Public Sub Disconnect()
    ' 连接断开/异常时先重连
    If _Connection.State = ConnectionState.Closed OrElse _Connection.State = ConnectionState.Broken Then
        _Connection.Open()
        _Transaction = _Connection.BeginTransaction()
    End If
    Using Command As OracleCommand = _Connection.CreateCommand()
        Command.CommandType = CommandType.StoredProcedure
        Command.CommandText = "log.Disconnect"
        ' 显式绑定事务，否则执行会报错
        Command.Transaction = _Transaction
        Command.ExecuteNonQuery()
    End Using
    _Transaction.Commit()
    _Connection.Close()
End Sub

3. 给 GetValues 方法的 Command 也加上事务绑定，避免执行时报错导致连接提前关闭：

Public Sub GetValues(ByVal ID As Integer, ByVal params As Params)
    Using Command As OracleCommand = _Connection.CreateCommand()
        ' 绑定当前事务
        Command.Transaction = _Transaction
        ' 原有参数配置、执行逻辑
        Command.ExecuteNonQuery()
    End Using
End Sub

4. 调整连接池配置：根据并发量调整连接字符串参数，示例如下：

Data Source=你的库;User Id=账号;Password=密码;Validate Connection=True;Connection Timeout=60;Max Pool Size=200;

5. 增加异常日志排查：在 GetValues、Disconnect 方法中增加异常捕获，记录错误发生时的连接状态、SQL 错误信息，可快速定位具体触发原因。

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