C#实现Socket数据接收的三种经典方式

int recv;//定义接收数据长度变量
IPEndPoint ipEnd = new IPEndPoint(IPAddress.Parse(textBox1.Text), int.Parse(textBox2.Text));
//接收端所监听的接口,ip也可以用IPAddress.Any
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//初始化一个Socket对象
socket.Bind(ipEnd);
//绑定套接字到一个IP地址和一个端口上(bind())；
socket.Listen(10);
while (true)
{
    byte[] data = new byte[1024];//对data清零
    Socket clientSocket = socket.Accept(); 
    //一旦接受连接，创建一个客户端
    recv = clientSocket.Receive(data);
    if (recv == 0) 
    //如果收到的数据长度小于0，则退出
        break;
    string stringData = "0x" + BitConverter.ToString(data).Replace("-", " 0x").ToLower();
    
    this.Invoke((EventHandler)delegate
    {
        richTextBox1.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss")  + stringData + "\n";
    });
}

private void BGWorker_DoWork()
{
    var serverIPEndPoint = new IPEndPoint(IPAddress.Parse("192.168.1.99"), 8234); // 当前服务器使用的ip和端口
    TcpListener tcpListener = new TcpListener(serverIPEndPoint);
    tcpListener.Start();
    Console.WriteLine("服务端已启用......"); // 阻塞线程的执行，直到一个客户端连接
    tcpClient = tcpListener.AcceptTcpClient();
    Console.WriteLine("已连接.");
    stream = tcpClient.GetStream();          // 创建用于发送和接受数据的NetworkStream

    var t1 = new Thread(ReceiveMsg);
    t1.IsBackground = true;
    t1.Start();
}

void ReceiveMsg()
{
    byte[] buffer = new byte[1024]; // 预设最大接受1024个字节长度，可修改
    int count = 0;
    try
    {
        while ((count = stream.Read(buffer, 0, buffer.Length)) != 0)
        {
            string stringData = "0x" + BitConverter.ToString(buffer, 0, count).Replace("-", " 0x").ToLower();
            Console.WriteLine($"{tcpClient.Client.LocalEndPoint.ToString()}:{DateTime.Now.ToString("yy-MM-dd hh:mm:ss -*- ") + stringData + "\n"}");
            this.Invoke((EventHandler)delegate
            {
                richTextBox1.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss -*- ") + stringData + "\n";
            });
        }
    }
    catch(Exception ex)
    {
        Console.WriteLine(ex.Message);
    }
}

private void BGWorker_DoWork1()
{
    int recv;
    IPEndPoint ipEnd = new IPEndPoint(IPAddress.Parse(textBox1.Text), int.Parse(textBox2.Text));
    Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    socket.Bind(ipEnd);
    socket.Listen(10);

    Thread thread = new Thread(Listen);
    thread.IsBackground = true;
    thread.Start(socket);
}

void Listen(object o)
{
    try
    {
        Socket socketWatch = o as Socket;
        while (true)
        {
            socketSend = socketWatch.Accept();
            Thread r_thread = new Thread(Received);
            r_thread.IsBackground = true;
            r_thread.Start(socketSend);
        }
    }
    catch { }
}

void Received(object o)
{
    try
    {
        Socket socketSend = o as Socket;
        while (true)
        {
            byte[] buffer = new byte[1024 * 1024 * 3];
            int len = socketSend.Receive(buffer);
            if (len == 0)
            {
                break;
            }
            string stringData = "0x" + BitConverter.ToString(buffer, 0, len).Replace("-", " 0x").ToLower();
            this.Invoke((EventHandler)delegate
            {
                richTextBox1.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss -*- ") + stringData + "\n";
            });
        }
    }
    catch { }
}

private void BGWorker_DoWork2()
{
    int recv;
    IPEndPoint ipEnd = new IPEndPoint(IPAddress.Parse(textBox1.Text), int.Parse(textBox2.Text));
    Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    socket.Bind(ipEnd);
    socket.Listen(10);
    new Thread(delegate ()
    {
        Socket clientSocket = null;
        while (true)
        {
            Stopwatch sw = new Stopwatch();
            sw.Start();

            clientSocket = socket.Accept();

            Task.Run(() =>
            {
                while (true)
                {
                    byte[] data = new byte[50];
                    recv = clientSocket.Receive(data, 0, data.Length, SocketFlags.None);
                    string stringData = "0x" + BitConverter.ToString(data, 0, recv).Replace("-", " 0x").ToLower();

                    this.Invoke((EventHandler)delegate
                    {
                        richTextBox1.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss -*- ") + stringData + "\n";
                    });
                    sw.Stop();
                    long times = sw.ElapsedMilliseconds;
                    this.Invoke((EventHandler)delegate
                    {
                        richTextBox1.Text += "执行查询总共使用了" + times + "毫秒" + "\n";
                    });
                }
            });
        }
    })
    { IsBackground = true }.Start();
}