C#網(wǎng)絡(luò)編程（基本概念和操作）

C#網(wǎng)絡(luò)編程（基本概念和操作）?Part1引言C#網(wǎng)絡(luò)編程系列文章計(jì)劃簡單地講述網(wǎng)絡(luò)編程方面的基礎(chǔ)知識(shí),由于本人在這方面功カ有限,所以只能提供ー些初步的入門知識(shí),希望能対剛開始學(xué)習(xí)的朋友提供?些幫助。如果想要更加深入的內(nèi)容,可以參考相關(guān)書籍。本文是該系列第?篇，主要講述了基于套接字（Socket）進(jìn)行網(wǎng)絡(luò)編程的基本概念,其中包括TCP協(xié)議、套接字、聊天程序的三種開發(fā)模式，以及兩個(gè)基本操作:偵聽端口、連接遠(yuǎn)程服務(wù)端:第二篇講述了一個(gè)簡單的范例:從客戶端傳輸字符串到服務(wù)端,服務(wù)端接收并打印字符串，將字符串改為大寫,然后再將字符串回發(fā)到客戶端，客戶端最后打印傳回的字符串:第三篇是第二篇的一個(gè)強(qiáng)化，講述了第二篇中沒有解決的ー個(gè)問題，并使用了異步傳輸?shù)姆绞絹硗瓿珊偷诙瑯拥墓δ?第四篇?jiǎng)t演示了如何在客戶端與服務(wù)端之間收發(fā)文件;第五篇實(shí)現(xiàn)了一個(gè)能夠在線聊天并進(jìn)行文件傳輸?shù)牧奶斐绦颍瑢?shí)際上是對(duì)前面知識(shí)的ー個(gè)綜合應(yīng)用。與本文相關(guān)的還有一篇文章是:C# ，但這個(gè)聊天程序不及本系列中的聊天程序功能強(qiáng)大，實(shí)現(xiàn)方式也不相同。網(wǎng)絡(luò)編程基本概念.面向連接的傳輸協(xié)議:TCP對(duì)于TCP協(xié)議我不想說太多東西,這屬于大學(xué)課程,又涉及計(jì)算機(jī)科學(xué),而我不是“學(xué)院派”,對(duì)于這部分內(nèi)容，我覺得作為開發(fā)人員，只需要掌握與程序相關(guān)的概念就可以了,不需要做太艱深的研究。我們首先知道TCP是面向連接的,它的意思是說兩個(gè)遠(yuǎn)程主機(jī)（或者叫進(jìn)程,因?yàn)閷?shí)際上遠(yuǎn)程通信是進(jìn)程之間的通信,而進(jìn)程則是運(yùn)行中的程序），必須首先進(jìn)行一個(gè)握手過程，確認(rèn)連接成功,之后才能傳輸實(shí)際的數(shù)據(jù)。比如說進(jìn)程A想將字符串“It'safinedaytoday”發(fā)給進(jìn)程B,它首先要建立連接。在這ー過程中,它首先需要知道進(jìn)程B的位置（主機(jī)地址和端口號(hào)）?隨后發(fā)送一個(gè)不包含實(shí)際數(shù)據(jù)的請(qǐng)求報(bào)文,我們可以將這個(gè)報(bào)文稱之為"hello"。如果進(jìn)程B接收到了這個(gè)“hello”,就向進(jìn)程A回復(fù)ー個(gè)“hello”，進(jìn)程A隨后オ發(fā)送實(shí)際的數(shù)據(jù)"It'safinedaytoday”。關(guān)于TCP第二個(gè)需要了解的,就是它是全雙工的。意思是說如果兩個(gè)主機(jī)上的進(jìn)程（比如進(jìn)程A、進(jìn)程B）,一旦建立好連接,那么數(shù)據(jù)就既可以由A流向B,也可以由B流向A。除此以外，它還是點(diǎn)對(duì)點(diǎn)的，意思是說ー個(gè)TCP連接總是兩者之間的,在發(fā)送中，通過ー個(gè)連接將數(shù)據(jù)發(fā)給多個(gè)接收方是不可能的。TCP還有一個(gè)特性，就是稱為可靠的數(shù)據(jù)傳輸,意思是連接建立后,數(shù)據(jù)的發(fā)送一定能夠到達(dá),并且是有序的,就是說發(fā)的時(shí)候你發(fā)了ABC,那么收的一方收到的也一定是ABC,而不會(huì)是BCA或者別的什么。編程中與TCP相關(guān)的最重要的?個(gè)概念就是套接字。我們應(yīng)該知道網(wǎng)絡(luò)七層協(xié)議，如果我們將上面的應(yīng)用程、表示層、會(huì)話層籠統(tǒng)地算作一層（有的教材便是如此劃分的），那么我們編寫的網(wǎng)絡(luò)應(yīng)用程序就位于應(yīng)用層，而大家知道TCP是屬于傳輸層的協(xié)議,那么我們?cè)趹?yīng)用層如何使用傳輸層的服務(wù)呢（消息發(fā)送或者文件上傳下載）?大家知道在應(yīng)用程序中我們用接口來分離實(shí)現(xiàn),在應(yīng)用層和傳輸層之間,則是使用套接字來進(jìn)行分離。它就像是傳輸層為應(yīng)用層開的ー個(gè)小口,應(yīng)用程序通過這個(gè)小口向遠(yuǎn)程發(fā)送數(shù)據(jù),或者接收遠(yuǎn)程發(fā)來的數(shù)據(jù):而這個(gè)小口以內(nèi)，也就是數(shù)據(jù)進(jìn)入這個(gè)口之后,或者數(shù)據(jù)從這個(gè)口出來之前,我們是不知道也不需要知道的，我們也不會(huì)關(guān)心它如何傳輸，這屬于網(wǎng)絡(luò)其它層次的工作。舉個(gè)例子，如果你想寫封郵件發(fā)給遠(yuǎn)方的朋友，那么你如何寫信、將信打包,屬于應(yīng)用層，信怎么寫，怎么打包完全由我們做主;而當(dāng)我們將信投入郵筒時(shí)，郵筒的那個(gè)口就是套接字,在進(jìn)入套接字之后，就是傳輸層、網(wǎng)絡(luò)層等（郵局、公路交管或者航線等）其它層次的工作了。我們從來不會(huì)去關(guān)心信是如何從西安發(fā)往北京的,我們只知道寫好了投入郵筒就0K了?？梢杂孟旅孢@兩幅圖來表示它;注意在上面圖中,兩個(gè)主機(jī)是対等的,但是按照約定,我們將發(fā)起請(qǐng)求的一方稱為客戶端,將另一端稱為服務(wù)端?？梢钥磳鐑蓚€(gè)程序之間的對(duì)話是通過套接字這個(gè)出入口來完成的，實(shí)際上套接字包含的最重要的也就是兩個(gè)信息:連接至遠(yuǎn)程的本地的端口信息（本機(jī)地址和端口號(hào)）,連接到的遠(yuǎn)程的端口信息（遠(yuǎn)程地址和端口號(hào)）。注意上面詞語的微妙變化,ー個(gè)是本地地址，ー個(gè)是遠(yuǎn)程地址。這里又出現(xiàn)了了一個(gè)名詞端口。一般來說我們的計(jì)算機(jī)上運(yùn)行著非常多的應(yīng)用程序，它們可能都需要同遠(yuǎn)程主機(jī)打交道，所以遠(yuǎn)程主機(jī)就需要有一個(gè)ID來標(biāo)識(shí)它想與本地機(jī)器上的哪個(gè)應(yīng)用程序打交道，這里的ID就是端口。將端口分配給ー個(gè)應(yīng)用程序，那么來自這個(gè)端口的數(shù)據(jù)則總是針對(duì)這個(gè)應(yīng)用程序的。有這樣ー個(gè)很好的例子:可以將主機(jī)地址想象為電話號(hào)碼，而將端口號(hào)想象為分機(jī)號(hào)。在,NET中，盡管我們可以直接對(duì)套接字編程，但是.NET提供了兩個(gè)類將対套接字的編程進(jìn)行了一個(gè)封裝，使我們的使用能夠更加方便，這兩個(gè)類是TcpClient和TcpListener,它與套接字的關(guān)系如下：去往傳輸乂來白傳輸乂從上面圖中可以看出TcpClient和TcpListener對(duì)套接字進(jìn)行了封裝。從中也可以看出,TcpListener用于接受連接請(qǐng)求,而TcpClient則用于接收和發(fā)送流數(shù)據(jù)這幅圖的意思是TcpListener持續(xù)地保持對(duì)端口的偵聽,一旦收到ー個(gè)連接請(qǐng)求后，就可以獲得一

