程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#基礎知識 >> 用C#實現基於TCP協議的網絡通訊

用C#實現基於TCP協議的網絡通訊

編輯:C#基礎知識

  TCP協議是一個基本的網絡協議,基本上所有的網絡服務都是基於TCP協議的,如HTTP,FTP等等,所以要了解網絡編程就必須了解基於TCP協議的編程。然而TCP協議是一個龐雜的體系,要徹底的弄清楚它的實現不是一天兩天的功夫,所幸的是在.net framework環境下,我們不必要去追究TCP協議底層的實現,一樣可以很方便的編寫出基於TCP協議進行網絡通訊的程序。

  牐犚進行基於TCP協議的網絡通訊,首先必須建立同遠程主機的連接,連接地址通常包括兩部分——主機名和端口,如www.ddvip.com:80中,www.ddvip.com就是主機名,80指主機的80端口,當然,主機名也可以用IP地址代替。當連接建立之後,就可以使用這個連接去發送和接收數據包,TCP協議的作用就是保證這些數據包能到達終點並且能按照正確的順序組裝起來。

  牐犜.net framework的類庫(Class Library)中,提供了兩個用於TCP網絡通訊的類,分別是TcpClient和TcpListener。由其英文意義顯而易見,TcpClient類是基於TCP協議的客戶端類,而TcpListener是服務器端,監聽(Listen)客戶端傳來的連接請求。TcpClient類通過TCP協議與服務器進行通訊並獲取信息,它的內部封裝了一個Socket類的實例,這個Socket對象被用來使用TCP協議向服務器請求和獲取數據。因為與遠程主機的交互是以數據流的形式出現的,所以傳輸的數據可以使用.net framework中流處理技術讀寫。在我們下邊的例子中,你可以看到使用NetworkStream類操作數據流的方法。

  牐犜谙旅娴睦子中,我們將建立一個時間服務器,包括服務器端程序和客戶端程序。服務器端監聽客戶端的連接請求,建立連接以後向客戶端發送當前的系統時間。

  牐犗仍誦蟹務器端程序,下面截圖顯示了服務器端程序運行的狀況:

  牐犎緩笤誦鋅突Ф順絛颍客戶端首先發送連接請求到服務器端,服務器端回應後發送當前時間到客戶端,這是客戶端程序的截圖:

  牐牱⑺屯瓿珊螅服務器端繼續等待下一次連接:

  牐犕ü這個例子我們可以了解TcpClient類的基本用法,要使用這個類,必須使用System.Net.Socket命名空間,本例用到的三個命名空間如下:

  牐爑sing System;

  牐爑sing System.Net.Sockets;

  牐爑sing System.Text;//從字節數組中獲取字符串時使用該命名空間中的類

  牐犑紫忍致垡幌驢突Ф順絛颍開始我們必須初始化一個TcpClient類的實例:

  牐燭cpClient client = new TcpClient(hostName, portNum);

  牐犎緩笫褂肨cpClient類的GetStream()方法獲取數據流,並且用它初始化一個NetworkStream類的實例:

  牐燦etworkStream ns = client.GetStream();

  牐犠⒁猓當使用主機名和端口號初始化TcpClient類的實例時,直到跟服務器建立了連接,這個實例才算真正建立,程序才能往下執行。如果因為網絡不通,服務器不存在,服務器端口未開放等等原因而不能連接,程序將拋出異常並且中斷執行。

  牐牻立數據流之後,我們可以使用NetworkStream類的Read()方法從流中讀取數據,使用Write()方法向流中寫入數據。讀取數據時,首先應該建立一個緩沖區,具體的說,就是建立一個byte型的數組用來存放從流中讀取的數據。Read()方法的原型描述如下:

  牐爌ublic override int Read(in byte[] buffer,int offset,int size)

  牐燽uffer是緩沖數組,offset是數據(字節流)在緩沖數組中存放的開始位置,size是讀取的字節數目,返回值是讀取的字節數。在本例中,簡單地使用該方法來讀取服務器反饋的信息:

  牐燽yte[] bytes = new byte[1024];//建立緩沖區

  牐爄nt bytesRead = ns.Read(bytes, 0, bytes.Length);//讀取字節流

  牐犎緩笙允鏡狡聊簧希

  牐燙onsole.WriteLine(Encoding.ASCII.GetString(bytes,0,bytesRead));

  牐犠詈蟛灰忘記關閉連接:

  牐燾lient.Close();

  牐犗旅媸潛糾完整的程序清單:

  牐

using System;
牐爑sing System.Net.Sockets;
牐爑sing System.Text;
牐爊amespace TcpClientExample
牐爗
牐牐牐爌ublic class TcpTimeClient
牐牐牐爗
牐牐牐牐牐爌rivate const int portNum = 13;//服務器端口,可以隨意修改
牐牐牐牐牐爌rivate const string hostName = "127.0.0.1";//服務器地址,127.0.0.1指本機
牐牐牐牐牐燵STAThread]
牐牐牐牐牐爏tatic void Main(string[] args)
牐牐牐牐牐爗
牐牐牐牐牐牐牐爐ry
牐牐牐牐牐牐牐爗
牐牐牐牐牐牐牐牐牐燙onsole.Write("Try to connect to "+hostName+":"+portNum.ToString()+"\r\n");
牐牐牐牐牐牐牐牐牐燭cpClient client = new TcpClient(hostName, portNum);
牐牐牐牐牐牐牐牐牐燦etworkStream ns = client.GetStream();
牐牐牐牐牐牐牐牐牐燽yte[] bytes = new byte[1024];
牐牐牐牐牐牐牐牐牐爄nt bytesRead = ns.Read(bytes, 0, bytes.Length);
牐牐牐牐牐牐牐牐牐燙onsole.WriteLine(Encoding.ASCII.GetString(bytes,0,bytesRead));
牐牐牐牐牐牐牐牐牐燾lient.Close();
牐牐牐牐牐牐牐牐牐燙onsole.ReadLine();//由於是控制台程序,故為了清楚的看到結果,可以加上這句
牐牐牐牐牐牐牐爙
牐牐牐牐牐牐牐燾atch (Exception e)
牐牐牐牐牐牐牐爗
牐牐牐牐牐牐牐牐牐燙onsole.WriteLine(e.ToString());
牐牐牐牐牐牐牐爙
牐牐牐牐牐爙
牐牐牐爙
牐爙

  • 首頁
  • 上一頁
  • 1
  • 2
  • 下一頁
  • 尾頁
  • 共2頁
  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved