【正文】 lic Socket workSocket = null。 public const int BufferSize = 256。 public byte[] buffer = new byte[BufferSize]。 public StringBuilder sb = new StringBuilder()。 } private ManualResetEvent connectDone = new ManualResetEvent(false)。 private ManualResetEvent sendDone = new ManualResetEvent(false)。 private ManualResetEvent receiveDone = new ManualResetEvent(false)。 private Socket client = new Socket(, , )。 private String content_receive = 。 private String content_send = 。 private Thread demoThread = null。 delegate void SetTextCallback(string text)。 /// summary /// 連接客戶端 /// /summary /// param name=sender/param /// param name=e/param private void but_con_Click(object sender, EventArgs e) { if ( == || == ) { (請輸入要連接的IP和端口)。 return。 } IPAddress ipAddress = ()。 IPEndPoint remoteEP = new IPEndPoint(ipAddress, ())。 (remoteEP, new AsyncCallback(ConnectCallback), client)。 ()。 if () { Receive(client)。 } } private void ConnectCallback(IAsyncResult ar) { try { Socket client = (Socket)。 (ar)。 ()。 } catch (Exception e) { (())。 } } private void Receive(Socket client) { try { StateObject state = new StateObject()。 = client。 (, 0, , 0, new AsyncCallback(ReceiveCallback), state)。 } catch (Exception e) { } } private void ReceiveCallback(IAsyncResult ar) { StateObject state = (StateObject)。 Socket client = 。 int bytesRead = (ar)。 if (bytesRead 0) { content_receive = (, 0, bytesRead)。 Receive_text()。 } } private void Send(Socket client, String data) { byte[] byteData = (data)。 (byteData, 0, , 0, new AsyncCallback(SendCallback), client)。 } private void SendCallback(IAsyncResult ar) { try { Socket client = (Socket)。 int bytesSent = (ar)。 ()。 } catch (Exception e) { } } /// summary /// 發(fā)送接收 /// /summary /// param name=sender/param /// param name=e/param private void but_send_Click(object sender, EventArgs e) { if () { Send_text()。 if ( != ) { Send(client, )。 //()。 } Receive(client)。 //()。 } } /// summary /// 關閉客戶端 /// /summary /// param name=sender/param /// param name=e/param private void but_close_Click(object sender, EventArgs e) { DialogResult answer = (這將關閉客戶端。您是否確實要關閉它？, 提示框, )。 if (answer == ) { ()。 //()。 //()。 } if (answer == ) { return。 } } /// summary /// 安全調(diào)用text_receive控件 /// /summary private void Receive_text() { = new Thread(new ThreadStart())。 ()。 } private void ThreadProcSafe() { (content_receive)。 } private void SetText(string text) { if () { SetTextCallback d = new SetTextCallback(SetText)。 (d, new object[] { text })。 } else { = text。 } } /// summary /// 安全調(diào)用text_send控件 /// /summary private void Send_text() { = new Thread(new ThreadStart())。 ()。 } private void ThreadSend() { (content_send)。 } private void SendText(string text) { if () { SetTextCallback d = new SetTextCallback(SendText)。 (d, new object[] { text })。 } else { content_send = 。 } } private void Form1_Load(object sender, EventArgs e) { } }}