c多線程socket開發(fā)一個服務(wù)器對多個客戶端

1、下面直接講多線程服務(wù)器端開發(fā)。（直接給代碼和解釋吧） 首先定義一個新類，用于傳遞（連接socket ）和接受發(fā)送數(shù)據(jù)。 class ClientThread Encoding encoding = Encoding.GetEncoding(GB2312); /解碼器（可以用于漢字） private Socket client; private string data = null; private byte receiveBytes = new byte1024;/服務(wù)器端設(shè)置緩沖區(qū) private int recCount; /傳遞連接socket public ClientThread(S

2、ocket ClientSocket) this.client = ClientSocket; /數(shù)據(jù)處理接口 public void ClientServer() try while (true) recCount = client.Receive(receiveBytes, receiveBytes.Length, 0);/從客戶端接收信息 if (recCount != 0)/當服務(wù)器端的緩沖區(qū)接收到的信息不為空時 data = encoding.GetString(receiveBytes, 0, recCount); /接收數(shù)據(jù) /接收數(shù)據(jù)成功后給客戶端返回OK client.Sen

3、d(encoding.GetBytes(OK), 2, 0); else break; catch (Exception ex) Console.Write(出現(xiàn)異常：); Console.WriteLine(ex.ToString(); Console.ReadLine(); client.Close(); 開始服務(wù)器端的多線程開發(fā)。 string HostName = Dns.GetHostName(); /得到主機名 IPHostEntry IpEntry = Dns.GetHostEntry(HostName); /得到主機IP string strIPAddr = IpEntry.A

4、ddressList0.ToString(); IPAddress ip = IPAddress.Parse(strIPAddr); /把ip地址字符串轉(zhuǎn)換為IPAddress IPEndPoint ipep = new IPEndPoint(ip, 9001); /用指定的端口和ip newsock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); newsock.Bind(ipep);/綁定 newsock.Listen(10);/監(jiān)聽 while (true) try /當有可用的

5、客戶端連接嘗試時執(zhí)行，并返回一個新的socket Socket client = newsock.Accept(); /創(chuàng)建消息服務(wù)線程對象，并把連接socket賦于ClientThread ClientThread newclient = new ClientThread(client); /把ClientThread 類的ClientService方法委托給線程 Thread newthread = new Thread(new ThreadStart(newclient.ClientServer); / 啟動消息服務(wù)線程 newthread.Start(); catch /連接中斷或者連

6、接失敗 這樣就完成了多線程socket的開發(fā)。一個服務(wù)器能對多個客戶端：當有客戶端要求連接的時候創(chuàng)建新的線程去處理對應(yīng)的客戶端。但是這有一個缺點是，當有N個連接客戶端的時候，就有N個線程，會對程序性能以及計算機性能影響很大。下面用線程池的方法對線程進行線程管理（限制最大的線程數(shù)，把空閑的線程重新使用，以提高性能）。 使用.socket命名空間下的threadpool類。 Thread newthread = new Thread(new ThreadStart(newclient.ClientServer); newthread.Start(); 將以上程序代碼換成threadpool的靜態(tài)方法 QueueUserWorkItem（這個方法默認最多能有25個線程，你可以根據(jù)你自己的需要進行設(shè)置，這里不詳說了）： ThreadPool.QueueUserWorkItem(new Wa