C#客戶端程序?qū)崿F(xiàn)同步傳輸字符串淺析
C#客戶端程序?qū)崿F(xiàn)同步傳輸字符串的問題:我們編寫客戶端向服務(wù)器發(fā)送字符串的代碼,與服務(wù)端類似,它先獲取連接服務(wù)器端的流,將字符串保存到buffer緩存中,再將緩存寫入流,寫入流這一過程,相當(dāng)于將消息發(fā)往服務(wù)端。
- class Client {
- static void Main(string[] args) {
- Console.WriteLine("Client Running ...");
- TcpClient client;
- //C#客戶端程序
- try {
- client = new TcpClient();
- client.Connect("localhost", 8500); // 與服務(wù)器連接
- } catch (Exception ex) {
- Console.WriteLine(ex.Message);
- return;
- }
- // 打印連接到的服務(wù)端信息
- Console.WriteLine("Server Connected!{0} --> {1}",
- client.Client.LocalEndPoint, client.Client.RemoteEndPoint);
- //C#客戶端程序
- string msg = "\"Welcome To TraceFact.Net\"";
- NetworkStream streamToServer = client.GetStream();
- byte[] buffer = Encoding.Unicode.GetBytes(msg); // 獲得緩存
- streamToServer.Write(buffer, 0, buffer.Length); // 發(fā)往服務(wù)器
- Console.WriteLine("Sent: {0}", msg);
- // 按Q退出
- }
- }
現(xiàn)在再次運(yùn)行程序,得到的輸出為:
- // 服務(wù)端
- Server is running ...
- Start Listening ...
- Client Connected!127.0.0.1:8500 <-- 127.0.0.1:7847
- Reading data, 52 bytes ...
- Received: "Welcome To TraceFact.Net"
- 輸入"Q"鍵退出。
- // 客戶端
- Client Running ...
- Server Connected!127.0.0.1:7847 --> 127.0.0.1:8500
- Sent: "Welcome To TraceFact.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.GetStream().Read()方法,則服務(wù)端只能處理到同一客戶端的一條請(qǐng)求。
◆如果使用一個(gè)do/while循環(huán),并將listener.AcceptTcpClient()方法和TcpClient.GetStream().Read()方法都放在這個(gè)循環(huán)以內(nèi),那么服務(wù)端將可以處理多個(gè)客戶端的一條請(qǐng)求。
◆如果使用一個(gè)do/while循環(huán),并將listener.AcceptTcpClient()方法放在循環(huán)之外,將TcpClient.GetStream().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.GetStream().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 {
- // 獲取一個(gè)連接,中斷方法
- TcpClient remoteClient = listener.AcceptTcpClient();
- // 打印連接到的客戶端信息
- Console.WriteLine("Client Connected!{0} <-- {1}",
- remoteClient.Client.LocalEndPoint,
- remoteClient.Client.RemoteEndPoint);
- // 獲得流,并寫入buffer中
- NetworkStream streamToClient = remoteClient.GetStream();
- byte[] buffer = new byte[BufferSize];
- int bytesRead = streamToClient.Read(buffer, 0, BufferSize);
- Console.WriteLine("Reading data, {0} bytes ...", bytesRead);
- // 獲得請(qǐng)求的字符串
- string msg = Encoding.Unicode.GetString(buffer, 0, bytesRead);
- Console.WriteLine("Received: {0}", msg);
- } while (true);
然后啟動(dòng)多個(gè)客戶端,在服務(wù)端應(yīng)該可以看到下面的輸出(客戶端沒有變化):
- Server is running ...
- Start Listening ...
- Client Connected!127.0.0.1:8500 <-- 127.0.0.1:8196
- Reading data, 52 bytes ...
- Received: "Welcome To TraceFact.Net"
- Client Connected!127.0.0.1:8500 <-- 127.0.0.1:8199
- Reading data, 52 bytes ...
- Received: "Welcome To TraceFact.Net"
由第2種情況改為第3種情況,只需要將do向下挪動(dòng)幾行就可以了:
- // 獲取一個(gè)連接,中斷方法
- TcpClient remoteClient = listener.AcceptTcpClient();
- // 打印連接到的客戶端信息
- Console.WriteLine("Client Connected!{0} <-- {1}",
- remoteClient.Client.LocalEndPoint,
- remoteClient.Client.RemoteEndPoint);
- // 獲得流,并寫入buffer中
- NetworkStream streamToClient = remoteClient.GetStream();
- do {
- byte[] buffer = new byte[BufferSize];
- int bytesRead = streamToClient.Read(
- buffer, 0, BufferSize);
- Console.WriteLine("Reading data,
- {0} bytes ...", bytesRead);
- // 獲得請(qǐng)求的字符串
- string msg = 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):
- NetworkStream streamToServer = client.GetStream();
- ConsoleKey key;
- Console.WriteLine("Menu: S - Send, X - Exit");
- do {
- key = Console.ReadKey(true).Key;
- if (key == ConsoleKey.S) {
- // 獲取輸入的字符串
- Console.Write("Input the message: ");
- string msg = Console.ReadLine();
- byte[] buffer = Encoding.Unicode.GetBytes(msg);// 獲得緩存
- streamToServer.Write(buffer, 0, buffer.Length);// 發(fā)往服務(wù)器
- Console.WriteLine("Sent: {0}", msg);
- }
- } while (key != ConsoleKey.X);
接下來我們先運(yùn)行服務(wù)端,然后再運(yùn)行客戶端,輸入一些字符串,來進(jìn)行測(cè)試,應(yīng)該能夠看到下面的輸出結(jié)果:
- // 服務(wù)端
- Server is running ...
- Start Listening ...
- Client Connected!127.0.0.1:8500 <-- 127.0.0.1:11004
- Reading data, 44 bytes ...
- Received: 歡迎訪問我的博客:TraceFact.Net
- Reading data, 14 bytes ...
- Received: 我們一起進(jìn)步!
- //客戶端
- Client Running ...
- Server Connected!127.0.0.1:11004 --> 127.0.0.1:8500
- Menu: S - Send, X - Exit
- Input the message: 歡迎訪問我的博客:TraceFact.Net
- Sent: 歡迎訪問我的博客:TraceFact.Net
- Input the message: 我們一起進(jìn)步!
- Sent: 我們一起進(jìn)步!
這里還需要注意一點(diǎn),當(dāng)客戶端在TcpClient實(shí)例上調(diào)用Close()方法,或者在流上調(diào)用Dispose()方法,服務(wù)端的streamToClient.Read()方法會(huì)持續(xù)地返回0,但是不拋出異常,所以會(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塊中。
C#客戶端程序的基本內(nèi)容就向你介紹到這里,希望對(duì)你了解和學(xué)習(xí)C#客戶端程序有所幫助。
【編輯推薦】