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.AnySocket 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(); // 創建用于發送和接受數據的NetworkStreamvar 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.AnySocket 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.AnySocket 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("指令發送成功");}} }

測試：

?Task.Run(() => {}); 這個可以去掉；

總結

以上是生活随笔為你收集整理的C# 三种方式实现Socket数据接收(经典)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。