C#构造函数中TcpClient.GetStream()返回null引发程序异常

TcpClient.GetStream() 返回null、后续读写抛出异常，核心是两个代码缺陷：

• 你使用的new TcpClient(ip, port)重载构造函数，在部分.NET运行时版本、双栈网络环境、连接被对端/防火墙快速重置的场景下，不会正确抛出连接失败异常，会返回未完成连接初始化的TcpClient实例。此时套接字不处于已连接状态，调用GetStream()无法拿到可用的NetworkStream引用，部分场景下会直接返回null。
• 代码没有做任何连接状态、流可用性校验，拿到流后直接存储为私有字段使用，也没有实现资源释放逻辑，一旦底层连接异常断开、资源被隐式回收，读写操作就会直接触发异常。

1. 替换TcpClient初始化逻辑：先创建无参TcpClient实例，显式调用Connect()方法建立连接，该方法在连接失败时会稳定抛出对应异常，不会返回状态异常的实例。
2. 增加多层校验：连接建立后校验Connected属性，获取流后校验流是否为null、是否支持读写，校验通过再存储引用。
3. 读写操作前增加状态检查，避免操作已断开的连接、已释放的流。
4. 实现IDisposable接口释放TcpClient和NetworkStream持有的非托管资源，避免端口泄漏、连接残留问题。

修复后的可直接运行代码：

using System.Net.Sockets;
using System.Net;
using System.Text;

class TcpPeer : IPeer, IDisposable
{
    private TcpClient _client;
    private NetworkStream _stream;
    private bool _disposed = false;

    public TcpPeer(string ip, int port)
    {
        _client = new TcpClient();
        // 显式建立连接，失败直接抛出对应Socket异常
        _client.Connect(ip, port);
        
        if (!_client.Connected)
        {
            throw new InvalidOperationException($"连接远端{ip}:{port}失败");
        }

        _stream = _client.GetStream();
        if (_stream == null || !_stream.CanRead || !_stream.CanWrite)
        {
            throw new InvalidOperationException("获取TCP通信流失败，流不可用");
        }
    }

    public byte[] Read()
    {
        ThrowIfInvalid();
        byte[] data = new byte[8192];
        
        int len = _stream.Read(data, 0, data.Length);
        // 处理对端正常关闭连接的场景
        if (len == 0)
        {
            Dispose();
            return Array.Empty<byte>();
        }

        Array.Resize(ref data, len);
        return data;
    }

    public void Write(byte[] msg)
    {
        ThrowIfInvalid();
        if (msg == null || msg.Length == 0) return;
        _stream.Write(msg, 0, msg.Length);
        _stream.Flush();
    }

    private void ThrowIfInvalid()
    {
        if (_disposed || !_client.Connected || _stream == null || !_stream.CanRead || !_stream.CanWrite)
        {
            throw new ObjectDisposedException(nameof(TcpPeer), "TCP连接已断开或实例已释放");
        }
    }

    public void Dispose()
    {
        if (_disposed) return;
        _disposed = true;
        
        _stream?.Close();
        _stream?.Dispose();
        _client?.Close();
        _client?.Dispose();
    }
}

interface IPeer
{
    byte[] Read();
    void Write(byte[] data);
}

• 上述代码是同步读写逻辑，如果需要高并发场景使用，可以替换为异步的ReadAsync/WriteAsync方法，避免阻塞线程。
• 如果需要支持自动重连，可以在读写捕获到Socket异常后，重新执行连接、流获取逻辑，重置内部的_client和_stream引用即可。

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