关于服务端可以接受多个客户端的连接，进行互相通信的问题．

Question

[STAThread]
  static void Main() 
  {
   Application.Run(new Form1());
  }  private void btnListen_Click(object sender, System.EventArgs e)
  {
   try
   {
    hostIPAddress=IPAddress.Parse(txtServer.Text);
    port=txtPort.Text;
   }
   catch{MessageBox.Show("请输入正确的IP地址格式");}
   try
   {  //通过组合服务的主机 IP 地址和端口号，IPEndPoint 类形成到服务的连接点。
    Server=new IPEndPoint(hostIPAddress,Int32.Parse(port));
    // Create a socket object to establish a connection with the server
    listeningSocket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
    listeningSocket.Bind(Server); //绑定该主机端口
    listeningSocket.Listen(50); //监听端口，等待客户端连接请求。50是队列中最多可容纳的等待接受的传入连接数
    statusBar1.Text="主机"+txtServer.Text+"端口"+txtPort.Text+"开始监听.....";
    //Accept 以同步方式从侦听套接字的连接请求队列中提取第一个挂起的连接请求，然后创建并返回新的 Socket。
    //mySocket=listeningSocket.Accept();
    //一个进程可以创建一个或多个线程以执行与该进程关联的部分程序代码。使用 ThreadStart 委托指定由线程执行的程序代码。
    Thread thread=new Thread(new ThreadStart(ThreadProc));
    thread.Start();
   }
   catch(Exception ee){statusBar1.Text=ee.Message;}
  }
  private void ThreadProc()
  {
   //if(mySocket.Connected)
   //{
    //statusBar1.Text="与客户建立连接.";
    while(true)
    {
     /*Byte[] ByteRecv=new Byte[256];
     mySocket.Receive(ByteRecv,ByteRecv.Length,0);
     string strRecv=Encoding.BigEndianUnicode.GetString(ByteRecv);
     rtbReceive.AppendText(strRecv+"\r\n");*/
     Done.Reset(); //将状态设为非终止
     listeningSocket.BeginAccept(new AsyncCallback(AcceptCallBack),listeningSocket);//开始一个异步操作来接受一个传入的连接尝试
     Done.WaitOne(); //阻塞当前线程，直到当前线程收到信号。
    }
   //}
  }
  private void AcceptCallBack(IAsyncResult ar)//ar表示异步操作的状态。
  {
   Done.Set();//设为终止
   mySocket=(Socket)ar.AsyncState; //获取状态
   handler=mySocket.EndAccept(ar);   //异步接受传入的连接尝试，并创建新的 Socket 来处理远程主机通信,获取结果
   try
   {
    byte[] byteData=Encoding.BigEndianUnicode.GetBytes("准备完毕，可以通话"+"\r\n");
    //调用SendCallBack异步发送数据,
    handler.BeginSend(byteData,0,byteData.Length,0,new AsyncCallback(SendCallBack),handler);
   }
   catch(Exception ee){MessageBox.Show(ee.Message);}
   Thread thread=new Thread(new ThreadStart(ThreadRev));
   thread.Start();
  }
  
  private void SendCallBack(IAsyncResult ar)
  {
   try
   {
    handler=(Socket)ar.AsyncState;  //获取状态
    int bytesSent=handler.EndSend(ar);//结束挂起的异步发送,返回向 Socket 发送的字节数
   }
   catch{}
  }
  private void ThreadRev()
  { 
   handler.BeginReceive(buffer,0,BufferSize,0,new AsyncCallback(ReadCallBack),handler);
  }
  
  private void ReadCallBack(IAsyncResult ar)
  {
   int bytesRead=handler.EndReceive(ar); //结束挂起的异步读取,返回接收到的字节数。
   StringBuilder sb=new StringBuilder();   //接收数据的可变字符字符串,在通过追加、移除、替换或插入字符而创建它后可以对它进行修改。
   sb.Append(Encoding.BigEndianUnicode.GetString(buffer,0,bytesRead));//追加字符串
   string content=sb.ToString();   //转换为字符串
   sb.Remove(0,content.Length);   //清除sb内容
   rtbReceive.AppendText(content+"\r\n");
   handler.BeginReceive(buffer,0,BufferSize,0,new AsyncCallback(ReadCallBack),handler);
  }
  private void btnStop_Click(object sender, System.EventArgs e)
  {
   try
   {
    listeningSocket.Close();
    statusBar1.Text="主机"+txtServer.Text+"端口"+txtPort.Text+"监听停止";
   }
   catch{MessageBox.Show("监听尚未开始,关闭无效");}
  }  private void btnSend_Click(object sender, System.EventArgs e)
  {
   try
   {
    string strSend ="Server--->"+rtbSend.Text+"\r\n";
    Byte[] ByteSend = Encoding.BigEndianUnicode.GetBytes(strSend);
    handler.BeginSend(ByteSend,0,ByteSend.Length,0,new AsyncCallback(SendCallBack),handler);
   }
   catch{MessageBox.Show("连接尚未建立,无法发送.");}
  }  private void Form1_Closing(object sender, System.ComponentModel.CancelEventArgs e)
  {
   try
   {
    listeningSocket.Close();//在窗口关闭之前关闭Scoket连接并释放所有关联的资源。
   }
   catch{}
  }
 }