個(gè)TcpClient對(duì)象,而對(duì)于數(shù)據(jù)的發(fā)送和接收都有TcpClient去完成。此時(shí),TcpListener并沒有停止工作,它始終持續(xù)地保持對(duì)端口的偵聽狀態(tài)。我們考慮這樣?種情況:兩臺(tái)主機(jī),主機(jī)A和主機(jī)B,起初它們誰也不知道誰在哪兒,當(dāng)它們想要進(jìn)行對(duì)話時(shí),總是需要有一方發(fā)起連接,而另一方則需要對(duì)本機(jī)的某一端口進(jìn)行偵聽。而在偵聽方收到連接請(qǐng)求、并建立起連接以后,它們之間進(jìn)行收發(fā)數(shù)據(jù)時(shí),發(fā)起連接的一方并不需要再進(jìn)行偵聽。因?yàn)檫B接是全雙工的,它可以使用現(xiàn)有的連接進(jìn)行收發(fā)數(shù)據(jù)。而我們前面已經(jīng)做了定義:將發(fā)起連接的一方稱為客戶端，另一段稱為服務(wù)端,則現(xiàn)在可以得出:總是服務(wù)端在使用TcpListener類，因?yàn)樗枰⑵鹨粋€(gè)初始的連接..網(wǎng)絡(luò)聊天程序的三種模式實(shí)現(xiàn)ー個(gè)網(wǎng)絡(luò)聊天程序本應(yīng)是最后一篇文章的內(nèi)容,也是本系列最后的ー個(gè)程序,來作為ー個(gè)終結(jié)。但是我想后面更多的是編碼,講述的內(nèi)容應(yīng)該不會(huì)太多，所以還是把講述的東西都放到這里吧。當(dāng)采用這種模式時(shí)，即是所謂的完全點(diǎn)對(duì)點(diǎn)模式,此時(shí)每臺(tái)計(jì)算機(jī)本身也是服務(wù)器,因?yàn)樗枰M(jìn)行端口的偵聽。實(shí)現(xiàn)這個(gè)模式的難點(diǎn)是：各個(gè)主機(jī)(或終端)之間如何知道其它主機(jī)的存在?此時(shí)通常的做法是當(dāng)某一主機(jī)上線時(shí),使用UDP協(xié)議進(jìn)行ー個(gè)廣播(Broadcast),通過這種方式來“告知”其它主機(jī)自己已經(jīng)在線并說明位置，收到廣播的主機(jī)發(fā)回ー個(gè)應(yīng)答,此時(shí)主機(jī)便知道其他主機(jī)的存在。這種方式我個(gè)人并不喜歡，但在G" 這篇文章中,我使用了這種模式,可惜的是我沒有實(shí)現(xiàn)廣播,所以還很不完善。

第二種方式較好的解決了上面的問題,它引入了服務(wù)器,由這個(gè)服務(wù)器來專門進(jìn)行廣播。服務(wù)器持續(xù)保持對(duì)端U的偵聽狀態(tài),每當(dāng)有主機(jī)上線時(shí),首先連接至服務(wù)器,服務(wù)器收到連接后,將該主機(jī)的位置（地址和端口號(hào)）發(fā)往其他在線主機(jī)（綠色箭頭標(biāo)識(shí)）。這樣其他主機(jī)便知道該主機(jī)已上線,并知道其所在位置,從而可以進(jìn)行連接和對(duì)話。在服務(wù)器進(jìn)行了廣播之后,因?yàn)楦鱾€(gè)主機(jī)已經(jīng)知道了其他主機(jī)的位置,因此主機(jī)之間的對(duì)話就不再通過服務(wù)器（黑色箭頭表示）,而是直接進(jìn)行連接。因此,使用這種模式時(shí),各個(gè)主機(jī)依然需要保持對(duì)端口的偵聽。在某臺(tái)主機(jī)離線時(shí),與登錄時(shí)的模式類似,服務(wù)器會(huì)收到通知,然后轉(zhuǎn)告給其他的主機(jī)。

第三種模式是我覺得最簡單也最實(shí)用的?種,主機(jī)的登錄與離線與第二種模式相同。注意到每臺(tái)主機(jī)在上線時(shí)首先就與服務(wù)器建立了連接,那么從主機(jī)A發(fā)往主機(jī)B發(fā)送消息,就可以通過這樣一條路徑，主機(jī)A-＞服務(wù)器一＞主機(jī)B,通過這種方式，各個(gè)主機(jī)不需要在對(duì)端口進(jìn)行偵聽，而只需要服務(wù)器進(jìn)行偵聽就可以了，大大地簡化了開發(fā)。而對(duì)于ー些較大的文件，比如說圖片或者文件,如果想由主機(jī)A發(fā)往主機(jī)B,如果通過服務(wù)器進(jìn)行傳輸效率會(huì)比較低，此時(shí)可以臨時(shí)搭建一個(gè)主機(jī)A至主機(jī)B之間的連接，用于傳輸大文件。當(dāng)文件傳輸結(jié)束之后再關(guān)閉連接(桔紅色箭頭標(biāo)識(shí))。除此以外，由于消息都經(jīng)過服務(wù)器，所以服務(wù)器還可以緩存主機(jī)間的對(duì)話，即是說當(dāng)主機(jī)A發(fā)往主機(jī)B時(shí)，如果主機(jī)B已經(jīng)離線，則服務(wù)器可以對(duì)消息進(jìn)行緩存，當(dāng)主機(jī)B下次連接到服務(wù)器時(shí)，服務(wù)器自動(dòng)將緩存的消息發(fā)給主機(jī)Bo本系列文章最后采用的即是此種模式，不過沒有實(shí)現(xiàn)過多復(fù)雜的功能。接下來我們的理論知識(shí)告一段落，開始下ー階段ーー漫長的編碼?；静僮?服務(wù)端對(duì)端口進(jìn)行偵聽接下來我們開始編寫ー些實(shí)際的代碼,第一步就是開啟對(duì)本地機(jī)器上某一端口的偵聽。首先創(chuàng)建一個(gè)控制臺(tái)應(yīng)用程序，將項(xiàng)目名稱命名為ServerConsole,它代表我們的服務(wù)端。如果想要與外界進(jìn)行通信,第一件要做的事情就是開啟對(duì)端口的偵聽，這就像為計(jì)算機(jī)打開了一個(gè)“門”,所有向這個(gè)“門”發(fā)送的請(qǐng)求(“敲門”)都會(huì)被系統(tǒng)接收到。在C#中可以通過下面幾個(gè)步驟完成，首先使用本機(jī)Ip地址和端口號(hào)創(chuàng)建一個(gè)System.Net.Sockets.TcpListener類型的實(shí)例,然后在該實(shí)例上調(diào)用Start。方法,從而開啟對(duì)指定端口的偵聽。usingSystem.Net; /ZりI入這兩個(gè)命名空間，以卜同usingSystem.Net.Sockets;using...//略classServer{staticvoidMain(string[]args){Console.WriteLine(MServerisrunning...n);IPAddressip=newIPAddress(newbyte[]{12フ,0f0,1!);TcpListenerlistener=newTcpListener(ip,8500);

