.NET Core中如何为TcpClient设置超时关闭？

问题描述 #

我正在使用.NET Core，通过TCP发送消息，为此使用TcpClient类并创建了自定义服务，代码如下：

class MyTcpService : IMyTcpService {
    private readonly TcpClient tcpClient = new TcpClient();
    public async Task Send(byte[] bytesToSend) {
        if (!tcpClient.Connected) // 检查客户端是否已关闭
        {
            await tcpClient.ConnectAsync("127.0.0.1", 5000); // 从配置读取值
        }
        NetworkStream networkStream = tcpClient.GetStream();
        // 发送消息
        await networkStream.WriteAsync(bytesToSend, 0, bytesToSend.Length);
        // 读取响应
        byte[] responseBuffer = new byte[1024]; // 从配置读取值
        int amountOfResponseBytes = await networkStream.ReadAsync(responseBuffer, 0, responseBuffer.Length);
        string responseMessage = Encoding.ASCII.GetString(responseBuffer, 0, amountOfResponseBytes);
        // 若为true则带超时关闭连接
        if (true) // 从配置读取值
        {
            networkStream.Close(1000); // 从配置读取值
            tcpClient.Close();
        }
        // 在此处理响应消息
        // ...
    }
}

我希望将IMyTcpService作为瞬时服务注入，想了解如何为TcpClient设置超时关闭？Socket类有接受超时参数的Close方法，但我未找到TcpClient对应的方法，仅NetworkStream有相关方法。

解决方案 #

核心思路：利用TcpClient的底层Socket实例 #

TcpClient本身没有直接提供带超时参数的Close方法，但它内部封装了一个Socket对象——你可以通过TcpClient.Client属性直接访问这个底层Socket，而Socket类的Close(int timeout)方法正好满足你的需求：它会等待指定的超时时间，确保所有待发送的数据都传输完成后再关闭连接。

优化后的代码实现 #

结合你的业务场景，我调整了关闭逻辑，同时优化了资源管理（比如用using语句自动释放NetworkStream），避免资源泄漏：

class MyTcpService : IMyTcpService {
    private readonly TcpClient tcpClient = new TcpClient();
    // 建议从配置文件注入这些参数，这里为了演示暂时硬编码
    private readonly string _serverIp = "127.0.0.1";
    private readonly int _serverPort = 5000;
    private readonly int _bufferSize = 1024;
    private readonly bool _closeAfterSend = true;
    private readonly int _closeTimeoutMs = 1000;

    public async Task Send(byte[] bytesToSend) {
        if (!tcpClient.Connected)
        {
            await tcpClient.ConnectAsync(_serverIp, _serverPort);
        }

        // 使用using自动释放NetworkStream资源，无需手动Close
        using (NetworkStream networkStream = tcpClient.GetStream())
        {
            // 发送消息
            await networkStream.WriteAsync(bytesToSend, 0, bytesToSend.Length);
            
            // 读取响应
            byte[] responseBuffer = new byte[_bufferSize];
            int amountOfResponseBytes = await networkStream.ReadAsync(responseBuffer, 0, responseBuffer.Length);
            string responseMessage = Encoding.ASCII.GetString(responseBuffer, 0, amountOfResponseBytes);
            
            // 在此处理响应消息
            // ...

            if (_closeAfterSend)
            {
                // 利用底层Socket的带超时关闭方法，确保数据发送完成
                tcpClient.Client.Close(_closeTimeoutMs);
            }
        }
    }
}

额外注意事项 #

• 瞬时服务的生命周期适配：因为IMyTcpService是瞬时服务，每次注入都会创建新的MyTcpService实例，每个实例的TcpClient都是独立的，不会出现跨实例的连接冲突问题，完全符合你的使用场景。
• Connected属性的局限性：TcpClient.Connected只能反映上一次IO操作的连接状态，无法实时检测远端是否主动关闭了连接。如果需要更可靠的连接校验，可以在发送前尝试执行一次非阻塞读取，或者依赖后续发送/接收操作抛出的异常来判断连接状态。
• 资源释放最佳实践：虽然瞬时服务最终会被GC回收，但显式关闭Socket是更稳妥的做法，能避免TCP连接处于TIME_WAIT状态过久，占用系统资源。

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