C#中Socket用法，多個(gè)聊天和單一聊天。

自己琢磨Socket剛剛幾天，所以整理出來和大家共享一下。廢話少說直接進(jìn)入正題。

在C#中提供了兩種網(wǎng)絡(luò)服務(wù)，一種是Socket類，另一種是TcpListener（服務(wù)器）,TcpClient（客戶端）;

至于這兩種有什么區(qū)別那；MSDN上是這樣解釋的：

TcpClient 類，TcpListener 類提供了一些簡單的方法，用于在同步阻止模式下通過網(wǎng)絡(luò)來連接、發(fā)送和接收流數(shù)據(jù)。

Socket 類為網(wǎng)絡(luò)通信提供了一套豐富的方法和屬性。 Socket 類允許您使用 PRotocolType 枚舉中所列出的任何一種協(xié)議執(zhí)行異步和同步數(shù)據(jù)傳輸。

個(gè)人理解就是一個(gè)是用于簡單的業(yè)務(wù)，一種用于復(fù)雜的業(yè)務(wù)。所以感覺是一樣的。本文事例主要用Socket類來實(shí)現(xiàn)。一般來說復(fù)雜的會(huì)了，簡單的應(yīng)該也差不多了。

先從第一個(gè)情景來說：第一個(gè)就是建立多人聊天的模式，就是多個(gè)客戶端連接一個(gè)服務(wù)器，然后可以和多個(gè)客戶端通信。就像QQ里的群聊。

首先我們來見一個(gè)服務(wù)器：

