C#基于Socket的CS模式的完整例子

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");   //服务器IP
try
{      
    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);                  //捕获异常
}