第C#三種方式實(shí)現(xiàn)Socket數(shù)據(jù)接收socketSend=socketWatch.Accept();//等待接收客戶(hù)端連接

//開(kāi)啟一個(gè)新線程，執(zhí)行接收消息方法

Threadr_thread=newThread(Received);

r_thread.IsBackground=true;

r_thread.Start(socketSend);

catch{}

///summary

///服務(wù)器端不停的接收客戶(hù)端發(fā)來(lái)的消息

////summary

///paramname="o"/param

voidReceived(objecto)

SocketsocketSend=oasSocket;

while(true)

//客戶(hù)端連接服務(wù)器成功后，服務(wù)器接收客戶(hù)端發(fā)送的消息

byte[]buffer=newbyte[1024*1024*3];

//實(shí)際接收到的有效字節(jié)數(shù)

intlen=socketSend.Receive(buffer);

if(len==0)

break;

//stringstr=Encoding.UTF8.GetString(buffer,0,len);

stringstringData="0x"+BitConverter.ToString(buffer,0,len).Replace("-","0x").ToLower();

this.Invoke((EventHandler)delegate

richTextBox1.Text+=DateTime.Now.ToString("yy-MM-ddhh:mm:ss-*-")+stringData+"\n";

catch{}

privatevoidBGWorker_DoWork2()

intrecv;//定義接收數(shù)據(jù)長(zhǎng)度變量

IPEndPointipEnd=newIPEndPoint(IPAddress.Parse(textBox1.Text),int.Parse(textBox2.Text));//接收端所監(jiān)聽(tīng)的接口,ip也可以用IPAddress.Any

Socketsocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);//初始化一個(gè)Socket對(duì)象

socket.Bind(ipEnd);//綁定套接字到一個(gè)IP地址和一個(gè)端口上(bind())；

socket.Listen(10);

newThread(delegate()

SocketclientSocket=null;

while(true)

Stopwatchsw=newStopwatch();

//開(kāi)始計(jì)時(shí)

sw.Start();

clientSocket=socket.Accept();//一旦接受連接，創(chuàng)建一個(gè)客戶(hù)端

Task.Run(()=

while(true)

byte[]data=newbyte[50];//對(duì)data清零

recv=clientSocket.Receive(data,0,data.Length,SocketFlags.None);

//if(recv==0)//如果收到的數(shù)據(jù)長(zhǎng)度小于0，則退出

//break;

stringstringData="0x"+BitConverter.ToString(data,0,recv).Replace("-","0x").ToLower();

this.Invoke((EventHandler)delegate

richTextBox1.Text+=DateTime.Now.ToString("yy-MM-ddhh:mm:ss-*-")+stringData+"\n";

//結(jié)束計(jì)時(shí)

sw.Stop();

longtimes=sw.ElapsedMilliseconds;

this.Invoke((EventHandler)delegate

richTextBox1.Text+="執(zhí)行查詢(xún)總共使用了"+times+"毫秒"+"\n";

{IsBackground=true}.Start();

voidReceiveMsg()

byte[]buffer=newbyte[1024];//預(yù)設(shè)最大接受1024個(gè)字節(jié)長(zhǎng)度，可修改

intcount=0;

while((count=stream.Read(buffer,0,buffer.Length))!=0)

stringstringData="0x"+BitConverter.ToString(buffer,0,count).Replace("-","0x").ToLower();

Console.WriteLine($"{tcpClient.Client.LocalEndPoint.ToString()}:{DateTime.Now.ToString("yy-MM-ddhh:mm:ss-*-")+stringData+"\n"}");

this.Invoke((EventHandler)delegate

richTextBox1.Text+=DateTime.Now.ToString("yy-MM-ddhh:mm:ss-*-")+stringData+"\n";

catch(Exceptionex)

Console.WriteLine(ex.Message);

privatevoidSendData(IPAddressremoteIP,intPort,byte[]bits)

//實(shí)例化socket

Socketsocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

IPEndPointipep=newIPEndPoint(remoteIP,Port);

socket.Connect(ipep);

//socket.Send(bits,8,SocketFlags.None);

socket.Send(bits);

socket.Close();

privatevoidbtnListen_Click(objectsend