C# 三種方式實現Socket數據接收(經典)

Stream.Read 方法

當在派生類中重寫時，從當前流讀取字節序列，並將此流中的位置提升讀取的字節數。

語法：

public abstract int Read(byte[] buffer, int offset, int count)

參數：

• buffer: 字節數組。此方法返回時，該緩沖區包含指定的字符數組，該數組的 offset 和 (offset + count -1) 之間的值由從當前源中讀取的字節替換。

• offset: buffer 中的從零開始的字節偏移量，從此處開始存儲從當前流中讀取的數據。

• count: 要從當前流中最多讀取的字節數。

返回值：

讀入緩沖區中的總字節數。如果當前可用的字節數沒有請求的字節數那么多，則總字節數可能小於請求的字節數，或者如果已到達流的末尾，則為零 (0)。

備注：

此方法的實現從當前流中讀取最多的 count 個字節，並將它們存儲在從 offset 開始的 buffer 中。流中的當前位置提升已讀取的字節數；但是，如果出現異常，流中的當前位置保持不變。實現返回已讀取的字節數。僅當位置當前位於流的末尾時，返回值才為零。如果沒有任何可用的數據，該實現將一直阻塞到至少有一個字節的數據可讀為止。僅當流中不再有其他的數據，而且也不再需要更多的數據（如已關閉的套接字或文件尾）時，Read 才返回 0。即使尚未到達流的末尾，實現仍可以隨意返回少於所請求的字節。

之前一般采用如下方式進行數據接收：

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";
                });
            }

　　

之前用的時候沒發現什么問題，但是今天在測試金屬門數據接收的時候發現會丟數據，金屬門每隔十秒給我一次數據，用上面這個差不多60秒才能收到一組數據，針對以上問題，做了如下修改：

將數據接收放到 while (true)，數據接收正常。

以下分別采用三種方式實現了數據的正常接收，代碼如下：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace MetalGate
{
    public partial class MainForm : Form
    {
        public MainForm()
        {
            InitializeComponent();
        }
        private BackgroundWorker demoBGWorker = new BackgroundWorker();
        static TcpClient tcpClient;
        static NetworkStream stream;
        private void MainForm_Load(object sender, EventArgs e)
        {
            textBox1.Text = "192.168.1.99";
            textBox2.Text = "8234";

        }
        //private void BGWorker_DoWork(object sender, DoWorkEventArgs e)
         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();

        }
        private void BGWorker_DoWork1()
        {
            //在這里執行耗時的運算。
            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);

            //創建監聽線程
             Thread thread = new Thread(Listen);
             thread.IsBackground = true;
             thread.Start(socket);

          
        }
         /// <summary>
        /// 等待客戶端的連接 並且創建與之通信的Socket
        /// </summary>
        Socket socketSend;
        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 { }
        }
        /// <summary>
         /// 服務器端不停的接收客戶端發來的消息
         /// </summary>
         /// <param name="o"></param>
         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 str = Encoding.UTF8.GetString(buffer, 0, len);
                    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));//接收端所監聽的接口,ip也可以用IPAddress.Any
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//初始化一個Socket對象
            socket.Bind(ipEnd);//綁定套接字到一個IP地址和一個端口上(bind())；
            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];//對data清零
                            recv = clientSocket.Receive(data, 0, data.Length, SocketFlags.None);
                            //if (recv == 0) //如果收到的數據長度小於0，則退出
                            //    break;
                            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();
        }

        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 SendData(IPAddress remoteIP, int Port, byte[] bits)
        {
            //實例化socket               
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint ipep = new IPEndPoint(remoteIP, Port);
            socket.Connect(ipep);
            //socket.Send(bits, 8, SocketFlags.None);
            socket.Send(bits);
            socket.Close();
        }

        private void btnListen_Click(object sender, EventArgs e)
        {
            //demoBGWorker.DoWork += BGWorker_DoWork;
            //demoBGWorker.RunWorkerAsync();
            //Task.Run(() =>
           // {
                BGWorker_DoWork2();
            //});
        }



        private void btnSend_Click(object sender, EventArgs e)
        {
            byte[] order = new byte[8];
            order = new byte[] { 0x80, 0x04, 0x00, 0x7F };
            SendData(IPAddress.Parse("192.168.1.100"), int.Parse("49558"), order);
            MessageBox.Show("指令發送成功");
        }
    }
}

　　

 

 

 

----------------------------------------------------

以上就是本節的全部內容，如果感覺有用，請多多的點擊在看和分享，需要進技術交流群的，請加小編微信zls20210502，切記備注 進群！