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

在下面的例子中，我們將建立乙個時間伺服器，包括伺服器端程式和客戶端程式。伺服器端監聽客戶端的連線請求，建立連線以後向客戶端傳送當前的系統時間。

先執行伺服器端程式，下面截圖顯示了伺服器端程式執行的狀況：

然後執行客戶端程式，客戶端首先傳送連線請求到伺服器端，伺服器端回應後傳送當前時間到客戶端

通過這個例子我們可以了解tcpclient類的基本用法，要使用這個類，必須使用system.net.socket命名空間，本例用到的三個命名空間如下：

using system;

using system.net.sockets;

using system.text;//從位元組陣列中獲取字串時使用該命名空間中的類

首先討論一下客戶端程式，開始我們必須初始化乙個tcpclient類的例項：

tcpclient client = new tcpclient(hostname, portnum);

然後使用tcpclient類的getstream()方法獲取資料流，並且用它初始化乙個networkstream類的例項：

networkstream ns = client.getstream();

注意，當使用主機名和埠號初始化tcpclient類的例項時，直到跟伺服器建立了連線，這個例項才算真正建立，程式才能往下執行。如果因為網路不通，伺服器不存在，伺服器端口未開放等等原因而不能連線，程式將丟擲異常並且中斷執行。

建立資料流之後，我們可以使用networkstream類的read()方法從流中讀取資料，使用write()方法向流中寫入資料。讀取資料時，首先應該建立乙個緩衝區，具體的說，就是建立乙個byte型的陣列用來存放從流中讀取的資料。read()方法的原型描述如下：

public override int read(in byte buffer,int offset,int size)

buffer是緩衝陣列，offset是資料（位元組流）在緩衝陣列中存放的開始位置，size是讀取的位元組數目，返回值是讀取的位元組數。在本例中，簡單地使用該方法來讀取伺服器反饋的資訊：

byte bytes = new byte[1024];//建立緩衝區

int bytesread = ns.read(bytes, 0, bytes.length);//讀取位元組流

然後顯示到螢幕上：

console.writeline(encoding.ascii.getstring(bytes,0,bytesread));

最後不要忘記關閉連線：

client.close();

下面是本例完整的程式清單：

using system;

using system.net.sockets;

using system.text;

namespace tcpclientexample

 catch (exception e)



}

}

}上面這個例子清晰地演示了客戶端程式的編寫要點，下面我們討論一下如何建立伺服器程式。這個例子將使用tcplistener類，在13號埠監聽，一旦有客戶端連線，將立即向客戶端傳送當前伺服器的時間資訊。

tcplistener的關鍵在於accepttcpclient()方法，該方法將檢測埠是否有未處理的連線請求，如果有未處理的連線請求，該方法將使伺服器同客戶端建立連線，並且返回乙個tcpclient物件，通過這個物件的getstream方法建立同客戶端通訊的資料流。事實上，tcplistener類還提供乙個更為靈活的方法acceptsocket()，當然靈活的代價是複雜，對於比較簡單的程式，accepttcpclient()已經足夠用了。此外，tcplistener類提供start()方法開始監聽，提供stop()方法停止監聽。

首先我們使用埠初始化乙個tcplistener例項，並且開始在13埠監聽：

private const int portnum = 13;

tcplistener listener = new tcplistener(portnum);

listener.start();//開始監聽

如果有未處理的連線請求，使用accepttcpclient方法進行處理，並且獲取資料流：

tcpclient client = listener.accepttcpclient();

networkstream ns = client.getstream();

然後，獲取本機時間，並儲存在位元組陣列中，使用networkstream.write()方法寫入資料流，然後客戶端就可以通過read()方法從資料流中獲取這段資訊：

　byte bytetime = encoding.ascii.getbytes(datetime.now.tostring());

ns.write(bytetime, 0, bytetime.length);

ns.close();//不要忘記關閉資料流和連線

client.close();

伺服器端程式完整的程式清單如下：

using system;

using system.net.sockets;

using system.text;

namespace timeserver

 catch (exception e)



}

listener.stop();

}

}

}

乙個p2p例項：

using system ;

using system.drawing ;

using system.collections ;

using system.componentmodel ;

using system.windows.forms ;

using system.data ;

using system.net.sockets ;

using system.net ;

using system.io ;

using system.text ;

using system.threading ;

namespace p2p

///

/// 清理所有正在使用的資源。

///

protected override void dispose( bool disposing )

catch

if ( disposing ) }

base.dispose ( disposing ) ;

#region windows 窗體設計器生成的**

///

/// 設計器支援所需的方法 - 不要使用**編輯器修改

/// 此方法的內容。

///

#endregion

///

/// 應用程式的主入口點。

///

private void listen ( )

catch ( system.security.securityexception ) }

} private void form1_load(object sender, system.eventargs e)

private void button1_click(object sender, system.eventargs e)

catch ( exception ) }

private void button3_click(object sender, system.eventargs e)

button3.enabled = false;

}private void button4_click(object sender, system.eventargs e)

//異常處理

catch ( exception ) }

private void button2_click(object sender, system.eventargs e)

private void button5_click(object sender, system.eventargs e)}}

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

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

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

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

相關推薦