listener.Start(); /Z開始偵聽Console.WriteLine(MStartListeningConsole.WriteLine(H\n\n輸入、"Q\"鍵退出。");ConsoleKeykey;do{key=Console.ReadKey(true).Key;}while(key!=ConsoleKey.Q);/Z獲得IPAddress對(duì)象的另外幾種常用方法:IPAddressip=IPAddress.Parse("");IPAddressip=Dns.GetHostEntry("localhost").AddressList[0];上面的代碼中,我們開啟了對(duì)8500端口的偵聽。在運(yùn)行了上面的程序之后,然后打開“命令提示符”,輸入“netstat-a”,可以看到計(jì)算機(jī)器中所有打開的端口的狀態(tài)?？梢詮闹姓业?500端口，看到它的狀態(tài)是LISTENING,這說明它已經(jīng)開始了偵聽:TCPjimmy:1030:0LISTENINGTCPjimmy:360:0LISTENINGTCPjimmy:8500:0LISTENINGTCPjimmy:netbios-ssn:0LISTENING在打開了對(duì)端口的偵聽以后，服務(wù)端必須通過某種方式進(jìn)行阻塞(比如Console.ReadKey()),使得程序不能夠因?yàn)檫\(yùn)行結(jié)束而退出。否則就無法使用“netstat-a”看到端口的連接狀態(tài)，因?yàn)槌绦蛞呀?jīng)退出,連接會(huì)自然中斷，再運(yùn)行“netstat-a”當(dāng)然就不會(huì)顯示端口了。所以程序最后按“Q”退出那段代碼是必要的，下面的每段程序都會(huì)含有這個(gè)代碼段，但為了節(jié)省空間,我都省略掉了。.客戶端與服務(wù)端連接單ー客戶端與服務(wù)端連接當(dāng)服務(wù)器開始對(duì)端口偵聽之后，便可以創(chuàng)建客戶端與它建立連接。這ー步是通過在客戶端創(chuàng)建一個(gè)TcpClient的類型實(shí)例完成。每創(chuàng)建一個(gè)新的TcpClient便相當(dāng)于創(chuàng)建了一個(gè)新的套接字Socket去與服務(wù)端通信,.Net會(huì)自動(dòng)為這個(gè)套接字分配ー個(gè)端口號(hào),上面說過,TcpClient類不過是對(duì)Socket進(jìn)行了一個(gè)包裝。創(chuàng)建TcpClient類型實(shí)例時(shí),可以在構(gòu)造函數(shù)中指定遠(yuǎn)程服務(wù)器的地址和端口號(hào)。這樣在創(chuàng)建的同時(shí),就會(huì)向遠(yuǎn)程服務(wù)端發(fā)

