int port = 6000;string host = "127.0.0.1";IPAddress ip = IPAddress.Parse(host);IPEndPoint ipe = new IPEndPoint(ip, port);Socket sSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);sSocket.Bind(ipe);sSocket.Listen(0);Console.WriteLine("监听已经打开，请等待");//receive messageSocket serverSocket = sSocket.Accept();Console.WriteLine("连接已经建立");string recStr = "";byte[] recByte = new byte[4096];int bytes = serverSocket.Receive(recByte, recByte.Length, 0);recStr += Encoding.ASCII.GetString(recByte, 0, bytes);//send messageConsole.WriteLine("服务器端获得信息:{0}", recStr);string sendStr = "send to client :hello";byte[] sendByte = Encoding.ASCII.GetBytes(sendStr);serverSocket.Send(sendByte, sendByte.Length, 0);serverSocket.Close();sSocket.Close();

int port = 6000;string host = "127.0.0.1";//服务器端ip地址IPAddress ip = IPAddress.Parse(host);IPEndPoint ipe = new IPEndPoint(ip, port);Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);clientSocket.Connect(ipe);//send messagestring sendStr = "send to server : hello,ni hao";byte[] sendBytes = Encoding.ASCII.GetBytes(sendStr);clientSocket.Send(sendBytes);//receive messagestring recStr = "";byte[] recBytes = new byte[4096];int bytes = clientSocket.Receive(recBytes, recBytes.Length, 0);recStr += Encoding.ASCII.GetString(recBytes, 0, bytes);Console.WriteLine(recStr);clientSocket.Close();

public void Connect(IPAddress ip, int port){this.clientSocket.BeginConnect(ip, port, new AsyncCallback(ConnectCallback), this.clientSocket);}private void ConnectCallback(IAsyncResult ar){try{Socket handler = (Socket)ar.AsyncState;handler.EndConnect(ar);}catch (SocketException ex){ }}

public void Send(string data){Send(System.Text.Encoding.UTF8.GetBytes(data));}private void Send(byte[] byteData){try{int length = byteData.Length;byte[] head = BitConverter.GetBytes(length);byte[] data = new byte[head.Length + byteData.Length];Array.Copy(head, data, head.Length);Array.Copy(byteData, 0, data, head.Length, byteData.Length);this.clientSocket.BeginSend(data, 0, data.Length, 0, new AsyncCallback(SendCallback), this.clientSocket);}catch (SocketException ex){ }}private void SendCallback(IAsyncResult ar){try{Socket handler = (Socket)ar.AsyncState;handler.EndSend(ar);}catch (SocketException ex){ }}

public void ReceiveData(){clientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), null);}private void ReceiveCallback(IAsyncResult ar){try{int REnd = clientSocket.EndReceive(ar);if (REnd > 0){byte[] data = new byte[REnd];Array.Copy(MsgBuffer, 0, data, 0, REnd);//在此次可以对data进行按需处理clientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), null);}else{dispose();}}catch (SocketException ex){ }}private void dispose(){try{this.clientSocket.Shutdown(SocketShutdown.Both);this.clientSocket.Close();}catch (Exception ex){ }}

public Hashtable DataTable = new Hashtable();//因为要接收到多个服务器（ip）发送的数据，此处按照ip地址分开存储发送数据public void DataArrial(byte[] Data , string ip){try{if (Data.Length < 12)//按照需求进行判断{lock (DataTable){if (DataTable.Contains(ip)){DataTable[ip] = Data;return;}}}if (Data[0] != 0x1F || Data[1] != 0xF1)//标志位（按照需求编写）{if (DataTable.Contains(ip)){if (DataTable != null){byte[] oldData = (byte[])DataTable[ip];//取出粘包数据if (oldData[0] != 0x1F || oldData[1] != 0xF1){return;}byte[] newData = new byte[Data.Length + oldData.Length];Array.Copy(oldData, 0, newData, 0, oldData.Length);Array.Copy(Data, 0, newData, oldData.Length, Data.Length);//组成新数据数组，先到的数据排在前面，后到的数据放在后面lock (DataTable){DataTable[ip] = null;}DataArrial(newData, ip);return;}}return;}int revDataLength = Data[2];//打算发送数据的长度int revCount = Data.Length;//接收的数据长度if (revCount > revDataLength)//如果接收的数据长度大于发送的数据长度，说明存在多帧数据，继续处理{byte[] otherData = new byte[revCount - revDataLength];Data.CopyTo(otherData, revCount - 1);Array.Copy(Data, revDataLength, otherData, 0, otherData.Length);Data = (byte[])Redim(Data, revDataLength);DataArrial(otherData, ip);}if (revCount < revDataLength) //接收到的数据小于要发送的长度{if (DataTable.Contains(ip)){DataTable[ip] = Data;//更新当前粘包数据return;}}//此处可以按需进行数据处理}catch (Exception ex){ }}private Array Redim(Array origArray, Int32 desizedSize){//确认每个元素的类型Type t = origArray.GetType().GetElementType();//创建一个含有期望元素个数的新数组//新数组的类型必须匹配数组的类型Array newArray = Array.CreateInstance(t, desizedSize);//将原数组中的元素拷贝到新数组中。Array.Copy(origArray, 0, newArray, 0, Math.Min(origArray.Length, desizedSize));//返回新数组return newArray;}