日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
C#客戶端程序?qū)崿F(xiàn)同步傳輸字符串淺析

C#客戶端程序?qū)崿F(xiàn)同步傳輸字符串的問題：我們編寫客戶端向服務(wù)器發(fā)送字符串的代碼，與服務(wù)端類似，它先獲取連接服務(wù)器端的流，將字符串保存到buffer緩存中，再將緩存寫入流，寫入流這一過程，相當(dāng)于將消息發(fā)往服務(wù)端。

創(chuàng)新互聯(lián)成立于2013年，先為仁壽等服務(wù)建站，仁壽等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為仁壽企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。

 
 
 
    
  
  
  
  1. class Client {  
    2. 
  
  
  
  2.     static void Main(string[] args) {  
    3. 
  
  
  
  3.         Console.WriteLine("Client Running ...");  
    4. 
  
  
  
  4.         TcpClient client;  
    5. 
  
  
  
  5. //C#客戶端程序  
    6. 
  
  
  
  6.         try {  
    7. 
  
  
  
  7.             client = new TcpClient();  
    8. 
  
  
  
  8.             client.Connect("localhost", 8500);      // 與服務(wù)器連接  
    9. 
  
  
  
  9.         } catch (Exception ex) {  
    10. 
  
  
  
  10.             Console.WriteLine(ex.Message);  
    11. 
  
  
  
  11.             return;  
    12. 
  
  
  
  12.         }  
    13. 
  
  
  
  13.         // 打印連接到的服務(wù)端信息  
    14. 
  
  
  
  14.         Console.WriteLine("Server Connected！{0} --> {1}",  
    15. 
  
  
  
  15.             client.Client.LocalEndPoint, client.Client.RemoteEndPoint);  
    16. 
  
  
  
  16. //C#客戶端程序  
    17. 
  
  
  
  17.         string msg = "\"Welcome To TraceFact.Net\"";  
    18. 
  
  
  
  18.         NetworkStream streamToServer = client.GetStream();  
    19. 
  
  
  
  19.  
    20. 
  
  
  
  20.         byte[] buffer = Encoding.Unicode.GetBytes(msg);     // 獲得緩存  
    21. 
  
  
  
  21.         streamToServer.Write(buffer, 0, buffer.Length);     // 發(fā)往服務(wù)器  
    22. 
  
  
  
  22.         Console.WriteLine("Sent: {0}", msg);  
    23. 
  
  
  
  23.  
    24. 
  
  
  
  24.         // 按Q退出  
    25. 
  
  
  
  25.     }  
    26. 
  
  
  
  26. }  
    27.

現(xiàn)在再次運(yùn)行程序，得到的輸出為：

 
 
 
    
  
  
  
  1. // 服務(wù)端  
    2. 
  
  
  
  2. Server is running ...  
    3. 
  
  
  
  3. Start Listening ...  
    4. 
  
  
  
  4. Client Connected！127.0.0.1:8500 <-- 127.0.0.1:7847  
    5. 
  
  
  
  5. Reading data, 52 bytes ...  
    6. 
  
  
  
  6. Received: "Welcome To TraceFact.Net" 
    7. 
  
  
  
  7. 輸入"Q"鍵退出。  
    8. 
  
  
  
  8. // 客戶端  
    9. 
  
  
  
  9. Client Running ...  
    10. 
  
  
  
  10. Server Connected！127.0.0.1:7847 --> 127.0.0.1:8500  
    11. 
  
  
  
  11. Sent: "Welcome To TraceFact.Net" 
    12. 
  
  
  
  12. 輸入"Q"鍵退出。 
    13.

