如何在C#中实现TcpClient的自动重连

在C#中实现TcpClient的自动重连，可以通过封装一个自定义的TcpClient类，该类包含重连逻辑

using System;using System.Net.Sockets;using System.Threading;public class ReconnectingTcpClient{    private TcpClient _tcpClient;    private string _host;    private int _port;    private int _reconnectInterval; // 重连间隔（毫秒）    private bool _isConnected;    private Thread _reconnectThread;    public ReconnectingTcpClient(string host, int port, int reconnectInterval = 1000)    {        _host = host;        _port = port;        _reconnectInterval = reconnectInterval;        _tcpClient = new TcpClient();    }    public void Connect()    {        _isConnected = true;        _reconnectThread = new Thread(Reconnect);        _reconnectThread.Start();    }    private void Reconnect()    {        while (_isConnected)        {            try            {                if (!_tcpClient.Connected)                {                    _tcpClient.Connect(_host, _port);                    Console.WriteLine("已连接到服务器");                }            }            catch (Exception ex)            {                Console.WriteLine($"连接失败: {ex.Message}");                Thread.Sleep(_reconnectInterval);            }        }    }    public void Disconnect()    {        _isConnected = false;        _tcpClient.Close();        Console.WriteLine("已断开与服务器的连接");    }    public void Send(byte[] data)    {        if (_tcpClient.Connected)        {            NetworkStream stream = _tcpClient.GetStream();            stream.Write(data, 0, data.Length);        }    }    public byte[] Receive()    {        if (_tcpClient.Connected)        {            NetworkStream stream = _tcpClient.GetStream();            byte[] buffer = new byte[_tcpClient.ReceiveBufferSize];            int bytesRead = stream.Read(buffer, 0, buffer.Length);            byte[] receivedData = new byte[bytesRead];            Array.Copy(buffer, receivedData, bytesRead);            return receivedData;        }        return null;    }}

使用示例：

class Program{    static void Main(string[] args)    {        ReconnectingTcpClient client = new ReconnectingTcpClient("127.0.0.1", 8000);        client.Connect();        // 发送和接收数据...        client.Disconnect();    }}

这个示例中的ReconnectingTcpClient类包含了自动重连逻辑。当调用Connect()方法时，会启动一个新线程来处理重连。如果连接丢失，线程会尝试每隔指定的时间间隔（默认为1秒）重新连接。你可以通过修改_reconnectInterval变量来调整重连间隔。