如何从其他线程关闭SslStream？异步读取超时关闭报错解决

你遇到的问题核心在于：超时后直接关闭SslStream时，正在后台运行的异步ReadAsync操作还未完全终止，后续它尝试访问已经被释放的流对象，就会抛出这个异常。正确的做法是用**取消令牌（CancellationToken）**优雅终止异步读取操作，而非直接强制关闭流。

下面是优化后的可行方案：

方案1：用CancellationToken实现超时取消 #

我们可以通过CancellationTokenSource创建带5秒超时的取消令牌，把它传递给ReadAsync方法，超时后先取消读取操作，再安全地清理流资源。

private static async Task<string> ReadMessageAsync(SslStream sslStream)
{
    byte[] buffer = new byte[2048];
    StringBuilder messageBuilder = new StringBuilder();
    int bytesRead;

    // 创建5秒超时的取消令牌源
    using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5));

    try
    {
        // 将取消令牌传递给ReadAsync，让读取操作响应超时取消
        bytesRead = await sslStream.ReadAsync(buffer, 0, buffer.Length, cts.Token);
        if (bytesRead > 0)
        {
            // 根据你的实际编码调整，这里用UTF8示例
            string receivedChunk = Encoding.UTF8.GetString(buffer, 0, bytesRead);
            messageBuilder.Append(receivedChunk);
        }
        return messageBuilder.ToString();
    }
    catch (OperationCanceledException)
    {
        // 这是超时触发的预期异常，无需惊慌
        Console.WriteLine("读取操作超时，即将关闭流");
        // 先优雅关闭SSL会话，再释放资源
        await sslStream.ShutdownAsync();
        sslStream.Dispose();
        return null; // 或返回空字符串，根据业务需求调整
    }
    catch (IOException ex)
    {
        Console.WriteLine($"读取发生IO错误: {ex.Message}");
        sslStream.Dispose();
        return null;
    }
}

方案2：支持循环读取的场景（如果需要读取完整消息） #

如果你的业务是要持续读取直到获取完整消息（比如按换行符结束），可以在循环中加入取消令牌，确保每一次读取都能响应超时：

private static async Task<string> ReadMessageAsync(SslStream sslStream)
{
    byte[] buffer = new byte[2048];
    StringBuilder messageBuilder = new StringBuilder();
    int bytesRead;

    using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5));

    try
    {
        do
        {
            bytesRead = await sslStream.ReadAsync(buffer, 0, buffer.Length, cts.Token);
            if (bytesRead > 0)
            {
                string chunk = Encoding.UTF8.GetString(buffer, 0, bytesRead);
                messageBuilder.Append(chunk);
                // 示例：判断是否读取到完整消息（按\r\n结束）
                if (chunk.EndsWith("\r\n"))
                    break;
            }
        } while (bytesRead > 0);

        return messageBuilder.ToString().TrimEnd('\r', '\n');
    }
    catch (OperationCanceledException)
    {
        Console.WriteLine("读取超时，已终止操作并关闭流");
        await sslStream.ShutdownAsync();
        sslStream.Dispose();
        return null;
    }
    catch (Exception ex)
    {
        Console.WriteLine($"读取出错: {ex.Message}");
        sslStream.Dispose();
        return null;
    }
}

关键注意事项 #

• 别直接强制Dispose：一定要先通过取消令牌终止异步操作，确保读取任务完全停止后再释放流，避免操作访问已释放资源。
• 优先用ShutdownAsync：对于SslStream，先调用ShutdownAsync优雅关闭SSL会话，再释放资源，能减少异常概率。
• 捕获取消异常：OperationCanceledException是超时取消的预期异常，捕获后做正常的资源清理即可。

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