再繼續(xù)進(jìn)行之前，我們假設(shè)客戶端可以發(fā)送多條消息，而服務(wù)端要不斷的接收來自客戶端發(fā)送的消息，但是上面的代碼只能接收客戶端發(fā)來的一條消息，因?yàn)樗呀?jīng)輸出了“輸入Q鍵退出”，說明程序已經(jīng)執(zhí)行完畢，無法再進(jìn)行任何動作。此時如果我們再開啟一個客戶端，那么出現(xiàn)的情況是：客戶端可以與服務(wù)器建立連接，也就是netstat-a顯示為ESTABLISHED，這是操作系統(tǒng)所知道的；但是由于服務(wù)端的程序已經(jīng)執(zhí)行到了最后一步，只能輸入Q鍵退出，無法再采取任何的動作。

回想一個上面我們需要一個服務(wù)器對應(yīng)多個客戶端時，對AcceptTcpClient()方法的處理辦法，將它放在了do/while循環(huán)中；類似地，當(dāng)我們需要一個服務(wù)端對同一個客戶端的多次請求服務(wù)時，可以將Read()方法放入到do/while循環(huán)中。

現(xiàn)在，我們大致可以得出這樣幾個結(jié)論：

◆如果不使用do/while循環(huán)，服務(wù)端只有一個listener.AcceptTcpClient()方法和一個TcpClient.GetStream().Read()方法，則服務(wù)端只能處理到同一客戶端的一條請求。

◆如果使用一個do/while循環(huán)，并將listener.AcceptTcpClient()方法和TcpClient.GetStream().Read()方法都放在這個循環(huán)以內(nèi)，那么服務(wù)端將可以處理多個客戶端的一條請求。

◆如果使用一個do/while循環(huán)，并將listener.AcceptTcpClient()方法放在循環(huán)之外，將TcpClient.GetStream().Read()方法放在循環(huán)以內(nèi)，那么服務(wù)端可以處理一個客戶端的多條請求。

◆如果使用兩個do/while循環(huán)，對它們進(jìn)行分別嵌套，那么結(jié)果是什么呢？結(jié)果并不是可以處理多個客戶端的多條請求。因?yàn)槔飳拥膁o/while循環(huán)總是在為一個客戶端服務(wù)，因?yàn)樗鼤袛嘣赥cpClient.GetStream().Read()方法的位置，而無法執(zhí)行完畢。即使可以通過某種方式讓里層循環(huán)退出，比如客戶端往服務(wù)端發(fā)去“exit”字符串時，服務(wù)端也只能挨個對客戶端提供服務(wù)。如果服務(wù)端想執(zhí)行多個客戶端的多個請求，那么服務(wù)端就需要采用多線程。主線程，也就是執(zhí)行外層do/while循環(huán)的線程，在收到一個TcpClient之后，必須將里層的do/while循環(huán)交給新線程去執(zhí)行，然后主線程快速地重新回到listener.AcceptTcpClient()的位置，以響應(yīng)其它的客戶端。

對于第四種情況，實(shí)際上是構(gòu)建一個服務(wù)端更為通常的情況，所以需要專門開辟一個章節(jié)討論，這里暫且放過。而我們上面所做的，即是列出的第一種情況，接下來我們再分別看一下第二種和第三種情況。

對于第二種情況，我們按照上面的敘述先對服務(wù)端進(jìn)行一下改動：

 
 
 
    
  
  
  
  1. do {  
    2. 
  
  
  
  2. // 獲取一個連接，中斷方法  
    3. 
  
  
  
  3. TcpClient remoteClient = listener.AcceptTcpClient();  
    4. 
  
  
  
  4. // 打印連接到的客戶端信息  
    5. 
  
  
  
  5. Console.WriteLine("Client Connected！{0} <-- {1}",  
    6. 
  
  
  
  6. remoteClient.Client.LocalEndPoint,   
    7. 
  
  
  
  7. remoteClient.Client.RemoteEndPoint);  
    8. 
  
  
  
  8.  
    9. 
  
  
  
  9. // 獲得流，并寫入buffer中  
    10. 
  
  
  
  10. NetworkStream streamToClient = remoteClient.GetStream();  
    11. 
  
  
  
  11. byte[] buffer = new byte[BufferSize];  
    12. 
  
  
  
  12. int bytesRead = streamToClient.Read(buffer, 0, BufferSize);  
    13. 
  
  
  
  13. Console.WriteLine("Reading data, {0} bytes ...", bytesRead);  
    14. 
  
  
  
  14.  
    15. 
  
  
  
  15. // 獲得請求的字符串  
    16. 
  
  
  
  16. string msg = Encoding.Unicode.GetString(buffer, 0, bytesRead);  
    17. 
  
  
  
  17. Console.WriteLine("Received: {0}", msg);  
    18. 
  
  
  
  18. } while (true);  
    19.

