程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#入門知識 >> C#網絡編程(同步傳輸字符串)二

C#網絡編程(同步傳輸字符串)二

編輯：C#入門知識

服務端客戶端通信

在與服務端的連接建立以後，我們就可以通過此連接來發送和接收數據。端口與端口之間以流（Stream）的形式傳輸數據，因為幾乎任何對象都可以保存到流中，所以實際上可以在客戶端與服務端之間傳輸任何類型的數據。對客戶端來說，往流中寫入數據，即為向服務器傳送數據；從流中讀取數據，即為從服務端接收數據。對服務端來說，往流中寫入數據，即為向客戶端發送數據；從流中讀取數據，即為從客戶端接收數據。

同步傳輸字符串

我們現在考慮這樣一個任務：客戶端打印一串字符串，然後發往服務端，服務端先輸出它，然後將它改為大寫，再回發到客戶端，客戶端接收到以後，最後再次打印一遍它。我們將它分為兩部分：1、客戶端發送，服務端接收並輸出；2、服務端回發，客戶端接收並輸出。

1.客戶端發送，服務端接收並輸出

1.1服務端程序

我們可以在TcpClient上調用GetStream()方法來獲得連接到遠程計算機的流。注意這裡我用了遠程這個詞，當在客戶端調用時，它得到連接服務端的流；當在服務端調用時，它獲得連接客戶端的流。接下來我們來看一下代碼，我們先看服務端（注意這裡沒有使用do/while循環）：

class Server {
    static void Main(string[] args) {
        const int BufferSize = 8192;    // 緩存大小，8192字節

        Console.WriteLine("Server is running ... ");
        IPAddress ip = new IPAddress(new byte[] { 127, 0, 0, 1 });
        TcpListener listener = new TcpListener(ip, 8500);

        listener.Start();           // 開始偵聽
        Console.WriteLine("Start Listening ...");

        // 獲取一個連接，中斷方法
        TcpClient remoteClient = listener.AcceptTcpClient();
        // 打印連接到的客戶端信息
        Console.WriteLine("Client Connected！{0} <-- {1}",
            remoteClient.Client.LocalEndPoint, remoteClient.Client.RemoteEndPoint);

        // 獲得流，並寫入buffer中
        NetworkStream streamToClient = remoteClient.GetStream();
        byte[] buffer = new byte[BufferSize];
        int bytesRead = streamToClient.Read(buffer, 0, BufferSize);
        Console.WriteLine("Reading data, {0} bytes ...", bytesRead);

        // 獲得請求的字符串
        string msg = Encoding.Unicode.GetString(buffer, 0, bytesRead);
        Console.WriteLine("Received: {0}", msg);

        // 按Q退出
    }
}

這段程序的上半部分已經很熟悉了，我就不再解釋。remoteClient.GetStream()方法獲取到了連接至客戶端的流，然後從流中讀出數據並保存在了buffer緩存中，隨後使用Encoding.Unicode.GetString()方法，從緩存中獲取到了實際的字符串。最後將字符串打印在了控制台上。這段代碼有個地方需要注意：在能夠讀取的字符串的總字節數大於BufferSize的時候會出現字符串截斷現象，因為緩存中的數目總是有限的，而對於大對象，比如說圖片或者其它文件來說，則必須采用“分次讀取然後轉存”這種方式，比如這樣：

// 獲取字符串
byte[] buffer = new byte[BufferSize];
int bytesRead;          // 讀取的字節數
MemoryStream msStream = new MemoryStream();
do {
    bytesRead = streamToClient.Read(buffer, 0, BufferSize);
    msStream.Write(buffer, 0, bytesRead);
} while (bytesRead > 0);

buffer = msStream.GetBuffer();
string msg = Encoding.Unicode.GetString(buffer);

這裡我沒有使用這種方法，一個是因為不想關注在太多的細節上面，一個是因為對於字符串來說，8192字節已經很多了，我們通常不會傳遞這麼多的文本。當使用Unicode編碼時，8192字節可以保存4096個漢字和英文字符。使用不同的編碼方式，占用的字節數有很大的差異，在本文最後面，有一段小程序，可以用來測試Unicode、UTF8、ASCII三種常用編碼方式對字符串編碼時，占用的字節數大小。

現在對客戶端不做任何修改，然後運行先運行服務端，再運行客戶端。結果我們會發現這樣一件事：服務端再打印完“Client Connected！127.0.0.1:8500 <-- 127.0.0.1:xxxxx”之後，再次被阻塞了，而沒有輸出“Reading data, {0} bytes ...”。可見，與AcceptTcpClient()方法類似，這個Read()方法也是同步的，只有當客戶端發送數據的時候，服務端才會讀取數據、運行此方法，否則它便會一直等待。