private Socket s;                                    //定义Socket对象private Thread th;                                   //客户端连接服务器的线程public Socket cSocket;                              //单个客户端连接的Socket对象public NetworkStream ns;                            //网络流public StreamReader sr;                        //流读取public StreamWriter sw;                        //流写入private delegate void SetTextCallback();         //用于操作主线程控件 

public void Communication() {while (true)     {try         {             cSocket = s.Accept();                   //用cSocket来代表该客户端连接             if (cSocket.Connected)                  //测试是否连接成功             {                 ns = new NetworkStream(cSocket);  //建立网络流，便于数据的读取                 sr = new StreamReader(ns);         //实例化流读取对象                 sw = new StreamWriter(ns);         //实例化写入流对象                 test();                               //从流中读取                 sw.WriteLine("收到请求，允许连接"); //向流中写入数据                 sw.Flush();                           //清理缓冲区             }else             {                 MessageBox.Show("连接失败");             }         }catch (SocketException ex)         {             MessageBox.Show(ex.Message);           //捕获Socket异常         }catch (Exception es)         {             MessageBox.Show("其他异常" + es.Message);      //捕获其他异常         }     } }//以下代码的用法在第16章有关线程的用法时曾提到过，主要用于从当前线程操作主线程中的控件，这里就不在赘//述 public void send() {     lbInfo.Items.Add(sr.ReadLine()+"\n"); }public void test() {     SetTextCallback stcb = new SetTextCallback(send);     Invoke(stcb); }

 button1.Enabled = false; s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//创建Socket对象 IPAddress serverIP = IPAddress.Parse("222.18.142.171"); IPEndPoint server = new IPEndPoint(serverIP,13);    //实例化服务器的IP和端口 s.Bind(server); s.Listen(10);try {     th = new Thread(new ThreadStart(Communication));     //创建线程     th.Start();                                                //启动线程     label1.Text = "服务器启动成功！"; }catch(Exception ex) {     MessageBox.Show("服务器启动失败！" + ex.Message); }

protected override void Dispose(bool disposing) {try     {if (disposing && (components != null))         {             components.Dispose();             th.Abort();//禁用当前Socket连接中的数据收发             s.Shutdown(System.Net.Sockets.SocketShutdown.Both);                          s.Close();         }base.Dispose(disposing);     }catch     {return;     } }//接着为当前窗体的FormClosed事件添加如下代码。 this.Close();

using System.IO; using System.Net.Sockets;using System.Net;

private Socket s;                                         //定义Socket对象                  public NetworkStream ns;                                //网络流public StreamReader sr;                                 //流读取 public StreamWriter sw;                                 //流写入

s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);serverIP = IPAddress.Parse("222.18.142.171");   //服务器IPtry{          s.Connect(serverIP, 13);                        //连接服务器，端口号用13}catch (Exception ex){     MessageBox.Show(ex.Message);}  try {          ns = new NetworkStream(s);                     //实例化网络流    sr = new StreamReader(ns);                     //实例化流读取对象    sw = new StreamWriter(ns);                     //实例化写入流对象    sw.WriteLine(textBox1.Text);                  //将textBox1.Text的数据写入流    sw.Flush();                                       //清理缓冲区    lbInfo.Items.Add(sr.ReadLine());              //将从流中读取的数据写入lbInfo28  }catch (Exception ex){    MessageBox.Show(ex.Message);                  //捕获异常}