如何在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 = https://www.yisu.com/ask/new byte[receivedBytes];"接收数据失败: {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秒）重新连接。你可以根据需要调整重连间隔和其他参数。