用C#實(shí)現(xiàn)TCP通信

1、用C#實(shí)現(xiàn)基于TCP協(xié)議的網(wǎng)絡(luò)通訊TCP協(xié)議是一個(gè)根本的網(wǎng)絡(luò)協(xié)議，根本上所有的網(wǎng)絡(luò)效勞都是基于TCP協(xié)議的，如 ，F(xiàn)TP等等，所以要了解網(wǎng)絡(luò)編程就必須了解基于TCP協(xié)議的編程。然而TCP協(xié)議是一個(gè)龐雜的體系，要徹底的弄清楚它的實(shí)現(xiàn)不是一天兩天的功夫，所幸的是在。net framework環(huán)境下，我們不必要去追究TCP協(xié)議底層的實(shí)現(xiàn)，一樣可以很方便的編寫(xiě)出基于TCP協(xié)議進(jìn)行網(wǎng)絡(luò)通訊的程序。要進(jìn)行基于TCP協(xié)議的網(wǎng)絡(luò)通訊，首先必須建立同遠(yuǎn)程主機(jī)的連接，連接地址通常包括兩局部主機(jī)名和端口，如 yesky ：80中， yesky 就是主機(jī)名，80指主機(jī)的80端口，當(dāng)然，主機(jī)名也可以用IP地址代替。當(dāng)連

2、接建立之后，就可以使用這個(gè)連接去發(fā)送和接收數(shù)據(jù)包，TCP協(xié)議的作用就是保證這些數(shù)據(jù)包能到達(dá)終點(diǎn)并且能按照正確的順序組裝起來(lái)。在。net framework的類庫(kù)Class Library中，提供了兩個(gè)用于TCP網(wǎng)絡(luò)通訊的類，分別是TcpClient和TcpListener.由其英文意義顯而易見(jiàn)，TcpClient 類是基于TCP協(xié)議的客戶端類，而TcpListener是效勞器端，監(jiān)聽(tīng)Listen客戶端傳來(lái)的連接請(qǐng)求。TcpClient類通過(guò)TCP協(xié)議與效勞器進(jìn)行通訊并獲取信息，它的內(nèi)部封裝了一個(gè)Socket類的實(shí)例，這個(gè)Socket對(duì)象被用來(lái)使用TCP協(xié)議向效勞器請(qǐng)求和獲取數(shù)據(jù)。因?yàn)榕c遠(yuǎn)程主機(jī)

3、的交互是以數(shù)據(jù)流的形式出現(xiàn)的，所以傳輸?shù)臄?shù)據(jù)可以使用。net framework中流處理技術(shù)讀寫(xiě)。在我們下邊的例子中，你可以看到使用NetworkStream類操作數(shù)據(jù)流的方法。在下面的例子中，我們將建立一個(gè)時(shí)間效勞器，包括效勞器端程序和客戶端程序。效勞器端監(jiān)聽(tīng)客戶端的連接請(qǐng)求，建立連接以后向客戶端發(fā)送當(dāng)前的系統(tǒng)時(shí)間。先運(yùn)行效勞器端程序，下面截圖顯示了效勞器端程序運(yùn)行的狀況：然后運(yùn)行客戶端程序，客戶端首先發(fā)送連接請(qǐng)求到效勞器端，效勞器端回應(yīng)后發(fā)送當(dāng)前時(shí)間到客戶端，這是客戶端程序的截圖：發(fā)送完成后，效勞器端繼續(xù)等待下一次連接：通過(guò)這個(gè)例子我們可以了解TcpClient類的根本用法，要使用這個(gè)類，

4、必須使用System.Net.Socket命名空間，本例用到的三個(gè)命名空間如下： using System;using System.Net.Sockets;using System.Text;/從字節(jié)數(shù)組中獲取字符串時(shí)使用該命名空間中的類/首先討論一下客戶端程序，開(kāi)始我們必須初始化一個(gè)TcpClient類的實(shí)例：TcpClient client = new TcpClient(hostName, portNum);/然后使用TcpClient類的GetStream()方法獲取數(shù)據(jù)流，并且用它初始化一個(gè)NetworkStream類的實(shí)例：NetworkStream ns = client.Ge

5、tStream();注意，當(dāng)使用主機(jī)名和端口號(hào)初始化TcpClient類的實(shí)例時(shí)，直到跟效勞器建立了連接，這個(gè)實(shí)例才算真正建立，程序才能往下執(zhí)行。如果因?yàn)榫W(wǎng)絡(luò)不通，效勞器不存在，效勞器端口未開(kāi)放等等原因而不能連接，程序?qū)伋霎惓２⑶抑袛鄨?zhí)行。建立數(shù)據(jù)流之后，我們可以使用NetworkStream類的Read方法從流中讀取數(shù)據(jù)，使用Write方法向流中寫(xiě)入數(shù)據(jù)。讀取數(shù)據(jù)時(shí)，首先應(yīng)該建立一個(gè)緩沖區(qū)，具體的說(shuō)，就是建立一個(gè)byte型的數(shù)組用來(lái)存放從流中讀取的數(shù)據(jù)。Read方法的原型描述如下：public override int Readin byte buffer，int offset，int s

