C#服務(wù)端程序?qū)崿F(xiàn)同步傳輸字符串淺析
C#服務(wù)端程序?qū)崿F(xiàn)同步傳輸字符串問(wèn)題的由來(lái):我們可以在TcpClient上調(diào)用GetStream()方法來(lái)獲得連接到遠(yuǎn)程計(jì)算機(jī)的流。注意這里我用了遠(yuǎn)程這個(gè)詞,當(dāng)在客戶端調(diào)用時(shí),它得到連接服務(wù)端的流;當(dāng)在服務(wù)端調(diào)用時(shí),它獲得連接客戶端的流。接下來(lái)我們來(lái)看一下代碼,我們先看服務(wù)端(注意這里沒(méi)有使用do/while循環(huán)):
C#服務(wù)端程序?qū)嵗?/P>
- //C#服務(wù)端程序
- class Server {
- static void Main(string[] args) {
- const int BufferSize = 8192;// 緩存大小,8192字節(jié)
- Console.WriteLine("Server is running ... ");
- IPAddress ip = new IPAddress(new byte[] { 127, 0, 0, 1 });
- TcpListener listener = new TcpListener(ip, 8500);
- listener.Start(); // 開(kāi)始偵聽(tīng)
- Console.WriteLine("Start Listening ...");
- //C#服務(wù)端程序
- // 獲取一個(gè)連接,中斷方法
- TcpClient remoteClient = listener.AcceptTcpClient();
- // 打印連接到的客戶端信息
- Console.WriteLine("Client Connected!{0} <-- {1}",
- remoteClient.Client.LocalEndPoint,
- remoteClient.Client.RemoteEndPoint);
- // 獲得流,并寫(xiě)入buffer中
- NetworkStream streamToClient = remoteClient.GetStream();
- byte[] buffer = new byte[BufferSize];
- int bytesRead = streamToClient.Read(buffer, 0, BufferSize);
- Console.WriteLine("Reading data, {0} bytes ...", bytesRead);
- //C#服務(wù)端程序
- // 獲得請(qǐng)求的字符串
- string msg = Encoding.Unicode.GetString(buffer, 0, bytesRead);
- Console.WriteLine("Received: {0}", msg);
- //C#服務(wù)端程序
- // 按Q退出
- }
- }
這段C#服務(wù)端程序的上半部分已經(jīng)很熟悉了,我就不再解釋。remoteClient.GetStream()方法獲取到了連接至客戶端的流,然后從流中讀出數(shù)據(jù)并保存在了buffer緩存中,隨后使用Encoding.Unicode.GetString()方法,從緩存中獲取到了實(shí)際的字符串。***將字符串打印在了控制臺(tái)上。這段代碼有個(gè)地方需要注意:在能夠讀取的字符串的總字節(jié)數(shù)大于BufferSize的時(shí)候會(huì)出現(xiàn)字符串截?cái)喱F(xiàn)象,因?yàn)榫彺嬷械臄?shù)目總是有限的,而對(duì)于大對(duì)象,比如說(shuō)圖片或者其它文件來(lái)說(shuō),則必須采用“分次讀取然后轉(zhuǎn)存”這種方式,比如這樣:
- // 獲取字符串
- byte[] buffer = new byte[BufferSize];
- int bytesRead; // 讀取的字節(jié)數(shù)
- MemoryStream msStream = new MemoryStream();
- do {
- bytesRead = streamToClient.Read(buffer, 0, BufferSize);
- msStream.Write(buffer, 0, bytesRead);
- } while (bytesRead > 0);
- //C#服務(wù)端程序
- buffer = msStream.GetBuffer();
- string msg = Encoding.Unicode.GetString(buffer);
這里我沒(méi)有使用這種方法,一個(gè)是因?yàn)椴幌腙P(guān)注在太多的細(xì)節(jié)上面,一個(gè)是因?yàn)閷?duì)于字符串來(lái)說(shuō),8192字節(jié)已經(jīng)很多了,我們通常不會(huì)傳遞這么多的文本。當(dāng)使用Unicode編碼時(shí),8192字節(jié)可以保存4096個(gè)漢字和英文字符。使用不同的編碼方式,占用的字節(jié)數(shù)有很大的差異,在本文***面,有一段小程序,可以用來(lái)測(cè)試Unicode、UTF8、ASCII三種常用編碼方式對(duì)字符串編碼時(shí),占用的字節(jié)數(shù)大小。
現(xiàn)在對(duì)客戶端不做任何修改,然后運(yùn)行先運(yùn)行服務(wù)端,再運(yùn)行客戶端。結(jié)果我們會(huì)發(fā)現(xiàn)這樣一件事:服務(wù)端再打印完“Client Connected!127.0.0.1:8500 <-- 127.0.0.1:xxxxx”之后,再次被阻塞了,而沒(méi)有輸出“Reading data, {0} bytes ...”。可見(jiàn),與AcceptTcpClient()方法類似,這個(gè)Read()方法也是同步的,只有當(dāng)客戶端發(fā)送數(shù)據(jù)的時(shí)候,服務(wù)端才會(huì)讀取數(shù)據(jù)、運(yùn)行此方法,否則它便會(huì)一直等待。
C#服務(wù)端程序的基本內(nèi)容就向你介紹到這里,希望對(duì)你了解和學(xué)習(xí)C#服務(wù)端程序有所幫助。
【編輯推薦】