然后啟動多個客戶端，在服務(wù)端應(yīng)該可以看到下面的輸出（客戶端沒有變化）：

 
 
 
    
  
  
  
  1. Server is running ...  
    2. 
  
  
  
  2. Start Listening ...  
    3. 
  
  
  
  3. Client Connected！127.0.0.1:8500 <-- 127.0.0.1:8196  
    4. 
  
  
  
  4. Reading data, 52 bytes ...  
    5. 
  
  
  
  5. Received: "Welcome To TraceFact.Net" 
    6. 
  
  
  
  6. Client Connected！127.0.0.1:8500 <-- 127.0.0.1:8199  
    7. 
  
  
  
  7. Reading data, 52 bytes ...  
    8. 
  
  
  
  8. Received: "Welcome To TraceFact.Net" 
    9.

由第2種情況改為第3種情況，只需要將do向下挪動幾行就可以了：

 
 
 
    
  
  
  
  1. // 獲取一個連接，中斷方法  
    2. 
  
  
  
  2. TcpClient remoteClient = listener.AcceptTcpClient();  
    3. 
  
  
  
  3. // 打印連接到的客戶端信息  
    4. 
  
  
  
  4. Console.WriteLine("Client Connected！{0} <-- {1}",  
    5. 
  
  
  
  5.     remoteClient.Client.LocalEndPoint,  
    6. 
  
  
  
  6.  remoteClient.Client.RemoteEndPoint);  
    7. 
  
  
  
  7. // 獲得流，并寫入buffer中  
    8. 
  
  
  
  8. NetworkStream streamToClient = remoteClient.GetStream();  
    9. 
  
  
  
  9.  
    10. 
  
  
  
  10. do {  
    11. 
  
  
  
  11.     byte[] buffer = new byte[BufferSize];  
    12. 
  
  
  
  12.     int bytesRead = streamToClient.Read(  
    13. 
  
  
  
  13. buffer, 0, BufferSize);  
    14. 
  
  
  
  14.     Console.WriteLine("Reading data,   
    15. 
  
  
  
  15. {0} bytes ...", bytesRead);  
    16. 
  
  
  
  16.  
    17. 
  
  
  
  17.     // 獲得請求的字符串  
    18. 
  
  
  
  18.     string msg = Encoding.Unicode.GetString(  
    19. 
  
  
  
  19. buffer, 0, bytesRead);  
    20. 
  
  
  
  20.     Console.WriteLine("Received: {0}", msg);  
    21. 
  
  
  
  21. } while (true);  
    22.

然后我們再改動一下客戶端，讓它發(fā)送多個請求。當(dāng)我們按下S的時候，可以輸入一行字符串，然后將這行字符串發(fā)送到服務(wù)端；當(dāng)我們輸入X的時候則退出循環(huán)：

 
 
 
    
  
  
  
  1. NetworkStream streamToServer = client.GetStream();  
    2. 
  
  
  
  2. ConsoleKey key;  
    3. 
  
  
  
  3. Console.WriteLine("Menu: S - Send, X - Exit");  
    4. 
  
  
  
  4. do {  
    5. 
  
  
  
  5. key = Console.ReadKey(true).Key;  
    6. 
  
  
  
  6.  
    7. 
  
  
  
  7. if (key == ConsoleKey.S) {  
    8. 
  
  
  
  8. // 獲取輸入的字符串  
    9. 
  
  
  
  9. Console.Write("Input the message: ");  
    10. 
  
  
  
  10. string msg = Console.ReadLine();  
    11. 
  
  
  
  11.  
    12. 
  
  
  
  12. byte[] buffer = Encoding.Unicode.GetBytes(msg);// 獲得緩存  
    13. 
  
  
  
  13. streamToServer.Write(buffer, 0, buffer.Length);// 發(fā)往服務(wù)器  
    14. 
  
  
  
  14. Console.WriteLine("Sent: {0}", msg);  
    15. 
  
  
  
  15. }  
    16. 
  
  
  
  16. } while (key != ConsoleKey.X);  
    17.

接下來我們先運(yùn)行服務(wù)端，然后再運(yùn)行客戶端，輸入一些字符串，來進(jìn)行測試，應(yīng)該能夠看到下面的輸出結(jié)果：

 
 
 
    
  
  
  
  1. // 服務(wù)端  
    2. 
  
  
  
  2. Server is running ...  
    3. 
  
  
  
  3. Start Listening ...  
    4. 
  
  
  
  4. Client Connected！127.0.0.1:8500 <-- 127.0.0.1:11004  
    5. 
  
  
  
  5. Reading data, 44 bytes ...  
    6. 
  
  
  
  6. Received: 歡迎訪問我的博客：TraceFact.Net  
    7. 
  
  
  
  7. Reading data, 14 bytes ...  
    8. 
  
  
  
  8. Received: 我們一起進(jìn)步！  
    9. 
  
  
  
  9. //客戶端  
    10. 
  
  
  
  10. Client Running ...  
    11. 
  
  
  
  11. Server Connected！127.0.0.1:11004 --> 127.0.0.1:8500  
    12. 
  
  
  
  12. Menu: S - Send, X - Exit  
    13. 
  
  
  
  13. Input the message: 歡迎訪問我的博客：TraceFact.Net  
    14. 
  
  
  
  14. Sent: 歡迎訪問我的博客：TraceFact.Net  
    15. 
  
  
  
  15. Input the message: 我們一起進(jìn)步！  
    16. 
  
  
  
  16. Sent: 我們一起進(jìn)步！ 
    17.

這里還需要注意一點(diǎn)，當(dāng)客戶端在TcpClient實(shí)例上調(diào)用Close()方法，或者在流上調(diào)用Dispose()方法，服務(wù)端的streamToClient.Read()方法會持續(xù)地返回0，但是不拋出異常，所以會產(chǎn)生一個無限循環(huán)；而如果直接關(guān)閉掉客戶端，或者客戶端執(zhí)行完畢但沒有調(diào)用stream.Dispose()或者TcpClient.Close()，如果服務(wù)器端此時仍阻塞在Read()方法處，則會在服務(wù)器端拋出異常：“遠(yuǎn)程主機(jī)強(qiáng)制關(guān)閉了一個現(xiàn)有連接”。因此，我們將服務(wù)端的streamToClient.Read()方法需要寫在一個try/catch中。同理，如果在服務(wù)端已經(jīng)連接到客戶端之后，服務(wù)端調(diào)用remoteClient.Close()，則客戶端會得到異?！盁o法將數(shù)據(jù)寫入傳輸連接: 您的主機(jī)中的軟件放棄了一個已建立的連接?！?；而如果服務(wù)端直接關(guān)閉程序的話，則客戶端會得到異常“無法將數(shù)據(jù)寫入傳輸連接: 遠(yuǎn)程主機(jī)強(qiáng)迫關(guān)閉了一個現(xiàn)有的連接?！?。因此，它們的讀寫操作必須都放入到try/catch塊中。

C#客戶端程序的基本內(nèi)容就向你介紹到這里，希望對你了解和學(xué)習(xí)C#客戶端程序有所幫助。


分享標(biāo)題：C#客戶端程序?qū)崿F(xiàn)同步傳輸字符串淺析
本文地址：http://www.5511xx.com/article/cddsshd.html