C# 温故而知新：Stream篇（七）
C# 溫故而知新：Stream篇（七）
NetworkStream
目錄：
- NetworkStream的作用
- 簡單介紹下TCP/IP 協議和相關層次
- 簡單說明下 TCP和UDP的區(qū)別
- 簡單介紹下套接字（Socket）的概念
- 簡單介紹下TcpClient,TcpListener,IPEndPoint類的作用
- 使用NetworkStream的注意事項和局限性
- NetworkStream的構造
- NetworkStream的屬性
- NetworkStream的方法
- NetwrokStream的簡單示例
- ???????? ? 創(chuàng)建一個客戶端向服務端傳輸圖片的小示例
- 本章總結
?
?
?
1.NetworkStream的作用
和先前的流有所不同，NetworkStream 的特殊性可以在它的命名空間中得以了解（System.Net.Sockets）,聰明的你馬上會反應過來：
既然是在網絡中傳輸的流，那必然有某種協議或者規(guī)則約束它，不錯，這種協議便是Tcp/IP協議，這個是什么東東？別急，我先讓大家了
解下NetworkStream的作用：如果服務器和客戶端之間基于TCP連接的，他們之間能夠依靠一個穩(wěn)定的字節(jié)流進行相互傳輸信息，這也是
NetworkStream的最關鍵的作用，有了這個神奇的協議，NetWorkStream便能向其他流一樣在網絡中（進行點對點的傳輸），這種傳輸的
效率和速度是非常高的（UDP也很快，稍后再介紹）
如果大家對這個概念還不是很清晰的話，別怕，后文中我會更詳細的說明
| 這里有5點大家先理解就行 |
?
?
?
?
?
?
?
?
2.簡單介紹下TCP/IP 協議和相關層次
提到協議相信許多初學者或者沒搞過這塊的朋友會一頭霧水，
不過別怕，協議也是人定的，肯定能搞懂：
| 其實協議可以這么理解，是人為定制的為某個活動定義的一些列規(guī)則和約束， 就好比足球賽上的紅黃牌，這是由世界足聯定制的協議或者規(guī)范，一旦不按照這個協議 足球賽肯定會一片混亂 |
?
?
?
?
?
進入正題：
TCP/IP
全稱：Transmission Control Protocol/Internet Protocol （傳輸控制協議/因特網互聯協議，又名網絡通訊協議）
這個便是互聯網中的最基本的協議，Tcp/IP 定義了電子設備如何進入到互聯網，以及數據如何在網絡中傳遞。既然有了協議但是空頭支票
還是不行地，就好比足聯定制了這些規(guī)則，但是沒有裁判在球場上來實施這些規(guī)則一樣，Tcp/IP協議也有它自己的層次結構，關于它的層次
結構，大家看圖就能明白
?
?發(fā)送數據：
大家不用刻板的去理解這個協議，我還是用我們最普通的瀏覽網頁來讓大家理解下，首先打開瀏覽器輸入一個url,這時候應用層會判斷這個要求是否是http的
，然后http會將請求信息交給傳輸層來執(zhí)行，傳輸層主要負責信息流的格式化并且提供一個可靠地傳輸，這時候，TCP和UDP這兩個協議在這里起作用了，
TCP協議規(guī)定：接收端必須發(fā)回確認，并且假如分組丟失，必須重新發(fā)送，接著網絡層得到了這些需要發(fā)送的數據，（網絡中的IP協議非常重要，不僅是IP協議，
還有ARP協議（查找遠程主機MAC地址）），這時候網絡層會命令網絡接口層去發(fā)送這些信息（IP層主要負責的是在節(jié)點之間（End to End）的數據包傳送，
這里的節(jié)點是一臺網絡設備，比如計算機，大家便可理解為網絡接口層的設備），最終將請求數據發(fā)送至遠程網站主機后等待遠程主機發(fā)送來信息
??
接收數據：
?好了，遠程網站主機會根據請求信息（Ip,數據報等等）發(fā)送一些列的網頁數據通過網線或者無線路由，回到網絡接口層，然后逐級上報，通過網絡層的ip然后通過
傳輸層的一些列格式化，最終通過http返回至瀏覽器顯示網頁了
基于篇幅的關系，還有其他的協議大家可以自行去學習了解學習
喜歡足球的朋友的朋友也許會反應過來：這不是2-4-5陣型么？其實不然，很多協議我還沒畫上去，其實大致含義就是每個層次上的協議（足球隊員有他各自的職責），
這些才能構成計算機與計算機之間的傳輸信息的橋梁。相信園子里很多大牛都寫過http 協議，大家也可以去學習下
?
?3.簡單說明下 TCP和UDP的區(qū)別
TCP:
1 TCP是面向連接的通信協議，通過三次握手建立連接
2 TCP提供的是一種可靠的數據流服務，采用“帶重傳的肯定確認”技術來實現傳輸的可靠性
?
UDP:
1 UDP是面向無連接的通訊協議，UDP數據包括目的端口號和源端口號信息，由于通訊不需要連接，所以可以實現廣播發(fā)送
2 UDP通訊時不需要接收方確認，屬于不可靠的傳輸，可能會出丟包現象，實際應用中要求在程序員編程驗證
3 由于上述2點的關系，UDP傳輸速度更快，但是安全性比較差，很容易發(fā)生未知的錯誤，所以本章的NetworkStream無法使用在UDP的功能上
?
4.簡單介紹下套接字（Socket）的概念
關于Socket的概念和功能可能可以寫很長一篇博文來介紹，這里大家把Socket理解Tcp/IP協議的抽象，并且能夠實現Tcp/IP協議棧的工具就行，換句話說，我們可以
利用Socket實現客戶端和服務端雙向通信，同樣，對于Socket最關鍵的理解還沒到位，很多新人或者不常用的朋友會問：Socket到底功能是什么？怎么工作的？
再次舉個例子，女友打電話給我，我可以選擇連接，或者拒絕，如果我接了她的電話，也就是說，我和她通過電話連接（Connect），那電話就是“Socket”，女友和我
都可以是客戶端或服務端，只要點對點就行，我們的聲音通過電話傳遞，但是具體傳輸內容不歸Socket管轄范圍，Socket的直接任務可以歸納為以下幾點：
?
?
?
?
?
?
?
簡單的Socket示例代碼：
?點擊這里
?
5.簡單介紹下TcpClient,TcpListener,IPEndPoint類的作用
1: TcpClient
此類是微軟基于Tcp封裝類，用于簡化Tcp客戶端的開發(fā)，主要通過構造帶入主機地址或者IPEndPonint對象，然后調用Connect進行和服務器點對點的連接，連接成功后通
過GetStream方法返回NetworkStream對象
2: TcpListener
此類也是微軟基于Tcp封裝類，用于監(jiān)聽服務端或客戶端的連接請求，一旦有連接請求信息，立刻交給TcpClient的AcceptTcpClient方法捕獲，Start方法用于開始監(jiān)聽
3: IPEndPonint
處理IP地址和端口的封裝類
4:IPAddress
提供包含計算機在 IP 網絡上的地址的工具類
?
?
6．使用NetworkStream的注意事項和局限性
抱歉到目前為止才開始介紹NetworkStream,我相信大家到這里在回過頭去看第一節(jié)的作用時能夠更多的領悟。前五節(jié)意在說明下NetworkStream背后那個必須掌握的知識點，
這樣才能在實際編程過程中很快上手，畢竟NetworkStream的工作環(huán)境和其他流有著很大的差別，
再回到第一節(jié)關于NetworkStream的知識點，在使用時有幾點必須注意
首先
1 再次強調NetworkStream是穩(wěn)定的，面向連接的，所以它只適合TCP協議的環(huán)境下工作
所以一旦在UDP環(huán)境中，雖然編譯不會報錯，但是會跳出異常
2 我們可以通過NetworkStream簡化Socket開發(fā)
3 如果要建立NetworkStream一個新的實例，則必須使用已經連接的Socket
4 NetworkStream 使用后不會自動關閉提供的socket，必須使用NetworkStream構造函數時指定Socket所有權（NetworkStream 的構造函數中設置）。
6 NetworkStream支持異步讀寫操作
NetworkStream的局限性
?
?
7．NetworkStream的構造
1.NetworkStream (Socket) ?為指定的 Socket 創(chuàng)建 NetworkStream 類的新實例
2.NetworkStream (Socket, Boolean ownsSocket) ?用指定的 Socket 所屬權為指定的 Socket
ownsSocket表示指示NetworkStream是否擁有該Socket
3.NetworkStream (Socket, FileAccess) ?用指定的訪問權限為指定的 Socket 創(chuàng)建
FileAccess 值的按位組合，這些值指定授予所提供的 Socket 上的 NetworkStream 的訪問類型
4.NetworkStream (Socket, FileAccess, Boolean ownsSocket) 。
| 對于NetworkStream構造函數的理解相信大家經過前文的解釋也能夠掌握了，但是有幾點 必須強調下 1如果用構造產生NetworkStream的實例，則必須使用連接的Socket 2 如果該NetworkStream擁有對Socket的所有權，則在使用NetworkStream的Close方法時會同時關閉Socket, 否則關閉NetworkStream時不會關閉Socket 3, 能夠創(chuàng)建對指定Socket帶有讀寫權限的NetworkStream |
?
?
?
?
?
?
?
?
?
?
8．NetworkStream的屬性
1. CanSeek :用于指示流是否支持查找，它的值始終為 false
2. DataAvailable 指示在要讀取的 NetworkStream 上是否有可用的數據。一般來說通過判斷這個屬性來判斷NetworkStream中是否有數據
3. Length:NetworkStream不支持使用Length屬性，強行使用會發(fā)生NotSupportedException異常
4.Position: NetworkStream不支持使用Position屬性，強行使用會發(fā)生NotSupportedException異常
?
9．NetworkStream的方法
同樣，NetworkStream的方法大致重寫或繼承了Stream的方法
但是以下方法必須注意：
1 int Read(byte[] buffer,int offset,int size)
該方法將數據讀入 buffer 參數并返回成功讀取的字節(jié)數。如果沒有可以讀取的數據，則 Read 方法返回 0。Read 操作將讀取盡可能多的可用數據，
直至達到由 size 參數指定的字節(jié)數為止。如果遠程主機關閉了連接并且已接收到所有可用數據，Read 方法將立即完成并返回零字節(jié)。
2 long Seek(long offset, SeekOrigin origin)
將流的當前位置設置為給定值。此方法當前不受支持，總是引發(fā) NotSupportedException。
3 ?void Write(byte[] buffer, int offset,int size)
Write方法在指定的 offset 處啟動，并將 buffer 內容中的 size 字節(jié)發(fā)送到網絡。Write 方法將一直處于阻止狀態(tài)(可以用異步解決)，直到發(fā)送了請求
的字節(jié)數或引發(fā) SocketException 為止。如果收到 SocketException，可以使用 SocketException.ErrorCode 屬性獲取特定的錯誤代碼。
?
10．NetworkStream的簡單示例
創(chuàng)建一個客戶端向服務端傳輸圖片的小示例
服務端一直監(jiān)聽客戶端傳來的圖片信息
/// <summary>/// 服務端監(jiān)聽客戶端信息，一旦有發(fā)送過來的信息，便立即處理/// </summary>class Program{//全局TcpClientstatic TcpClient client;//文件流建立到磁盤上的讀寫流static FileStream fs = new FileStream("E:\\abc.jpg", FileMode.Create);//bufferstatic int bufferlength = 200;static byte[] buffer = new byte[bufferlength];//網絡流static NetworkStream ns;static void Main(string[] args){ConnectAndListen();}static void ConnectAndListen() {//服務端監(jiān)聽任何IP 但是端口號是80的連接TcpListener listener = new TcpListener(IPAddress.Any,80);//監(jiān)聽對象開始監(jiān)聽 listener.Start();while(true){Console.WriteLine("等待連接");//線程會掛在這里，直到客戶端發(fā)來連接請求client = listener.AcceptTcpClient();Console.WriteLine("已經連接");//得到從客戶端傳來的網絡流ns = client.GetStream();//如果網絡流中有數據if (ns.DataAvailable){//同步讀取網絡流中的byte信息// do// {// ns.Read(buffer, 0, bufferlength);//} while (readLength > 0);//異步讀取網絡流中的byte信息ns.BeginRead(buffer, 0, bufferlength, ReadAsyncCallBack, null);}}}/// <summary>/// 異步讀取/// </summary>/// <param name="result"></param>static void ReadAsyncCallBack(IAsyncResult result) {int readCount;//獲得每次異步讀取數量readCount = client.GetStream().EndRead(result);//如果全部讀完退出，垃圾回收if (readCount < 1) {client.Close();ns.Dispose();fs.Dispose();return; }//將網絡流中的圖片數據片段順序寫入本地fs.Write(buffer, 0, 200);//再次異步讀取ns.BeginRead(buffer, 0, 200, ReadAsyncCallBack, null);}}?客戶端先連接上服務端后在發(fā)送圖片，注意如果是雙向通信的話最好將客戶端和服務端的項目設置為多個啟動項便于調試
class Program{/// <summary>/// 客戶端/// </summary>/// <param name="args"></param>static void Main(string[] args){SendImageToServer("xxx.jpg");} static void SendImageToServer(string imgURl){if (!File.Exists(imgURl)) return;//創(chuàng)建一個文件流打開圖片FileStream fs = File.Open(imgURl, FileMode.Open);//聲明一個byte數組接受圖片byte信息byte[] fileBytes = new byte[fs.Length];using (fs){//將圖片byte信息讀入byte數組中fs.Read(fileBytes, 0, fileBytes.Length);fs.Close();}//找到服務器的IP地址IPAddress address = IPAddress.Parse("127.0.0.1");//創(chuàng)建TcpClient對象實現與服務器的連接TcpClient client = new TcpClient();//連接服務器client.Connect(address, 80);using (client){//連接完服務器后便在客戶端和服務端之間產生一個流的通道NetworkStream ns = client.GetStream();using (ns){//通過此通道將圖片數據寫入網絡流，傳向服務器端接收ns.Write(fileBytes, 0, fileBytes.Length);}}}}
附件：?關于Socket的一個簡單示例
服務器端建立服務并且循環(huán)監(jiān)聽?
View Code const int PORT = 80;static Socket clientSocket;static Socket client;static void Main(string[] args){Thread thread=new Thread(new ThreadStart(SetUpBlockServer));thread.Start();}/// <summary>/// 服務器端建立服務并且循環(huán)監(jiān)聽/// </summary>static void SetUpBlockServer() {//同樣建立TcpListener 監(jiān)聽對象監(jiān)聽客戶端傳來的信息TcpListener lis = new TcpListener(IPAddress.Any, PORT);Console.WriteLine("正在監(jiān)聽任何端口號為80的任意IP的連接");//啟動監(jiān)聽 lis.Start();while (true) {//進程會掛起，知道客戶端的socket發(fā)送連接請求clientSocket = lis.AcceptSocket();Console.WriteLine("{0}時刻接收到客戶端的連接請求",DateTime.Now.ToString("G"));//連接成功后發(fā)送給客戶端信息string testMessage = "連接成功";clientSocket.Send(Encoding.Default.GetBytes(testMessage));}}?客戶端連接服務端的請求，和循環(huán)監(jiān)聽服務端傳來的信息
View Code class Program{//端口const int PORT = 80;static void Main(string[] args){Connect("127.0.0.1");}/// <summary>/// 建立與服務器端的異步連接/// </summary>/// <param name="server"></param>static void Connect(string server) {//建立一個socket用來和服務的Socket進行通信Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//獲得服務器IP地址IPAddress ipAddress = IPAddress.Parse(server);//獲得服務器端口IPEndPoint point = new IPEndPoint(ipAddress, PORT);//開始異步連接，注意將socket放入異步方法的參數中，提供給回調方法使用socket.BeginConnect(point, new AsyncCallback(ConnectCallBack), socket);Thread.Sleep(10000000);}/// <summary>///異步連接后的callback事件/// </summary>/// <param name="result"></param>static void ConnectCallBack(IAsyncResult result) {try{//建立一個接受信息的byte數組byte[] receiveBuffer = new byte[4098];//從回調參數中獲取上面Conntect方法中的socket對象Socket socket = result.AsyncState as Socket;//判斷是否和服務端的socket建立連接if (socket.Connected){//開始 異步接收服務端傳來的信息，同樣將socket傳入回調方法的參數中socket.BeginReceive(receiveBuffer, 0, receiveBuffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallBack), socket);}else { ConnectCallBack(result); }}catch {Console.WriteLine("連接出錯");}}/// <summary>/// 一旦服務器發(fā)送信息，則會觸發(fā)回調方法/// </summary>/// <param name="result"></param>static void ReceiveCallBack(IAsyncResult result) {byte[] receiveBuffer = new byte[4098];Socket socket = result.AsyncState as Socket;//讀取從服務器端傳來的數據，EndReceive是關閉異步接收方法，同時讀取數據int count = socket.EndReceive(result);if (count > 0) {try{//接受完服務端的數據后的邏輯 }catch {}}// 遞歸監(jiān)聽服務器端是否發(fā)來信息，一旦服務器再次發(fā)送信息，客戶端仍然可以接收到socket.BeginReceive(receiveBuffer, 0, receiveBuffer.Length, SocketFlags.None, ReceiveCallBack,socket);}}?
本章總結
?本章簡單介紹了關于NetworkStream以及其周邊的一些衍生知識，這些知識的重要性不言而喻，從Tcp/IP協議到期分層結構，
? Socket和NetworkStream 的關系和注意事項，以及Socket在Tcp/IP協議中的角色等等，不知不覺Stream篇快接近于尾聲了
? 期間感謝大家的關注，今后我會寫新的系列，請大家多多鼓勵
?
?
?
?
轉載于:https://www.cnblogs.com/JimmyZheng/archive/2012/05/17/2502727.html
總結
以上是生活随笔為你收集整理的C# 温故而知新：Stream篇（七）的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： SQL Server聚集索引的选择
- 下一篇： C#委托之就是跟委托过不去…