成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

C#客戶端程序實現同步傳輸字符串淺析

開發 后端
C#客戶端程序實現同步傳輸字符串主要向你介紹了C#客戶端程序實現同步傳輸字符串的具體操作與測試情況,希望對你了解和學習C#客戶端程序實現同步傳輸字符串有所幫助。

C#客戶端程序實現同步傳輸字符串的問題:我們編寫客戶端向服務器發送字符串的代碼,與服務端類似,它先獲取連接服務器端的流,將字符串保存到buffer緩存中,再將緩存寫入流,寫入流這一過程,相當于將消息發往服務端。

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

現在再次運行程序,得到的輸出為:

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

再繼續進行之前,我們假設客戶端可以發送多條消息,而服務端要不斷的接收來自客戶端發送的消息,但是上面的代碼只能接收客戶端發來的一條消息,因為它已經輸出了“輸入Q鍵退出”,說明程序已經執行完畢,無法再進行任何動作。此時如果我們再開啟一個客戶端,那么出現的情況是:客戶端可以與服務器建立連接,也就是netstat-a顯示為ESTABLISHED,這是操作系統所知道的;但是由于服務端的程序已經執行到了最后一步,只能輸入Q鍵退出,無法再采取任何的動作。

回想一個上面我們需要一個服務器對應多個客戶端時,對AcceptTcpClient()方法的處理辦法,將它放在了do/while循環中;類似地,當我們需要一個服務端對同一個客戶端的多次請求服務時,可以將Read()方法放入到do/while循環中。

現在,我們大致可以得出這樣幾個結論:

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

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

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

◆如果使用兩個do/while循環,對它們進行分別嵌套,那么結果是什么呢?結果并不是可以處理多個客戶端的多條請求。因為里層的do/while循環總是在為一個客戶端服務,因為它會中斷在TcpClient.GetStream().Read()方法的位置,而無法執行完畢。即使可以通過某種方式讓里層循環退出,比如客戶端往服務端發去“exit”字符串時,服務端也只能挨個對客戶端提供服務。如果服務端想執行多個客戶端的多個請求,那么服務端就需要采用多線程。主線程,也就是執行外層do/while循環的線程,在收到一個TcpClient之后,必須將里層的do/while循環交給新線程去執行,然后主線程快速地重新回到listener.AcceptTcpClient()的位置,以響應其它的客戶端。

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

對于第二種情況,我們按照上面的敘述先對服務端進行一下改動:

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

然后啟動多個客戶端,在服務端應該可以看到下面的輸出(客戶端沒有變化):

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

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

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

然后我們再改動一下客戶端,讓它發送多個請求。當我們按下S的時候,可以輸入一行字符串,然后將這行字符串發送到服務端;當我們輸入X的時候則退出循環:

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

接下來我們先運行服務端,然后再運行客戶端,輸入一些字符串,來進行測試,應該能夠看到下面的輸出結果:

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

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

C#客戶端程序的基本內容就向你介紹到這里,希望對你了解和學習C#客戶端程序有所幫助。

【編輯推薦】

  1. C#服務端與客戶端連接實現淺析
  2. C#服務端與客戶端連接實現淺談
  3. C#服務端與客戶端通信淺析
  4. C#服務端與客戶端通信詳解
  5. C#服務端程序實現同步傳輸字符串淺析
責任編輯:仲衡 來源: 博客園
相關推薦

2009-08-21 16:27:44

C#服務端程序

2009-08-21 14:33:15

C#異步傳輸字符串

2009-08-21 17:53:25

C#網絡編程客戶端程序

2009-08-21 15:36:41

服務端與客戶端

2009-08-21 17:48:43

C#網絡編程

2009-08-21 14:25:23

C#異步傳輸字符串

2009-08-11 10:26:49

C#算法C#字符串反轉

2009-08-21 15:59:22

服務端與客戶端通信

2009-09-01 17:50:23

C#截取字符串

2009-09-02 13:41:57

C#字符串操作

2009-08-21 15:54:40

服務端與客戶端

2009-09-03 18:45:06

GridView格式化

2009-07-15 17:33:08

Swing客戶端

2009-08-06 17:12:13

C# WebServi

2010-02-24 16:39:27

WCF客戶端處理

2009-10-15 10:46:03

PPC客戶端程序VB.NET創建

2009-08-28 16:03:15

C#程序實現鼠標移動

2009-08-20 14:31:55

C#正則表達式字符串

2011-04-07 09:33:01

Activex

2020-03-19 08:00:00

客戶端KubernetesAPI
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 国产精品久久久久aaaa九色 | 精品三级在线观看 | 亚洲精品免费视频 | 成人在线精品 | 久久精品国产一区 | 国产人成精品一区二区三 | 久久综合婷婷 | 国产精品久久久久久影视 | 日本一二三区在线观看 | 久久99深爱久久99精品 | 伊人久久一区二区 | 男女网站视频 | 久草免费在线视频 | 91大神新作在线观看 | 久久免费看 | 亚洲精品日韩一区二区电影 | 成人精品久久日伦片大全免费 | 色婷婷一区二区三区四区 | 在线成人av | 精品国产一区二区三区日日嗨 | 一区二区三区四区视频 | 亚洲一区中文字幕 | 欧美一级片免费看 | 久久精品欧美一区二区三区不卡 | 亚洲网站在线观看 | 亚洲一视频 | 在线精品一区二区三区 | 黄视频网站免费观看 | 欧美aaa| 国产精品1区2区 | 久久综合伊人 | 日韩a | 久久久久久免费毛片精品 | 亚洲国产精品久久久 | 狠狠色狠狠色综合系列 | 99精品国自产在线 | 天天躁日日躁性色aⅴ电影 免费在线观看成年人视频 国产欧美精品 | 成人免费观看视频 | 久久久久久久99 | 中文字幕1区2区3区 日韩在线视频免费观看 | 久久激情五月丁香伊人 |