送ー個(gè)連接請(qǐng)求(“握手”)，一旦成功,則兩者間的連接就建立起來了。也可以使用重載的無參數(shù)構(gòu)造函數(shù)創(chuàng)建對(duì)象,然后再調(diào)用Connect。方法,在Connect()方法中傳入遠(yuǎn)程服務(wù)器地址和端口號(hào)，來與服務(wù)器建立連接。這里需要注意的是，不管是使用有參數(shù)的構(gòu)造函數(shù)與服務(wù)器連接,或者是通過Connect。方法與服務(wù)器建立連接,都是同步方法(或者說是阻塞的,英文叫block)。它的意思是說，客戶端在與服務(wù)端連接成功、從而方法返回,或者是服務(wù)端不存、從而拋出異常之前，是無法繼續(xù)進(jìn)行后繼操作的。這里還有一個(gè)名為BeginConnect。的方法，用于實(shí)施異步的連接，這樣程序不會(huì)被阻塞，可以立即執(zhí)行后面的操作,這是因?yàn)榭赡苡捎诰W(wǎng)絡(luò)擁塞等問題，連接需要較長時(shí)間才能完成。網(wǎng)絡(luò)編程中有非常多的異步操作，凡事都是由簡入難，關(guān)于異步操作，我們后面再討論，現(xiàn)在只看同步操作。創(chuàng)建?個(gè)新的控制臺(tái)應(yīng)用程序項(xiàng)目，命名為Clientconsole,它是我們的客戶端,然后添加下面的代碼，創(chuàng)建與服務(wù)器的連接:classClient{staticvoidMain(string[]args){Console.WriteLine(MClientRunningTcpClientclient=newTcpClient();try{client.Connect(Mlocalhostnz8500);/Z與服務(wù)器連接}catch(Exceptionex){Console.WriteLine(ex.Message);return;)/Z打印連接到的服務(wù)端信息Console.WriteLine(MServerConnected!{0}——>{1}*',client.Client.LocalEndPointfclient.Client.RemoteEndPoint);//按Q退出))上面帶代碼中,我們通過調(diào)用Connect。方法來與服務(wù)端連接。隨后,我們打印了這個(gè)連接消息:本機(jī)的Ip地址和端口號(hào),以及連接到的遠(yuǎn)程Ip地址和端口號(hào)。TcpClient的Client屬性返回了一個(gè)Socket對(duì)象,它的LocalEndPoint和RemoteEndPoint屬性分別包含了本地和遠(yuǎn)程的地址信息。先運(yùn)行服務(wù)端,再運(yùn)行這段代碼?？梢钥吹絻蛇叺妮敵銮闆r如下:

//服務(wù)端:Serverisrunning...StartListening.../Z客戶端:ClientRunning...ServerConnected!:4761ーー>:8500我們看到客戶端使用的端口號(hào)為4761,上面已經(jīng)說過,這個(gè)端口號(hào)是山.NET隨機(jī)選取的,并不需要我們來設(shè)置,并且每次運(yùn)行時(shí),這個(gè)端口號(hào)都不同。再次打開“命令提示符”,輸入“netstat-a”，可以看到下面的輸出:TCPjimmy:8500:0LISTENINGTCPjimmy:8500localhost:4761ESTABLISHETCPjimmy:4761localhost:8500ESTABLISHED從這里我們可以得出幾個(gè)重要信息:1、端口8500和端口4761建立了連接，這個(gè)4761端口便是客戶端用來與服務(wù)端進(jìn)行通信的端口;2、8500端口在與客戶端建立起一個(gè)連接后,仍然繼續(xù)保持在監(jiān)聽狀態(tài)。這也就是說?個(gè)端口可以與多個(gè)遠(yuǎn)程端口建立通信,這是顯然的,大家眾所周之的HTTP使用的默認(rèn)端口為80,但是ー個(gè)Web服務(wù)器要通過這個(gè)端口與多少個(gè)瀏覽器通信啊?.2多個(gè)客戶端與服務(wù)端連接那么既然ー個(gè)服務(wù)器端口可以應(yīng)對(duì)多個(gè)客戶端連接,那么接下來我們就看一下,如何讓多個(gè)客戶端與服務(wù)端連接。如同我們上面所說的,ー個(gè)TcpClient就是ー個(gè)Socket,所以我們只要?jiǎng)?chuàng)建多個(gè)TcpClient,然后再調(diào)用Connect。方法就可以了:classClient{staticvoidMain(string[]args){Console.WriteLine(HClientRunning...");TcpClientclient;for(inti=0;i<=2;i++){try{client=newTcpClient();//與服務(wù)client.Connect("localhost”，8500);//與服務(wù)器連接}catch(Exceptionex){Console.WriteLine(ex.Message);return;)/Z打印連接到的服務(wù)端信息Console.WriteLine(HServerConnected!{0}一一＞{1}**rclient.Client.LocalEndPoint,client.Client.RemoteEndPoint);//按Q退出上面代碼最市:要的就是client=newTcpClient()這句,如果你將這個(gè)聲明放到循環(huán)外面,再循環(huán)的第二趟就會(huì)發(fā)生異常,原因很顯然:一個(gè)TcpClient對(duì)象對(duì)應(yīng)ー個(gè)Socket,ー個(gè)Socket對(duì)應(yīng)著ー個(gè)端口,如果不使用new操作符重新創(chuàng)建對(duì)象,那么就相當(dāng)于使用ー個(gè)已經(jīng)與服務(wù)端建立了連接的端口再次與遠(yuǎn)程建立連接,此時(shí)，如果在“命令提示符"運(yùn)行“netstat-a”,則會(huì)看到類似下面的的輸出:TCPjinuny:8500:0LISTENINGTCPjimmy:8500localhost:10282ESTABLISHEDTCPjimmy:8500localhost:10283ESTABLISHEDTCPjimmy:8500localhost:10284ESTABLISHEDTCPjimmy:10282localhost:8500ESTABLISHEDTCPjimmy:10283localhost:8500ESTABLISHEDTCPjimmy:10284localhost:8500ESTABLISHED可以看到創(chuàng)建了三個(gè)連接對(duì),并且8500端口持續(xù)保持偵聽狀態(tài),從這里以及上面我們可以推斷出TcpListener的Start()方法是ー個(gè)異步方法。

.服務(wù)端獲取客戶端連接獲取單ー客戶端連接上面服務(wù)端、客戶端的代碼已經(jīng)建立起了連接,這通過使用“netstat-a”命令,從端U的狀態(tài)可以看出來，但這是操作系統(tǒng)告訴我們的。那么我們現(xiàn)在需要知道的就是:服務(wù)端的程序如何知道已經(jīng)與一個(gè)客戶端建立起了連接?服務(wù)器端開始偵聽以后，可以在TcpListener實(shí)例上調(diào)用AcceptTcpClient()來獲取與一一個(gè)客戶端的連接，它返回ー個(gè)TcpClient類型實(shí)例。此時(shí)它所包裝的是由服務(wù)端去往客戶端的Socket,而我們?cè)诳蛻舳藙?chuàng)建的TcpClient則是由客戶端去往服務(wù)端的。這個(gè)方法是ー個(gè)同步方法(或者叫阻斷方法，blockmethod).意思就是說，當(dāng)程序調(diào)用它以后,它會(huì)一直等待某個(gè)客戶端連接，然后オ會(huì)返回,否則就會(huì)一直等下去。這樣的話，在調(diào)用它以后，除非得到ー個(gè)客戶端連接,不然不會(huì)執(zhí)行接下來的代碼。ー個(gè)很好的類比就是Console.ReadLineO方法，它讀取輸入在控制臺(tái)中的一行字符串，如果有輸入,就繼續(xù)執(zhí)行下面代碼;如果沒有輸入，就會(huì)一直等待下去。classServer{staticvoidMain(string[]args){Console.WriteLine(wServerisrunning...n);IPAddressip=newIPAddress(newbyte[]{12"7,0f〇,1});TcpListenerlistener=newTcpListener(ip,8500);listener.Start(); /Z開始イ貞聽Console.WriteLine(MStartListeningI!獲取ー個(gè)連接,中斷方法TcpClientremoteClient=listener.AcceptTcpClient();/Z打印連接到的客戶端信息Console.WriteLine(MClientConnected!{0}<--{1}”,remoteClient.Client.LocalEndPoint,remoteClient.Client.RemoteEndPoint);//按Q退出))運(yùn)行這段代碼,會(huì)發(fā)現(xiàn)服務(wù)端運(yùn)行到listener.AcceptTcpClient。時(shí)便停止了,并不會(huì)執(zhí)行下面的Console.WriteLine。方法。為了讓它繼續(xù)執(zhí)行ド去,必須有一個(gè)客戶端連

接到它,所以我們現(xiàn)在運(yùn)行客戶端,與它進(jìn)行連接。簡單起見,我們只在客戶端開啟ー個(gè)端ロ與之連接:classClient{staticvoidMain(string[]args){Console.WriteLine("ClientRunningTcpClientclient=newTcpClient();try(client.Connect(Mlocalhost**z8500);/Z與服務(wù)器連接}catch(Exceptionex){Console.WriteLine(ex.Message);return;)/Z打印連接到的服務(wù)端信息Console.WriteLine("ServerConnected!{0(——>{1}"zclient.Client.LocalEndPointzclient.Client.RemoteEndPoint);〃按Q退出}}此時(shí),服務(wù)端、客戶端的輸出分別為:/Z服務(wù)端Serverisrunning...StartListening...ClientConnected!:8500<--:5188/Z客戶端ClientRunning...ServerConnected!:5188-->:85003.2獲取多個(gè)客戶端連接現(xiàn)在我們?cè)俳又紤],如果有多個(gè)客戶端發(fā)動(dòng)對(duì)服務(wù)器端的連接會(huì)怎么樣,為了避免你將瀏覽器向上滾動(dòng),來查看上面的代碼，我將它拷貝了下來，我們先看下客戶端的關(guān)鍵代碼:

TcpClientclient;for(inti=0;i<=2;i++){try(client=newTcpClient();client.Connect(Mlocalhostn,8500); /Z與ル艮務(wù)器連接}catch(Exceptionex){Console.WriteLine(ex.Message);return;}/Z打印連接到的服務(wù)端信息Console.WriteLine("ServerConnected!{0}-->{1}”，client.Client.LocalEndPointtclient.Client.RemoteEndPoint);}如果服務(wù)端代碼不變,我們先運(yùn)行服務(wù)端,再運(yùn)行客戶端,那么接下來會(huì)看到這樣的輸出:/Z服務(wù)端Serverisrunning...StartListening...ClientConnected!:8500<--:5226/Z客戶端ClientRunning...ServerConnected!:5226-->:8500ServerConnected!:5227-->:8500ServerConnected!:5228-->:8500就又回到了本章第2.2小節(jié)“多個(gè)客戶端與服務(wù)端連接”中的處境:盡管有三個(gè)客戶端連接到了服務(wù)端,但是服務(wù)端程序只接收到了一個(gè)。這是因?yàn)榉?wù)端只調(diào)用了一次listener.AcceptTcpClient()>而它只對(duì)應(yīng)ー個(gè)連往客戶端的Socket。但是操作系統(tǒng)是知道連接已經(jīng)建立了的，只是我們程序中沒有處理到，所以我們當(dāng)我們輸入“netstat-a”時(shí)，仍然會(huì)看到3對(duì)連接都已經(jīng)建立成功。為了能夠接收到三個(gè)客戶端的連接,我們只要對(duì)服務(wù)端稍稍進(jìn)行ー下修改,將AcceptTcpClient方法放入ー個(gè)do/while循環(huán)中就可以了：

Console.WriteLine(**StartListeningwhile(true){/Z獲取ー個(gè)連接,同步方法TcpClientremoteClient=listener.AcceptTcpClient〇;/Z打印連接到的客戶端信息Console.WriteLine("ClientConnected!{0}<--{1}”，remoteClient.Client.LocalEndPoint,remoteClient.Client.RemoteEndPoint);)這樣看上去是ー個(gè)死循環(huán),但是并不會(huì)讓你的機(jī)器系統(tǒng)資源迅速耗盡。因?yàn)榍懊嬉呀?jīng)說過了,AcceptTcpClient。再?zèng)]有收到客戶端的連接之前,是不會(huì)繼續(xù)執(zhí)行的,它的大部分時(shí)間都在等待。另外,服務(wù)端幾乎總是要保持在運(yùn)行狀態(tài)，所以這樣做并無不可，還可以省去“按Q退出”那段代碼。此時(shí)再運(yùn)行代碼，會(huì)看到服務(wù)端可以收到3個(gè)客戶端的連接了。Serverisrunning...StartListening...ClientConnected!:8500<--:5305ClientConnected!:8500<ーー:5306ClientConnected!:8500<--:5307本篇文章到此就結(jié)束了，接ド來ー篇我們來看看如何在服務(wù)端與客戶端之間收發(fā)數(shù)據(jù)。C#網(wǎng)絡(luò)編程(同步傳輸字符串)-Part.2服務(wù)端客戶端通信在與服務(wù)端的連接建立以后,我們就可以通過此連接來發(fā)送和接收數(shù)據(jù)。端口與端口之間以流(Stream)的形式傳輸數(shù)據(jù),因?yàn)閹缀跞魏螌澫蠖伎梢员４娴搅髦?所以實(shí)際上可以在客戶端與服務(wù)端之間傳輸任何類型的數(shù)據(jù)。對(duì)客戶端來說，往流中寫入數(shù)據(jù)，即為向服務(wù)器傳送數(shù)據(jù);從流中讀取數(shù)據(jù)，即為從服務(wù)端接收數(shù)據(jù)。対服務(wù)端來說,往流中寫入數(shù)據(jù)，即為向客戶端發(fā)送數(shù)據(jù);從流中讀取數(shù)據(jù),即為從客戶端接收數(shù)據(jù)。同步傳輸字符串我們現(xiàn)在考慮這樣ー個(gè)任務(wù);客戶端打印ー串字符串,然后發(fā)往服務(wù)端，服務(wù)端先輸出它,然后將它改為大寫,再回發(fā)到客戶端，客戶端接收到以后,最后再次打印一遍它。我們將它分為兩部分:1、客戶端發(fā)送,服務(wù)端接收并輸出；2、服務(wù)端回發(fā)，客戶端接收并輸出。.客戶端發(fā)送,服務(wù)端接收并輸出服務(wù)端程序我們可以在TcpClient上調(diào)用GetStreamO方法來獲得連接到遠(yuǎn)程計(jì)算機(jī)的流。注意這里我用了遠(yuǎn)程這個(gè)詞,當(dāng)在客戶端調(diào)用時(shí)，它得到連接服務(wù)端的流；當(dāng)在服務(wù)端調(diào)用時(shí),它獲得連接客戶端的流。接ド來我們來看一下代碼，我們先看服務(wù)端(注意這里沒有使用do/while循環(huán))：classServer{staticvoidMain(string[]args){constintBufferSize=8192; //緩存大小,8192字節(jié)Console.WriteLine(HServerisrunning...n);IPAddressip=newIPAddress(newbyte[]{127,0,0,1})；TcpListenerlistener=newTcpListener(ipr8500);listener.Start();/Zlistener.Start();/Z開始偵聽Console.WriteLine(MStartListening//獲取ー個(gè)連接,中斷方法TcpCl：entremoteClient=listener.AcceptTcpClient〇;/Z打印連接到的客戶端信息Console.WriteLine("ClientConnected!{0}<--{1}",remoteClient.Client.LocalEndPoint,remoteClient.Client.RemoteEndPoint);/Z獲得流,并寫入buffer中NetworkstreamstreamToClient=remoteClient.GetStream();byte[]buffer=newbyte[BufferSize];intbytesRead=streamToClient.Read(buffer,0,BufferSize);Console.WriteLine("Readingdata,{0}bytes...",bytesRead);/Z獲得請(qǐng)求的字符串stringmsg=Encoding.Unicode.GetString(buffer,0,bytesRead);Console.WriteLine("Received:{0}",msg);//按Q退出}}這段程序的上半部分已經(jīng)很熟悉了,我就不再解釋。remoteClient.GetStreamO方法獲取到了連接至客戶端的流,然后從流中讀出數(shù)據(jù)并保存在了buffer緩存中，隨后使用Encoding.Unicode.GetStringO方法,從緩存中獲取到了實(shí)際的字符串。最后將字符串打印在了控制臺(tái)上。這段代碼有個(gè)地方需要注意:在能夠讀取的字符串的總字節(jié)數(shù)大于BufferSize的時(shí)候會(huì)出現(xiàn)字符串截?cái)喱F(xiàn)象，因?yàn)榫彺嬷械臄?shù)目總是有限的,而對(duì)于大對(duì)象,比如說圖片或者其它文件來說,則必須采用“分次讀取然后轉(zhuǎn)存”這種方式，比如這樣:/Z獲取字符串byte[]buffer=newbyte[BufferSize];intbytesRead; /Z讀取的字節(jié)數(shù)MemoryStreammsStream=newMemorystream();dobytesRead=streamToClient.Read(buffer,0,BufferSize);

msStream.Write(buffer,0,bytesRead);}while(bytesRead>0);buffer=msStream.GetBuffer();stringmsg=Encoding.Unicode.GetString(buffer);這里我沒有使用這種方法,ー個(gè)是因?yàn)椴幌腙P(guān)注在太多的細(xì)節(jié)上面,ー個(gè)是因?yàn)閷?duì)于字符串來說，8192字節(jié)已經(jīng)很多了，我們通常不會(huì)傳遞這么多的文本。當(dāng)使用Unicode編碼時(shí)，8192字節(jié)可以保存4096個(gè)漢字和英文字符。使用不同的編碼方式，占用的字節(jié)數(shù)有很大的差異，在本文最后面,有一段小程序，可以用來測(cè)試Unicode、UTF8、ASCII三種常用編碼方式對(duì)字符串編碼時(shí)，占用的字節(jié)數(shù)大小。現(xiàn)在對(duì)客戶端不做任何修改，然后運(yùn)行先運(yùn)行服務(wù)端，再運(yùn)行客戶端。結(jié)果我們會(huì)發(fā)現(xiàn)這樣ー件事:服務(wù)端再打印完"ClientConnected!:8500<—:xxxxx”之后,再次被阻塞了,而沒有輸出"Readingdata,{0}bytes…”。可見,與AcceptTcpClientO方法類似，這個(gè)Read。方法也是同步的，只有當(dāng)客戶端發(fā)送數(shù)據(jù)的時(shí)候,服務(wù)端オ會(huì)讀取數(shù)據(jù)、運(yùn)行此方法,否則它便會(huì)一直等待。1.2客戶端程序接下來我們編寫客戶端向服務(wù)器發(fā)送字符串的代碼，與服務(wù)端類似,它先獲取連接服務(wù)器端的流，將字符串保存到buffer緩存中，再將緩存寫入流，寫入流這一過程，相當(dāng)于將消息發(fā)往服務(wù)端。classClient{staticvoidMain(string[]args){Console.WriteLine(HClientRunningTcpClientclient;try{client=newTcpClient();client.Connect(Mlocalhostn,8500); /Z與服務(wù)器連接}catch(Exceptionex){Console.WriteLine(ex.Message);return;)/Z打印連接到的服務(wù)端信息Console.WriteLine(HServerConnected!{0}ーー>{1}nzclient.Client.LocalEndPoint,client.Client.RemoteEndPoint);

stringmsg=n\"WelcomeToTraceFact.Net\"**;NetworkstreamstreamToServer=client.GetStream();byte[]buffer=Encoding.Unicode.GetBytes(msg);/Z獲得緩存streamToServer.Write(buffer,〇,buffer.Length);/Z發(fā)往服務(wù)器Console.WriteLine("Sent:{0}",msg);//按Q退出現(xiàn)在再次運(yùn)行程序,得到的輸出為:/Z服務(wù)端Serverisrunning...StartListening...ClientConnected!:8500<--:7847Readingdata,52bytes...Received:"WelcomeToTraceFact.Net"輸入"Q"鍵退出。/Z客戶端ClientRunning...ServerConnected!:7847-->:8500Sent:"WelcomeToTraceFact.Net"輸入"Q"鍵退出。再繼續(xù)進(jìn)行之前,我們假設(shè)客戶端可以發(fā)送多條消息,而服務(wù)端要不斷的接收來自客戶端發(fā)送的消息，但是上面的代碼只能接收客戶端發(fā)來的一條消息,因?yàn)樗呀?jīng)輸出了“輸入Q鍵退出"，說明程序已經(jīng)執(zhí)行完畢，無法再進(jìn)行任何動(dòng)作。此時(shí)如果我們?cè)匍_啟ー個(gè)客戶端,那么出現(xiàn)的情況是:客戶端可以與服務(wù)器建立連接,也就是netstat-a顯示為ESTABLISHED,這是操作系統(tǒng)所知道的;但是由于服務(wù)端的程序已經(jīng)執(zhí)行到了最后ー步,只能輸入Q鍵退出,無法再采取任何的動(dòng)作?；叵氅`個(gè)上面我們需要一個(gè)服務(wù)器對(duì)應(yīng)多個(gè)客戶端時(shí)，對(duì)AcceptTcpClient()方法的處理辦法，將它放在了do/while循環(huán)中;類似地,當(dāng)我們需要一個(gè)服務(wù)端對(duì)同一個(gè)客戶端的多次請(qǐng)求服務(wù)時(shí),可以將Read。方法放入到do/while循環(huán)中。

現(xiàn)在,我們大致可以得出這樣幾個(gè)結(jié)論:?如果不使用do/while循環(huán),服務(wù)端只有一個(gè)listener.AcceptTcpClient()方法和一?個(gè)TcpClient.GetStreamO.Read。方法,則服務(wù)端只能處理到同一客戶端的一條請(qǐng)求。?如果使用ー個(gè)do/while循環(huán),并將listener.AcceptTcpClient()方法和TcpClient.GetStreamO.Read。方法都放在這個(gè)循環(huán)以內(nèi)，那么服務(wù)端將可以處理多個(gè)客戶端的一條請(qǐng)求。?如果使用ー個(gè)do/while循環(huán),并將listener.AcceptTcpClient()方法放在循環(huán)之外，將TcpClient.GetStreamO.Read。方法放在循環(huán)以內(nèi)，那么服務(wù)端可以處理一個(gè)客戶端的多條請(qǐng)求。?如果使用兩個(gè)do/while循環(huán),對(duì)它們進(jìn)行分別嵌套,那么結(jié)果是什么呢?結(jié)果并不是可以處理多個(gè)客戶端的多條請(qǐng)求。因?yàn)槔飳拥膁o/while循環(huán)總是在為ー個(gè)客戶端服務(wù),因?yàn)樗鼤?huì)中斷在TcpClient.GetStreamO.Read。方法的位置，而無法執(zhí)行完畢。即使可以通過某種方式讓里層循環(huán)退出，比如客戶端往服務(wù)端發(fā)去“exit”字符串時(shí)，服務(wù)端也只能挨個(gè)對(duì)客戶端提供服務(wù)。如果服務(wù)端想執(zhí)行多個(gè)客戶端的多個(gè)請(qǐng)求,那么服務(wù)端就需要采用多線程。主線程，也就是執(zhí)行外層do/while循環(huán)的線程,在收到ー個(gè)TcpClient之后，必須將里層的do/while循環(huán)交給新線程去執(zhí)行，然后主線程快速地重新回到listener.AcceptTcpClient()的位置,以響應(yīng)其它的客戶端。對(duì)于第四種情況，實(shí)際上是構(gòu)建一個(gè)服務(wù)端更為通常的情況，所以需要專門開辟ー個(gè)章節(jié)討論，這里暫且放過。而我們上面所做的,即是列出的第一種情況,接下來我們?cè)俜謩e看一下第二種和第三種情況。對(duì)于第二種情況，我們按照上面的敘述先對(duì)服務(wù)端進(jìn)行ー下改動(dòng):do{/Z獲取ー個(gè)連接,中斷方法TcpClientremoteClient=listener.AcceptTcpClient();/Z打印連接到的客戶端信息Console.WriteLine(MClientConnected!{0}<--{1}”,remoteClient.Client.LocalEndPoint,remoteClient.Client.RemoteEndPoint);/Z獲得流,并寫入buffer中NetworkstreamstreamToClient=remoteClient.GetStream();byte[]buffer=newbyte[BufferSize];intbytesRead=streamToClient.Read(buffer,〇,BufferSize);

Console.WriteLine(MReadingdata,{0}bytes bytesRead);/Z獲得請(qǐng)求的字符串stringmsg=Encoding.Unicode.GetString(buffer,0,bytesRead);Console.WriteLine(MReceived:{0}",msg);}while(true);然后啟動(dòng)多個(gè)客戶端,在服務(wù)端應(yīng)該可以看到下面的輸出(客戶端沒有變化)：Serverisrunning...StartListening...ClientConnected!:8500<--:8196Readingdata,52bytes...Received:"WelcomeToTraceFact.Net"ClientConnected!:8500<-:8199Readingdata,52bytes...Received:"WelcomeToTraceFact.Net"山第2種情況改為第3種情況,只需要將do向下挪動(dòng)幾行就可以了:/Z獲取ー個(gè)連接,中斷方法TcpClientremoteClient=listener.AcceptTcpClient〇;/Z打印連接到的客戶端信息Console.WriteLine("ClientConnected!{0}<ーー{1}",remoteClient.Client.LocalEndPoint,remoteClient.Client.RemoteEndPoint);/Z獲得流,并寫入buffeエ中NetworkstreamstreamToClient=remoteClient.GetStream();do{byte[]buffer=newbyte[BufferSize];intbytesRead=streamToClient.Read(buffer,0,BufferSize);Console.WriteLine("Readingdata,{0}bytes...",bytesRead);/Z獲得請(qǐng)求的字符串stringmsg=Encoding.Unicode.GetString(buffer,0,bytesRead);Console.WriteLine("Received:{0}",msg);}while(true);然后我們?cè)俑膭?dòng)一下客戶端，讓它發(fā)送多個(gè)請(qǐng)求。當(dāng)我們按下s的時(shí)候,可以輸入ー行字符串,然后將這行字符串發(fā)送到服務(wù)端;當(dāng)我們輸入X的時(shí)候則退出循環(huán):

NetworkstreamstreamToServer=client.GetStream();ConsoleKeykey;Console.WriteLine("Menu:S-Send,X-ExitM);do{key=Console.ReadKey(true).Key;if(key==ConsoleKey.S){/Z獲取輸入的字符串Console.Write("Inputthemessage:");stringmsg=Console.ReadLine();byte[]buffer=Encoding.Unicode.GetBytes(msg);/Z獲得緩存streamToServer.Write(buffer,0,buffer.Length);/Z發(fā)往服務(wù)器Console.WriteLine("Sent:{0}",msg);)}while(key!=ConsoleKey.X);接下來我們先運(yùn)行服務(wù)端,然后再運(yùn)行客戶端,輸入一些字符串,來進(jìn)行測(cè)試,應(yīng)該能夠看到下面的輸出結(jié)果:/Z服務(wù)端Serverisrunning...StartListening...ClientConnected!:8500<--:11004Readingdata,44bytes...Received:歡迎訪問我的博客:TraceFact.NetReadingdata,14bytes...Received:我們ー起進(jìn)步!//客戶端ClientRunning...ServerConnected!:11004-一>:8500Menu:S一Send,X一ExitInputthemessage:歡迎訪問我的博客:TraceFact.NetSent:歡迎訪問我的博客：TraceFact.NetInputthemessage:我們"起進(jìn)步!Sent:我們ー起進(jìn)步!

這里還需要注意一點(diǎn),當(dāng)客戶端在TcpClient實(shí)例上調(diào)用Close。方法,或者在流上調(diào)用Dispose。方法，服務(wù)端的streamToClient.Read。方法會(huì)持續(xù)地返回。,但是不拋出異常，所以會(huì)產(chǎn)生?個(gè)無限循環(huán);而如果直接關(guān)閉掉客戶端，或者客戶端執(zhí)行完畢但沒有調(diào)用stream.Dispose。或者TcpClient.Close。,如果服務(wù)器端此時(shí)仍阻塞在Read()方法處，則會(huì)在服務(wù)器端拋出異常:“遠(yuǎn)程主機(jī)強(qiáng)制關(guān)閉了?個(gè)現(xiàn)有連接”。因此,我們將服務(wù)端的streamToClient.Read。方法需要寫在ー個(gè)try/catch中。同理，如果在服務(wù)端己經(jīng)連接到客戶端之后，服務(wù)端調(diào)用remoteClient.Close。,則客戶端會(huì)得到異?！盁o法將數(shù)據(jù)寫入傳輸連接:您的主機(jī)中的軟件放棄了一個(gè)ー建立的連接?！?而如果服務(wù)端直接關(guān)閉程序的話,則客戶端會(huì)得到異常“無法將數(shù)據(jù)寫入傳輸連接:遠(yuǎn)程主機(jī)強(qiáng)迫關(guān)閉了一個(gè)現(xiàn)有的連接?！?。因此,它們的讀寫操作必須都放入到try/catch塊中。2.服務(wù)端回發(fā),客戶端接收并輸出2.2服務(wù)端程序我們接著再進(jìn)行進(jìn)ー步處理，服務(wù)端將收到的字符串改為大寫，然后回發(fā)，客戶端接收后打印。此時(shí)它們的角色和上面完全進(jìn)行了一下對(duì)調(diào):對(duì)于服務(wù)端來說,就好像剛オ的客戶端ー樣,將字符串寫入到流中:而客戶端則同服務(wù)端ー樣,接收并打印。除此以外，我們最好對(duì)流的讀寫操作加上lock,現(xiàn)在我們直接看代碼,首先看服務(wù)端:classServer{staticvoidMain(string[]args){constintBufferSize=8192; //緩存大小,8192BytesConsoleKeykey;Console.WriteLine(MServerisrunning...M);IPAddressip=newIPAddress(newbyte[]{127r0,0,1!);TcpListenerlistener=newTcpListener(ip,8500);listener.Start(); /Z開始偵聽Console.WriteLine(nStartListening...**);/Z獲取ー個(gè)連接,同步方法,在此處中斷TcpClientremoteClient=listener.AcceptTcpClient〇;/Z打印連接到的客戶端信息Console.WriteLine(MClientConnected!{0}<--{1}M,remoteClient.Client.LocalEndPoint,

remoteClient.Client.RemoteEndPoint);/Z獲得流NetworkstreamstreamToClient=remoteClient.GetStream();do{//寫入buffer中byte[]buffer=newbyte[BufferSize];intbytesRead;try{lock(streamToClient){bytesRead=streamToClient.Read(buffer,〇,BufferSize);)if(bytesRead==0)thrownewException("讀取至リ〇字節(jié)リ;Console.WriteLine(MReadingdata,{0}bytesbytesRead);/Z獲得請(qǐng)求的字符串stringmsg=Encoding.Unicode.GetString(buffer,0,bytesRead);Console.WriteLine("Received:{0}",msg);/Z轉(zhuǎn)換成大寫并發(fā)送msg=msg.ToUpper();buffer=Encoding.Unicode.GetBytes(msg);lock(streamToClient){streamToClient.Write(buffer,0,buffer.Length);)Console.WriteLine("Sent:{0}",msg);}catch(Exceptionex){Console.WriteLine(ex.Message);break;)}while(true);

streamToClient.Dispose();remoteClient.Close();Console.WriteLine("\n'n輸入、"Q\"鍵退出。");do{key=Console.ReadKey(true).Key;}while(key!=ConsoleKey.Q);}}接下來是客戶端:classClient{staticvoidMain(string[]args){Console.WriteLine("ClientRunning...");TcpClientclient;ConsoleKeykey;constintBufferSize=8192;try(client=newTcpClient();client.Connect("localhost"z8500);/Z與服務(wù)器連接}catch(Exceptionex){Console.WriteLine(ex.Message);return;}/Z打印連接到的服務(wù)端信息Console.WriteLine("ServerConnected!{0}——>{1}"zclient.Client.LocalEndPointzclient.Client.RemoteEndPoint);NetworkStreamstreamToServer=client.GetStream();Console.WriteLine("Menu:S-SendzX-Exit");do{key=Cons(：>Le.ReadKey(true).Key;

if(key==ConsoleKey.S){//獲取輸入的字符串Console.Write(MInputthemessage:**);stringmsg=Console.ReadLine();byte[]buffer=Encoding.Unicode.GetBytes(msg);/Z獲得緩存try(lock(streamToServer){streamToServer.Write(buffer,〇,buffer.Length);/Z發(fā)往服務(wù)器}Console.WriteLine(MSent:{0}",msg);intbytesRead;buffer=newbyte[BufferSize];lock(streamToServer){bytesRead=streamToServer.Read(buffer,0,BufferSize);}msg=Encoding.Unicode.GetString(buffer,0,bytesRead);Console.WriteLine("Received:{0}",msg);}catch(Exceptionex){Console.WriteLine(ex.Message);break;)}}while(key!=ConsoleKey.X);streamToServer.Dispose();client.Close();Console.WriteLine("\n\n輸入、"Q\"鍵退出。");do{key=Console.ReadKey(true).Key;

}while(key!=ConsoleKey.Q);最后我們運(yùn)行程序,然后輸入ー串英文字符串,然后看一下輸出:/Z客戶端Clientisrunning...ServerConnected!:12662—>:8500Menu:S-Send,X-ExitInputthemessage:Hello,11mjimmyzhang.Sent:Hello,I*mjimmyzhang.Received:HELLO,I?MJIMMYZHANG./Z服務(wù)端Serverisrunning...StartListening...ClientConnected!:8500<--:12662Readingdata,46bytes...Received:Hello,I*mjimmyzhang.Sent:HELLO,I?MJIMMYZHANG.看到這里,我想你應(yīng)該對(duì)使用TcpClient和TcpListener進(jìn)行C#網(wǎng)絡(luò)編程有了一個(gè)初步的認(rèn)識(shí)，可以說是剛剛?cè)腴T了，后面的路還很長。本章的所有操作都是同步操作，像上面的代碼也只是作為ー個(gè)入門的范例，實(shí)際當(dāng)中,ー個(gè)服務(wù)端只能為一個(gè)客戶端提供服務(wù)的情況是不存在的,下面就讓我們來看看上面所說的第四種情況，如何進(jìn)行異步的服務(wù)端編程。附錄:ASCH、UTF8>Uncicode編碼下的中英文字符大小privatestaticvoidShowCode(){string[]strArray={MbM,nabcd","乙"，"甲乙丙丁”);byte[]buffer;stringmode,back;foreach(stringstrinstrArray){for(inti=0;i<=2;i++){if(i==0){

buffer=Encoding.ASCII.GetBytes(str);back=Encoding.ASCII.GetString(buffer,〇,buffer.Length);mode="ASCII”；}elseif(i==1){buffer=Encoding.UTF8.GetBytes(str);back=Encoding.UTF8.GetString(buffer,0,buffer.Length);mode=MUTF8M;}else{buffer=Encoding.Unicode.GetBytes(str);back=Encoding.Unicode.GetString(buffer,0,buffer.Length);mode="Unicode";)Console.WriteLine("Mode:{0},String:{1},Buffer.Length:{2}",mode,str,buffer.Length);Console.WriteLine("Buffer:");for(intj=0;j<=buffer.Length-1;j++){Console.Write(buffer[j]+"");)Console.WriteLine("\nRetrived:{0}\n",back);)輸出為:Mode:ASCII,String:b,Buffer.Length:1Buffer:98Retrived:bMode:UTF8,String:b,Buffer.Length:1Buffer:98Retrived:b

Mode:Unicode,String:b,Buffer.Length:2Buffer:980Retrived:bMode:ASCII,String:abed.Buffer.Length:4Buffer:979899100Retrived:abedMode:UTF8,String:abed,Buffer.Length:4Buffer:979899100Retrived:abedMode:Unicode,String:abed,Buffer.Length:8Buffer:9709809901000Retrived:abedMode:ASCII,String:乙,Buffer.Length:1Buffer:63Retrived:?Mode:UTF8,String:乙,Buffer.Length:3Buffer:228185153Retrived:乙Mode:Unicode,String:乙，Buffer.Length:2Buffer:8978Retrived:乙Mode:ASCII,String:甲乙丙丁,Buffer.Length:4Buffer:63636363Retrived:????Mode:UTF8,String:甲乙丙J,Buffer.Length:12Buffer:231148178228185153228184153228184129Retrived:甲乙丙「Mode:Unicode,String:甲乙丙」,Buffer.Length:8

Buffer:5011789782578178Retrived:甲乙丙丁大體ヒ可以得出這么幾個(gè)結(jié)論:ASCII不能保存中文（貌似誰都知道--'）。UTF8是變長編碼。在對(duì)ASCII字符編碼時(shí),UTF更省空間,只占1個(gè)字節(jié),與ASCII編碼方式和長度相同:Unicode在對(duì)ASCII字符編碼時(shí),占用2個(gè)字節(jié),且第2個(gè)字節(jié)補(bǔ)零。UTF8在對(duì)中文編碼時(shí)需要占用3個(gè)字節(jié);Unicode對(duì)中文編碼則只需要2個(gè)字C#網(wǎng)絡(luò)編程（異步傳輸字符串）-Part.3這篇文章我們將前進(jìn)一大步,使用異步的方式來對(duì)服務(wù)端編程,以使它成為ー個(gè)真正意義上的服務(wù)器:可以為多個(gè)客戶端的多次請(qǐng)求服務(wù)。但是開始之前,我們需要解決ヒー節(jié)中遺留的一個(gè)問題。消息發(fā)送時(shí)的問題這個(gè)問題就是:客戶端分兩次向流中寫入數(shù)據(jù)（比如字符串）時(shí)，我們主觀上將這兩次寫入視為兩次請(qǐng)求;然而服務(wù)端有可能將這兩次合起來視為一條請(qǐng)求，這在兩個(gè)請(qǐng)求間隔時(shí)間比較短的情況下尤其如此。同樣，也有可能客戶端發(fā)出一條請(qǐng)求，但是服務(wù)端將其視為兩條請(qǐng)求處理。下面列出了可能的情況，假設(shè)我們?cè)诳蛻舳诉B續(xù)發(fā)送兩條“WelcometoTracefact,net!",則數(shù)據(jù)到達(dá)服務(wù)端時(shí)可能有這樣三種情況:NOTE:在這里我們假設(shè)采用ASCH編碼方式，因?yàn)榇藭r(shí)上面的ー個(gè)方框正好代表ー個(gè)字節(jié)，而字符串到達(dá)末尾后為持續(xù)的O（因?yàn)閎yte是值類型,且最小為0）。上面的第一種情況是最理想的情況,此時(shí)兩條消息被視為兩個(gè)獨(dú)立請(qǐng)求由服務(wù)端完整地接收。第二種情況的示意圖如下，此時(shí)一條消息被當(dāng)作兩條消息接收了：而對(duì)于第三種情況，則是兩條消息被合并成了一條接收:Welc〇me---WeIcometo如果你下載了上一篇文章所附帶的源碼,那么將Client2.cs進(jìn)行ー下修改，不通過用戶輸入,而是使用ー個(gè)for循環(huán)連續(xù)的發(fā)送三個(gè)請(qǐng)求過去，這樣會(huì)使請(qǐng)求的間隔時(shí)間更短,下面是關(guān)鍵代碼：

stringmsg="WelcometoTraceFact.Net!";for(inti=0;i<=2;i++){byte[]buffer=Encoding.Unicode.GetBytes(msg);/Z獲得緩存try{streamToServer.Write(buffer,〇,buffer.Length);/Z發(fā)往月艮務(wù)器Console.WriteLine("Sent:{0}",msg);}catch(Exceptionex){Console.WriteLine(ex.Message);break;}運(yùn)行服務(wù)端,然后再運(yùn)行這個(gè)客戶端,你可能會(huì)看到這樣的結(jié)果:"C:\TinOYS\systea32\cBd.exeSeruei*isrunning...StartListening...ClientConnectedI：8500<—：7763Beadingdata.50bytes...Beceiued：WelcometoTraceFact.Net!Beadingdata.100bytes...Beceiued：WeleonetoTraceFact.Net?WeleonetoTraceFact.Net?XX可以看到,盡管上面將消息分成了三條單獨(dú)發(fā)送,但是服務(wù)端卻將后兩條合并成了一條。對(duì)于這些情況，我們可以這樣處理:就好像HTTP協(xié)議ー樣，在實(shí)際的請(qǐng)求和應(yīng)答內(nèi)容之前包含了HTTP頭，其中是一些與請(qǐng)求相關(guān)的信息。我們也可以訂立自己的協(xié)議,來解決這個(gè)問題,比如說，對(duì)于上面的情況，我們就可以定義這樣ー個(gè)協(xié)議：

[length-XXX]!其中xxx是實(shí)際發(fā)送的字符串長度(注意不是字節(jié)數(shù)組buffer的長度),那么對(duì)于上面的請(qǐng)求,則我們發(fā)送的數(shù)據(jù)為:“[length=25]WelcometoTraceFact.Net!”。而服務(wù)端接收字符串之后，首先讀取這個(gè)‘'元數(shù)據(jù)”的內(nèi)容，然后再根據(jù)“元數(shù)據(jù)”內(nèi)容來讀取實(shí)際的數(shù)據(jù),它可能有下面這樣兩種情況:NOTE:我覺得這里借用“元數(shù)據(jù)”這個(gè)術(shù)語還算比較恰當(dāng),因?yàn)椤霸獢?shù)據(jù)”就是用來描述數(shù)據(jù)的數(shù)據(jù)。?“[“”ド中括號(hào)是完整的,可以讀取到length的字節(jié)數(shù)。然后根據(jù)這個(gè)數(shù)值與后面的字符串長度相比，如果相等，則說明發(fā)來了一一條完整信息;如果多了，那么說明接收的字節(jié)數(shù)多了，取出合適的長度，并將剩余的進(jìn)行緩存;如果少了,說明接收的不夠,那么將收到的進(jìn)行ー個(gè)緩存，等待下次請(qǐng)求,然后將兩條合并。?"ド“]”中括號(hào)本身就不完整,此時(shí)讀不到length的值,因?yàn)橹欣ㄌ?hào)里的內(nèi)容被截?cái)嗔?那么將讀到的數(shù)據(jù)進(jìn)行緩存,等待讀取ド次發(fā)送來的數(shù)據(jù),然后將兩次合并之后再按上面的方式進(jìn)行處理。接ド來我們來看下如何來進(jìn)行實(shí)際的操作,實(shí)際上,這個(gè)問題已經(jīng)不屬于C#網(wǎng)絡(luò)編程的內(nèi)容了,而完全是對(duì)字符串的處理。所以我們不再編寫服務(wù)端/客戶端代碼,直接編寫處理這幾種情況的方法:publicclassRequestHandler{privatestringtemp=string.Empty;publicstring[]GetActualString(stringinput){returnGetActualString(input,null);)privatestring[]GetActualString(stringinputtList<string>outputList){if(outputList==null)outputList=newList<string>();if(!String.IsNullOrEmpty(temp))input=temp+input;stringoutput=stringpattern=@H(?<=A\[length=)(\d+)(?=\])M;intlength;

if(Regex.IsMatch(input,pattern)){Matchm=Regex.Match(input,pattern);/Z獲取消息字符串實(shí)際應(yīng)有的長度length=Convert.ToInt32(m.Groups[0].Value);/Z獲取需要進(jìn)行截取的位置intstartIndex=input.IndexOf(1]1)+1；/Z獲取從此位置開始后所有字符的長度output=input.Substring(startIndex);if(output.Length==length){//如果。utput的長度與消息字符串的應(yīng)有長度相等/Z說明剛好是完整的一條信息outputList.Add(output);temp=nM;}elseif(output.Length<length){//如果之后的長度小于應(yīng)有的長度,/Z說明沒有發(fā)完整,則應(yīng)將整條信息,包括元數(shù)據(jù),全部緩存/Z與下一條數(shù)據(jù)合并起來再進(jìn)行處理temp=input;/Z此時(shí)程序應(yīng)該退出,因?yàn)樾枰却乱粭l數(shù)據(jù)到來才能繼續(xù)處理}elseif(output.Length>length){//如果之后的長度大于應(yīng)有的長度,/Z說明消息發(fā)完整了,但是有多余的數(shù)據(jù)//多余的數(shù)據(jù)可能是截?cái)嘞?，也可能是多條完整消息//截取字符串output=output.Substring(0,length);outputList.Add(output);temp=H;/Z縮短input的長度input=input.Substring(startIndex+length);

/Z遞歸調(diào)用GetActualString(input,outputList);)}else{/Z說明、'[",'']"就不完整temp=input;}returnoutputList.ToArray();這個(gè)方法接收ー個(gè)滿足協(xié)議格式要求的輸入字符串,然后返回一個(gè)數(shù)組,這是因?yàn)槿绻霈F(xiàn)多次請(qǐng)求合并成一個(gè)發(fā)送過來的情況，那么就將它們?nèi)糠祷亍ｋS后簡單起見，我在這個(gè)類中添加了一個(gè)靜態(tài)的Test()方法和PrintOutput()幫助方法，進(jìn)行了一個(gè)簡單的測(cè)試,注意我直接輸入了!ength-13,這個(gè)是我提前計(jì)算好的。publicstaticvoidTest(){RequestHandlerhandler=newRequestHandl