6、izebuffer是緩沖數(shù)組，offset是數(shù)據(jù)字節(jié)流在緩沖數(shù)組中存放的開(kāi)始位置，size是讀取的字節(jié)數(shù)目，返回值是讀取的字節(jié)數(shù)。在本例中，簡(jiǎn)單地使用該方法來(lái)讀取效勞器反應(yīng)的信息： 資料個(gè)人收集整理，勿做商業(yè)用途byte bytes = new byte1024;/建立緩沖區(qū)int bytesRead = ns.Read(bytes, 0, bytes.Length);/讀取字節(jié)流/然后顯示到屏幕上：Console.WriteLine(Encoding.ASCII.GetString(bytes,0,bytesRead);/最后不要忘記關(guān)閉連接：client.Close();下面是本例完整的程

7、序清單：using System;using System.Net.Sockets;using System.Text;namespace TcpClientExamplepublic class TcpTimeClientprivate const int portNum = 13;/效勞器端口，可以隨意修改private const string hostName = ;/效勞器地址，指本機(jī)STAThreadstatic void Main(string args)tryConsole.Write(Try to connect to +hostName+

8、:+portNum.ToString()+rn);TcpClient client = new TcpClient(hostName, portNum);NetworkStream ns = client.GetStream();byte bytes = new byte1024;int bytesRead = ns.Read(bytes, 0, bytes.Length);Console.WriteLine(Encoding.ASCII.GetString(bytes,0,bytesRead);client.Close();Console.ReadLine();/由于是控制臺(tái)程序，故為了清楚

9、的看到結(jié)果，可以加上這句catch (Exception e)Console.WriteLine(e.ToString();上面這個(gè)例子清晰地演示了客戶端程序的編寫(xiě)要點(diǎn)，下面我們討論一下如何建立效勞器程序。這個(gè)例子將使用TcpListener類，在13號(hào)端口監(jiān)聽(tīng)，一旦有客戶端連接，將立即向客戶端發(fā)送當(dāng)前效勞器的時(shí)間信息。TcpListener的關(guān)鍵在于AcceptTcpClient方法，該方法將檢測(cè)端口是否有未處理的連接請(qǐng)求，如果有未處理的連接請(qǐng)求，該方法將使效勞器同客戶端建立連接，并且返回一個(gè)TcpClient對(duì)象，通過(guò)這個(gè)對(duì)象的GetStream方法建立同客戶端通訊的數(shù)據(jù)流。事實(shí)上， Tc

10、pListener類還提供一個(gè)更為靈活的方法AcceptSocket，當(dāng)然靈活的代價(jià)是復(fù)雜，對(duì)于比擬簡(jiǎn)單的程序， AcceptTcpClient已經(jīng)足夠用了。此外，TcpListener類提供Start方法開(kāi)始監(jiān)聽(tīng)，提供Stop方法停止監(jiān)聽(tīng)。首先我們使用端口初始化一個(gè)TcpListener實(shí)例，并且開(kāi)始在13端口監(jiān)聽(tīng)：文檔來(lái)自于網(wǎng)絡(luò)搜索private const int portNum = 13;TcpListener listener = new TcpListener(portNum);listener.Start();/開(kāi)始監(jiān)聽(tīng)/如果有未處理的連接請(qǐng)求，使用AcceptTcpClient

11、方法進(jìn)行處理，并且獲取數(shù)據(jù)流：TcpClient client = listener.AcceptTcpClient();NetworkStream ns = client.GetStream();/然后，獲取本機(jī)時(shí)間，并保存在字節(jié)數(shù)組中，使用NetworkStream.Write()方法寫(xiě)入數(shù)據(jù)流，然后客戶端就可以通過(guò)Read()方法從數(shù)據(jù)流中獲取這段信息：byte byteTime = Encoding.ASCII.GetBytes(DateTime.Now.ToString();ns.Write(byteTime, 0, byteTime.Length);ns.Close();/不要忘記

12、關(guān)閉數(shù)據(jù)流和連接client.Close();效勞器端程序完整的程序清單如下： using System;using System.Net.Sockets;using System.Text;namespace TimeServerclass TimeServerprivate const int portNum = 13;STAThreadstatic void Main(string args)bool done = false;TcpListener listener = new TcpListener(portNum);listener.Start();while (!done)Console.Write(Waiting for connection.);TcpClient client = listener.AcceptTcpClient();Console.WriteLine(Connection accepted.);NetworkStream ns = client.GetStream();byte byteTime = Encoding.ASCII.GetBytes(DateTime.Now.ToString();tryns.Write(byteTime, 0, byteTime.Length);ns.Clo