就包含一個(gè)文本框就行了，里邊具體代碼如下：

 1     public partial class server : Form 2     { 3         private ipEndPoint ServerInfo;//存放服務(wù)器的IP和端口信息 4         private Socket ServerSocket;//服務(wù)端運(yùn)行的SOCKET 5         private Thread ServerThread;//服務(wù)端運(yùn)行的線程 6         private Socket[] ClientSocket;//為客戶端建立的SOCKET連接 7         private int ClientNumb;//存放客戶端數(shù)量 8         private byte[] MsgBuffer;//存放消息數(shù)據(jù) 9 10         private object obj;11 12         public server()13         {14             InitializeComponent();15             ListenClient();16         }17 18         /// <summary>19         /// 開始服務(wù)，監(jiān)聽客戶端20         /// </summary>21         private void ListenClient()22         {23             try24             {25                 ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);26                 IPAddress ip = IPAddress.Parse("127.0.0.1");27                 ServerInfo = new IPEndPoint(ip, Int32.Parse("3000"));28                 ServerSocket.Bind(ServerInfo);29                 ServerSocket.Listen(10);30 31                 ClientSocket = new Socket[65535];32                 MsgBuffer = new byte[65535];33                 ClientNumb = 0;34 35                 ServerThread = new Thread(new ThreadStart(RecieveAccept));36                 ServerThread.Start();37             }38             catch (System.Exception ex)39             {40 41             }42         }43 44         /// <summary>45         /// 添加阻塞，監(jiān)聽客戶端46         /// </summary>47         private void RecieveAccept()48         {49             while (true)50             {51                 //等待接受客戶端連接，如果有就執(zhí)行下邊代碼，沒有就阻塞52                 ClientSocket[ClientNumb] = ServerSocket.Accept();53                 //接受客戶端信息，沒有阻塞，則會(huì)執(zhí)行下邊輸出的代碼；如果是Receive則不會(huì)執(zhí)行下邊輸出代碼54                 ClientSocket[ClientNumb].BeginReceive(MsgBuffer, 0, MsgBuffer.Length, SocketFlags.None,55                     new AsyncCallback(ReceiveCallback), ClientSocket[ClientNumb]);56                 this.Invoke((MethodInvoker)delegate57                 {58                     lock (this.textBox1)59                         this.textBox1.Text += "客戶端：" + ClientNumb.ToString() + "連接成功！" + "/r/n";60                 });61                 ClientNumb++;62             }63         }64 65         /// <summary>66         /// 回發(fā)數(shù)據(jù)到客戶端67         /// </summary>68         /// <param name="ar"></param>69         private void ReceiveCallback(IAsyncResult ar)70         {71             try72             {73                 Socket rSocket = (Socket)ar.AsyncState;74                 int rEnd = rSocket.EndReceive(ar);75 76                 for (int i = 0; i < ClientNumb; i++)77                 {78                     if (ClientSocket[i].Connected)79                     {80                         //發(fā)送數(shù)據(jù)到客戶端81                         ClientSocket[i].Send(MsgBuffer, 0, rEnd, SocketFlags.None);82                     }83 84                     //同時(shí)接受客戶端回發(fā)的數(shù)據(jù)，用于回發(fā)85                     rSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), rSocket);86                 }87             }88             catch (System.Exception ex)89             {90 91             }92         }93     }

然后我們添加客戶端代碼，客戶端要一個(gè)按鈕和兩個(gè)文本框

具體代碼如下：

 1     public partial class Client : Form 2     { 3         private IPEndPoint ServerInfo; 4         private Socket ClientSocket; 5         private object obj; 6  7         //信息接收緩存 8         private Byte[] MsgBuffer; 9         //信息發(fā)送存儲(chǔ)10         private Byte[] MsgSend;11 12         public Client()13         {14             InitializeComponent();15             ConnectServer();16             this.button1.Click += new EventHandler(button1_Click);17         }18 19         /// <summary>20         /// 打開客戶端，即連接服務(wù)器21         /// </summary>22         private void ConnectServer()23         {24             try25             {26                 ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);27                 MsgBuffer = new byte[65535];28                 MsgSend = new byte[65535];29                 IPAddress ip = IPAddress.Parse("127.0.0.1");30                 ServerInfo = new IPEndPoint(ip, Int32.Parse("3000"));31                 ClientSocket.Connect(ServerInfo);32                 //發(fā)送信息至服務(wù)器33                 ClientSocket.Send(Encoding.Unicode.GetBytes("用戶： 進(jìn)入系統(tǒng)！" + "/r/n"));34                 ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, SocketFlags.None,35                     new AsyncCallback(ReceiveCallback), null);36                 this.textBox1.Text += "登錄服務(wù)器成功" + "/r/n";37             }38             catch (System.Exception ex)39             {40 41             }42         }43 44         /// <summary>45         /// 回調(diào)時(shí)調(diào)用46         /// </summary>47         /// <param name="ar"></param>48         private void ReceiveCallback(IAsyncResult ar)49         {50             int rEnd = ClientSocket.EndReceive(ar);51             this.Invoke((MethodInvoker)delegate52                  {53                      lock (this.textBox1)54                      {55                          this.textBox1.Text += Encoding.Unicode.GetString(MsgBuffer, 0, rEnd) + "/r/n";56                      }57                  });58             ClientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), null);59         }60 61         /// <summary>62         /// 發(fā)送信息63         /// </summary>64         /// <param name="sender"></param>65         /// <param name="e"></param>66         private void button1_Click(object sender, EventArgs e)67         {68             MsgSend = Encoding.Unicode.GetBytes("說：/n" + this.textBox2.Text + "/n/r");69             if (ClientSocket.Connected)70             {71                 ClientSocket.Send(MsgSend);72             }73         }74 75     }76 }

這樣先運(yùn)行服務(wù)器，在多運(yùn)行幾個(gè)客戶端就可以了。

下邊講一下第二種案例:這種是多個(gè)客戶端和服務(wù)器連接，每個(gè)客戶端都可以和服務(wù)器通信，但是客戶端之間沒有通信，而且每個(gè)客戶端和服務(wù)器通信時(shí)，不會(huì)影響其他客戶端。

具體樣式如圖：

接著我們來看看具體的代碼：

先來看看服務(wù)器的，樣式和第一種一樣，

具體代碼：

 1     public partial class Server : Form 2     { 3         private Socket socket = null; 4         private Thread thread = null; 5  6         public Server() 7         { 8             InitializeComponent(); 9             StartListening();10         }11 12         /// 13         /// 開始監(jiān)聽客戶端14         /// 15         private void StartListening()16         {17             try18             {19                 socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);20                 IPAddress ipaddress = IPAddress.Parse("127.0.0.1");21                 IPEndPoint endPoint = new IPEndPoint(ipaddress, int.Parse("3000"));22 23                 socket.Bind(endPoint);24                 socket.Listen(20);25 26                 thread = new Thread(new ThreadStart(WatchConnection));27                 thread.IsBackground = true;28                 thread.Start();29 30                 this.listBox1.Text = "開始監(jiān)聽客戶端傳來的消息" + "/r/n";31             }32             catch (System.Exception ex)33             {34                 this.listBox1.Text += "SocketException" + ex;35             }36         }37 38         Socket[] socConnection = ne