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

1、Good is good, but better carries it.精益求精，善益求善。c多線程socket開發(fā)一個服務(wù)器對多個客戶端-下面直接講多線程服務(wù)器端開發(fā)。（直接給代碼和解釋吧）首先定義一個新類，用于傳遞（連接socket）和接受發(fā)送數(shù)據(jù)。classClientThreadEncodingencoding=Encoding.GetEncoding(GB2312);/解碼器（可以用于漢字）privateSocketclient;privatestringdata=null;privatebytereceiveBytes=newbyte1024;/服務(wù)器端設(shè)置緩沖區(qū)privatein

2、trecCount;/傳遞連接socketpublicClientThread(SocketClientSocket)this.client=ClientSocket;/數(shù)據(jù)處理接口publicvoidClientServer()trywhile(true)recCount=client.Receive(receiveBytes,receiveBytes.Length,0);/從客戶端接收信息if(recCount!=0)/當(dāng)服務(wù)器端的緩沖區(qū)接收到的信息不為空時data=encoding.GetString(receiveBytes,0,recCount);/接收數(shù)據(jù)/接收數(shù)據(jù)成功后給客戶端返

3、回OKclient.Send(encoding.GetBytes(OK),2,0);elsebreak;catch(Exceptionex)Console.Write(出現(xiàn)異常：);Console.WriteLine(ex.ToString();Console.ReadLine();client.Close();開始服務(wù)器端的多線程開發(fā)。stringHostName=Dns.GetHostName();/得到主機(jī)名IPHostEntryIpEntry=Dns.GetHostEntry(HostName);/得到主機(jī)IPstringstrIPAddr=IpEntry.AddressList0.T

4、oString();IPAddressip=IPAddress.Parse(strIPAddr);/把ip地址字符串轉(zhuǎn)換為IPAddressIPEndPointipep=newIPEndPoint(ip,9001);/用指定的端口和ipnewsock=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);newsock.Bind(ipep);/綁定newsock.Listen(10);/監(jiān)聽while(true)try/當(dāng)有可用的客戶端連接嘗試時執(zhí)行，并返回一個新的socketSocketclient=

5、newsock.Accept();/創(chuàng)建消息服務(wù)線程對象，并把連接socket賦于ClientThreadClientThreadnewclient=newClientThread(client);/把ClientThread類的ClientService方法委托給線程Threadnewthread=newThread(newThreadStart(newclient.ClientServer);/啟動消息服務(wù)線程newthread.Start();catch/連接中斷或者連接失敗這樣就完成了多線程socket的開發(fā)。一個服務(wù)器能對多個客戶端：當(dāng)有客戶端要求連接的時候創(chuàng)建新的線程去處理對應(yīng)的客

6、戶端。但是這有一個缺點是，當(dāng)有N個連接客戶端的時候，就有N個線程，會對程序性能以及計算機(jī)性能影響很大。下面用線程池的方法對線程進(jìn)行線程管理（限制最大的線程數(shù)，把空閑的線程重新使用，以提高性能）。使用.socket命名空間下的threadpool類。Threadnewthread=newThread(newThreadStart(newclient.ClientServer);newthread.Start();將以上程序代碼換成threadpool的靜態(tài)方法QueueUserWorkItem（這個方法默認(rèn)最多能有25個線程，你可以根據(jù)你自己的需要進(jìn)行設(shè)置，這里不詳說了）：ThreadPool.QueueUserWorkItem(newWa