Task执行中异常无法捕获：数据库连接检查循环故障排查

核心问题定位 #

同步调用时异常能被正常捕获并执行重试逻辑，但通过Task.Run异步调用时，testConexion.Open()抛出的异常未进入CheckConectionLogic的catch块，导致重试计数器无法递减，最终陷入无限递归循环。

关键原因推导 #

1. 递归调用的参数传递问题：CheckConectionLogic使用递归实现重试，intentos是值类型参数，每次递归传递的是当前值的副本，在异步线程的上下文切换中，可能导致参数状态异常。
2. 异常捕获范围的隐性限制：无参catch在某些异步场景下可能无法捕获特定类型的异常（如跨线程的安全上下文异常），而同步场景下上下文稳定可正常捕获。
3. Task.Result的阻塞与异常包装：直接访问Task<T>.Result会阻塞线程，并将原始异常包装为AggregateException，干扰了原本的异常捕获流程。

具体修复方案 #

1. 替换递归为循环，避免参数传递异常

将CheckConectionLogic的递归重试改为循环实现，确保重试计数器的状态可控，同时优化资源管理：

private bool CheckConectionLogic(int intentos = 1)
{
    int remainingAttempts = intentos;
    while (remainingAttempts > 0)
    {
        try
        {
            // 使用using自动释放连接资源，避免泄漏
            using (SqlConnection testConexion = GetSQLConn())
            {
                if (!PingHost(testConexion.DataSource.Split('\\')[0]))
                {
                    remainingAttempts--;
                    continue;
                }

                testConexion.Open();
                if (testConexion.State != ConnectionState.Open)
                {
                    remainingAttempts--;
                    continue;
                }

                string testSelect = @"SELECT COUNT(*) 'Tablas'
                                    FROM sys.all_objects T
                                    WHERE T.is_ms_shipped = 0
                                    AND T.type IN ('U', 'V')";

                using (SqlDataAdapter adaptador = new SqlDataAdapter(testSelect, testConexion))
                using (SqlCommandBuilder build = new SqlCommandBuilder(adaptador))
                {
                    DataTable dtTable = new DataTable();
                    adaptador.Fill(dtTable);
                    if (int.Parse(dtTable.Rows[0][0].ToString()) == 0)
                    {
                        remainingAttempts--;
                        continue;
                    }
                }

                return true;
            }
        }
        catch (Exception ex) // 明确捕获所有非致命异常，可添加日志排查问题
        {
            // Logger.Error($"连接重试失败，剩余次数：{remainingAttempts-1}", ex);
            remainingAttempts--;
        }
    }
    return false;
}

2. 修改异步调用逻辑，避免直接访问Task.Result

在ComprobarConexiones中，使用await获取Task结果，避免AggregateException的包装干扰：

private async void ComprobarConexiones()
{
    var tGICO = Task.Run(() => BDManager.ChekConnectionGICO());
    var tWIP = Task.Run(() => BDManager.ChekConnectioniMove());

    // 若需任务完成一个处理一个，保留以下逻辑；否则用Task.WhenAll批量处理更简洁
    var tasks = new List<Task<bool>> { tGICO, tWIP };
    while (tasks.Count > 0)
    {
        var completedTask = await Task.WhenAny(tasks);
        // 用await获取结果，确保异常正确传递到下层捕获逻辑
        bool result = await completedTask;
        if (completedTask == tGICO)
        {
            HabilitarMenusGICO(result);
        }
        else if (completedTask == tWIP)
        {
            HabilitarMenusWIP(result);
        }
        tasks.Remove(completedTask);
    }
}

3. 验证Impersonation上下文的线程兼容性

如果使用ImpersonationHelper.Impersonate，需确保该方法在异步线程中能正确传递安全上下文，避免身份模拟失败导致的未捕获异常。可在Impersonate内部添加异常透传逻辑：

public static bool Impersonate(string userId, string password, Func<bool> action)
{
    IntPtr tokenHandle = IntPtr.Zero;
    try
    {
        // 原有身份模拟逻辑
        return action();
    }
    catch (Exception ex)
    {
        // 将异常透传到上层捕获逻辑
        throw;
    }
    finally
    {
        // 释放token等资源
        if (tokenHandle != IntPtr.Zero)
        {
            CloseHandle(tokenHandle);
        }
    }
}

额外优化建议 #

• 添加日志记录：在异常捕获块中记录具体的异常信息（如SqlException的错误码、消息），便于快速定位连接失败原因。
• 改用异步数据库操作：将testConexion.Open()替换为await testConexion.OpenAsync()，并将CheckConectionLogic改为异步方法，进一步提升异步场景兼容性。

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