如何在C#中实现Socket的断线重连

在C#中实现Socket的断线重连，可以通过封装一个自定义的Socket类，该类包含重连逻辑和异常处理。以下是一个简单的示例：

using System;using System.Net;using System.Net.Sockets;using System.Threading;public class ReconnectingSocket{    private Socket _socket;    private EndPoint _remoteEndPoint;    private int _reconnectInterval; // 重连间隔（毫秒）    private bool _isConnected;    private readonly object _lock = new object();    public ReconnectingSocket(EndPoint remoteEndPoint, int reconnectInterval = 5000)    {        _remoteEndPoint = remoteEndPoint;        _reconnectInterval = reconnectInterval;    }    public void Connect()    {        lock (_lock)        {            if (_isConnected) return;            _socket = new Socket(_remoteEndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);            while (!_isConnected)            {                try                {                    _socket.Connect(_remoteEndPoint);                    _isConnected = true;                }                catch (Exception ex)                {                    Console.WriteLine($"连接失败: {ex.Message}");                    Thread.Sleep(_reconnectInterval);                }            }        }    }    public void Disconnect()    {        lock (_lock)        {            if (!_isConnected) return;            _socket.Shutdown(SocketShutdown.Both);            _socket.Close();            _isConnected = false;        }    }    public void Send(byte[] data)    {        if (!_isConnected) throw new InvalidOperationException("套接字未连接");        try        {            _socket.Send(data);        }        catch (Exception ex)        {            Console.WriteLine($"发送数据失败: {ex.Message}");            _isConnected = false;            Connect();        }    }    public byte[] Receive(int bufferSize)    {        if (!_isConnected) throw new InvalidOperationException("套接字未连接");        byte[] buffer = new byte[bufferSize];        try        {            int receivedBytes = _socket.Receive(buffer);            if (receivedBytes > 0)            {                byte[] data = new byte[receivedBytes];                Array.Copy(buffer, 0, data, 0, receivedBytes);                return data;            }        }        catch (Exception ex)        {            Console.WriteLine($"接收数据失败: {ex.Message}");            _isConnected = false;            Connect();        }        return null;    }}

使用示例：

class Program{    static void Main(string[] args)    {        IPAddress ipAddress = IPAddress.Parse("127.0.0.1");        int port = 8080;        IPEndPoint remoteEndPoint = new IPEndPoint(ipAddress, port);        ReconnectingSocket socket = new ReconnectingSocket(remoteEndPoint);        socket.Connect();        // 发送和接收数据...        socket.Disconnect();    }}

这个示例中的ReconnectingSocket类封装了一个标准的Socket对象，并在发送和接收数据时添加了重连逻辑。当连接断开时，它会尝试每隔指定的时间间隔（默认为5秒）重新连接。你可以根据需要调整重连间隔和其他参数。