C# Windows Sockets (Winsock) 接口 (轉)

在.Net中，System.Net.Sockets 命名空間爲須要嚴密控制網絡訪問的開發人員提供了 Windows Sockets (Winsock) 接口的託管實現。System.Net 命名空間中的全部其餘網絡訪問類都創建在該套接字Socket實現之上，如TCPClient、TCPListener 和 UDPClient 類封裝有關建立到 Internet 的 TCP 和 UDP 鏈接的詳細信息；NetworkStream類則提供用於網絡訪問的基礎數據流等，常見的許多Internet服務均可以見到Socket的蹤跡，如Telnet、Http、Email、Echo等，這些服務儘管通信協議Protocol的定義不一樣，可是其基礎的傳輸都是採用的Socket。

其實，Socket能夠象流Stream同樣被視爲一個數據通道，這個通道架設在應用程序端（客戶端）和遠程服務器端之間，然後，數據的讀取（接收）和寫入（發送）均針對這個通道來進行。


可見，在應用程序端或者服務器端建立了Socket對象以後，就可使用Send/SentTo方法將數據發送到鏈接的Socket,或者使用Receive/ReceiveFrom方法接收來自鏈接Socket的數據；

針對Socket編程，.NET 框架的 Socket 類是 Winsock32 API 提供的套接字服務的託管代碼版本。其中爲實現網絡編程提供了大量的方法，大多數狀況下，Socket 類方法只是將數據封送到它們的本機 Win32 副本中並處理任何須要的安全檢查。若是你熟悉Winsock API函數，那麼用Socket類編寫網絡程序會很是容易，固然，若是你未曾接觸過，也不會太困難，跟隨下面的解說，你會發覺使用Socket類開發windows 網絡應用程序原來有規可尋，它們在大多數狀況下遵循大體相同的步驟。

在使用以前，你須要首先建立Socket對象的實例，這能夠經過Socket類的構造方法來實現：

public Socket(AddressFamily addressFamily,SocketType socketType,ProtocolType protocolType);


其中，addressFamily 參數指定 Socket 使用的尋址方案，socketType 參數指定 Socket 的類型，protocolType 參數指定 Socket 使用的協議。

下面的示例語句建立一個 Socket，它可用於在基於 TCP/IP 的網絡（如 Internet）上通信。

Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);


若要使用 UDP 而不是 TCP，須要更改協議類型，以下面的示例所示：

Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);


一旦建立 Socket，在客戶端，你將能夠經過Connect方法鏈接到指定的服務器，並經過Send/SendTo方法向遠程服務器發送數據，然後能夠經過Receive/ReceiveFrom從服務端接收數據；而在服務器端，你須要使用Bind方法綁定所指定的接口使Socket與一個本地終結點相聯，並經過Listen方法偵聽該接口上的請求，當偵聽到用戶端的鏈接時，調用Accept完成鏈接的操做，建立新的Socket以處理傳入的鏈接請求。使用完 Socket 後，記住使用 Shutdown 方法禁用 Socket，並使用 Close 方法關閉 Socket。其間用到的方法/函數有：

Socket.Connect方法:創建到遠程設備的鏈接
public void Connect(EndPoint remoteEP)（有重載方法）
Socket.Send 方法:從數據中的指示位置開始將數據發送到鏈接的 Socket。
public int Send(byte[], int, SocketFlags);(有重載方法)
Socket.SendTo 方法 將數據發送到特定終結點。
public int SendTo(byte[], EndPoint);（有重載方法）
Socket.Receive方法:將數據從鏈接的 Socket 接收到接收緩衝區的特定位置。
public int Receive(byte[],int,SocketFlags);
Socket.ReceiveFrom方法：接收數據緩衝區中特定位置的數據並存儲終結點。
public int ReceiveFrom(byte[], int, SocketFlags, ref EndPoint);
Socket.Bind 方法：使 Socket 與一個本地終結點相關聯：
public void Bind( EndPoint localEP );
Socket.Listen方法：將 Socket 置於偵聽狀態。
public void Listen( int backlog );
Socket.Accept方法:建立新的 Socket 以處理傳入的鏈接請求。
public Socket Accept();
Socket.Shutdown方法:禁用某 Socket 上的發送和接收
public void Shutdown( SocketShutdown how );
Socket.Close方法:強制 Socket 鏈接關閉
public void Close();


能夠看出，以上許多方法包含EndPoint類型的參數，在Internet中，TCP/IP 使用一個網絡地址和一個服務端口號來惟一標識設備。網絡地址標識網絡上的特定設備；端口號標識要鏈接到的該設備上的特定服務。網絡地址和服務端口的組合稱爲終結點，在 .NET 框架中正是由 EndPoint 類表示這個終結點，它提供表示網絡資源或服務的抽象，用以標誌網絡地址等信息。.Net同時也爲每一個受支持的地址族定義了 EndPoint 的子代；對於 IP 地址族，該類爲 IPEndPoint。IPEndPoint 類包含應用程序鏈接到主機上的服務所需的主機和端口信息，經過組合服務的主機IP地址和端口號，IPEndPoint 類造成到服務的鏈接點。

用到IPEndPoint類的時候就不可避免地涉及到計算機IP地址，.Net中有兩種類能夠獲得IP地址實例：

IPAddress類：IPAddress 類包含計算機在 IP 網絡上的地址。其Parse方法可將 IP 地址字符串轉換爲 IPAddress 實例。下面的語句建立一個 IPAddress 實例：

IPAddress myIP = IPAddress.Parse("192.168.1.2");


Dns 類：向使用 TCP/IP Internet 服務的應用程序提供域名服務。其Resolve 方法查詢 DNS 服務器以將用戶友好的域名（如"host.contoso.com"）映射到數字形式的 Internet 地址（如 192.168.1.1）。Resolve方法 返回一個 IPHostEnty 實例，該實例包含所請求名稱的地址和別名的列表。大多數狀況下，可使用 AddressList 數組中返回的第一個地址。下面的代碼獲取一個 IPAddress 實例，該實例包含服務器 host.contoso.com 的 IP 地址。

IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
IPAddress ipAddress = ipHostInfo.AddressList[0];


你也可使用GetHostName方法獲得IPHostEntry實例：

IPHosntEntry hostInfo=Dns.GetHostByName("host.contoso.com")


在使用以上方法時，你將可能須要處理如下幾種異常：

SocketException異常：訪問Socket時操做系統發生錯誤引起

ArgumentNullException異常：參數爲空引用引起

ObjectDisposedException異常：Socket已經關閉引起

在掌握上面得知識後，下面的代碼將該服務器主機（ host.contoso.com的 IP 地址與端口號組合，以便爲鏈接建立遠程終結點：

IPEndPoint ipe = new IPEndPoint(ipAddress,11000);


肯定了遠程設備的地址並選擇了用於鏈接的端口後，應用程序能夠嘗試創建與遠程設備的鏈接。下面的示例使用現有的 IPEndPoint 實例與遠程設備鏈接，並捕獲可能引起的異常：

try {
s.Connect(ipe);//嘗試鏈接
}
//處理參數爲空引用異常
catch(ArgumentNullException ae) {
Console.WriteLine("ArgumentNullException : {0}", ae.ToString());
}
//處理操做系統異常
catch(SocketException se) {
Console.WriteLine("SocketException : {0}", se.ToString());
}
catch(Exception e) {
Console.WriteLine("Unexpected exception : {0}", e.ToString());
}


須要知道的是：Socket 類支持兩種基本模式：同步和異步。其區別在於：在同步模式中，對執行網絡操做的函數（如 Send 和 Receive）的調用一直等到操做完成後纔將控制返回給調用程序。在異步模式中，這些調用當即返回。

另外，不少時候，Socket編程視狀況不一樣須要在客戶端和服務器端分別予以實現，在客戶端編制應用程序向服務端指定端口發送請求，同時編制服務端應用程序處理該請求，這個過程在上面的闡述中已經說起；固然，並不是全部的Socket編程都須要你嚴格編寫這兩端程序；視應用狀況不一樣，你能夠在客戶端構造出請求字符串，服務器相應端口捕獲這個請求，交由其公用服務程序進行處理。如下事例語句中的字符串就向遠程主機提出頁面請求：

string Get = "GET / HTTP/1.1\r\nHost: " + server + "\r\nConnection: Close\r\n\r\n";


遠程主機指定端口接受到這一請求後，就可利用其公用服務程序進行處理而不須要另行編制服務器端應用程序。

綜合運用以上闡述的使用Visual C#進行Socket網絡程序開發的知識，下面的程序段完整地實現了Web頁面下載功能。用戶只需在窗體上輸入遠程主機名（Dns 主機名或以點分隔的四部分表示法格式的 IP 地址）和預保存的本地文件名，並利用專門提供Http服務的80端口，就能夠獲取遠程主機頁面並保存在本地機指定文件中。若是保存格式是.htm格式，你就能夠在Internet瀏覽器中打開該頁面。適當添加代碼，你甚至能夠實現一個簡單的瀏覽器程序。


實現此功能的主要源代碼以下：

C# code

//"開始"按鈕事件 private void button1_Click(object sender, System.EventArgs e) { //取得預保存的文件名string fileName=textBox3.Text.Trim(); //遠程主機 string hostName=textBox1.Text.Trim(); //端口 intport=Int32.Parse(textBox2.Text.Trim()); //獲得主機信息 IPHostEntry ipInfo=Dns.GetHostByName(hostName); //取得IPAddress[] IPAddress[] ipAddr=ipInfo.AddressList; //獲得ip IPAddress ip=ipAddr[0]; //組合出遠程終結點 IPEndPoint hostEP=new IPEndPoint(ip,port); //建立Socket 實例 Socket socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp); try {//嘗試鏈接 socket.Connect(hostEP); } catch(Exception se) { MessageBox.Show("鏈接錯誤"+se.Message,"提示信息 ,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information); } //發送給遠程主機的請求內容串string sendStr="GET / HTTP/1.1\r\nHost: " + hostName + "\r\nConnection: Close\r\n\r\n"; //建立bytes字節數組以轉換髮送串 byte[] bytesSendStr=new byte[1024]; //將發送內容字符串轉換成字節byte數組bytesSendStr=Encoding.ASCII.GetBytes(sendStr); try { //向主機發送請求socket.Send(bytesSendStr,bytesSendStr.Length,0); } catch(Exception ce) { MessageBox.Show("發送錯誤:"+ce.Message,"提示信息 ,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information); } //聲明接收返回內容的字符串 string recvStr=""; //聲明字節數組，一次接收數據的長度爲1024字節 byte[] recvBytes=newbyte[1024]; //返回實際接收內容的字節數 int bytes=0; //循環讀取，直到接收完全部數據 while(true) { bytes=socket.Receive(recvBytes,recvBytes.Length,0); //讀取完成後退出循環 if(bytes<=0) break; //將讀取的字節數轉換爲字符串 recvStr+=Encoding.ASCII.GetString(recvBytes,0,bytes); } //將所讀取的字符串轉換爲字節數組 byte[] content=Encoding.ASCII.GetBytes(recvStr); try { //建立文件流對象實例 FileStream fs=newFileStream(fileName,FileMode.OpenOrCreate,FileAccess.ReadWrite); //寫入文件fs.Write(content,0,content.Length); } catch(Exception fe) { MessageBox.Show("文件建立/寫入錯誤:"+fe.Message,"提示信息",MessageBoxButtons.RetryCancel,MessageBoxIcon.Information); } //禁用Socket socket.Shutdown(SocketShutdown.Both); //關閉Socket socket.Close(); } }

程序在WindowsXP中文版、.Net Frameworkd 中文正式版、Visual Studio.Net中文正式版下調試經過

 

 

 

////////////////////////////////////////

 

 

  對於TCP的Socket編程，主要分二部分：
      1、服務端Socket偵聽：
      服務端Socket偵聽主要分如下幾個步驟，按照如下幾個步驟咱們能夠很方便的創建起一個Socket偵聽服務，來偵聽嘗試鏈接到該服務器的客戶Socket，從而創建起鏈接進行相關通信。
      一、建立IPEndPoint實例，用於Socket偵聽時綁定
         

1 IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 6001);

      二、建立套接字實例

1 //建立一個套接字
2             serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

  
      這裏建立的時候用ProtocolType.Tcp，表示創建一個面向鏈接(TCP)的Socket。

      三、將所建立的套接字與IPEndPoint綁定

1  //將所建立的套接字與IPEndPoint綁定
2             serverSocket.Bind(ipep);

      四、設置套接字爲收聽模式
 

1 //設置套接字爲收聽模式
2             serverSocket.Listen(10);

      以上這四步，咱們已經創建了Socket的偵聽模式，下面咱們就來設置怎麼樣來獲取客戶Socket鏈接的實例，以及鏈接後的信息發送。

      五、在套接字上接收接入的鏈接
  

 1 while (true)
 2              {
 3                try
 4                {
 5                    //在套接字上接收接入的鏈接
 6                    clientSocket = serverSocket.Accept();
 7                    clientThread = new Thread(new ThreadStart(ReceiveData));
 8                    clientThread.Start();
 9                }
10                catch (Exception ex)
11                {
12                    MessageBox.Show("listening Error: " + ex.Message);
13                }
14            }

      經過serverSocket.Accept()來接收客戶Socket的鏈接請求，在這裏用循環能夠實現該線程實時偵聽，而不是隻偵聽一次。當程序運行serverSocket.Accept()時，會等待，直到有客戶端Socket發起鏈接請求時，獲取該客戶Socket，如上面的clientSocket。在這裏我用多線程來實現與多個客戶端Socket的鏈接和通訊，一旦接收到一個鏈接後，就新建一個線程，執行ReceiveData功能來實現信息的發送和接收。

      六、 在套接字上接收客戶端發送的信息和發送信息

 1 private void ReceiveData()
 2          {
 3            bool keepalive = true;
 4            Socket s = clientSocket;
 5            Byte[] buffer = new Byte[1024];
 6
 7            //根據收聽到的客戶端套接字向客戶端發送信息
 8            IPEndPoint clientep = (IPEndPoint)s.RemoteEndPoint;
 9            lstServer.Items.Add("Client：" + clientep.Address + "("+clientep.Port+")");
10            string welcome = "Welcome to my test sever ";
11            byte[] data = new byte[1024];
12            data = Encoding.ASCII.GetBytes(welcome);
13            s.Send(data, data.Length, SocketFlags.None);
14
15            while (keepalive)
16            {
17                //在套接字上接收客戶端發送的信息
18                int bufLen = 0;
19                try
20                {
21                    bufLen = s.Available;
22
23                    s.Receive(buffer, 0, bufLen, SocketFlags.None);
24                    if (bufLen == 0)
25                        continue;
26                }
27                catch (Exception ex)
28                {
29                    MessageBox.Show("Receive Error:" + ex.Message);
30                    return;
31                }
32                clientep = (IPEndPoint)s.RemoteEndPoint;
33                string clientcommand = System.Text.Encoding.ASCII.GetString(buffer).Substring(0, bufLen);
34
35                lstServer.Items.Add(clientcommand + "("+clientep.Address + ":"+clientep.Port+")");
36
37            }
38            
39        }

 

      經過IPEndPoint clientep = (IPEndPoint)s.RemoteEndPoint;咱們能夠獲取鏈接上的遠程主機的端口和IP地址，若是想查詢該主機的其它屬性如主機名等，可用於上一篇講的Dns.GetHostByAddress(string ipAddress)來返回一個IPHostEntry對象，就能夠獲得。另外咱們要注意的是，經過Socket發送信息，必需要先把發送的信息轉化成二進字進行傳輸，收到信息後也要把收到的二進字信息轉化成字符形式，這裏能夠經過Encoding.ASCII.GetBytes(welcome);和Encoding.ASCII.GetString(buffer).Substring(0, bufLen);來實現。

      以上就是服務端Socket偵聽模式的實現，只要有遠程客戶端Socket鏈接上後，就能夠輕鬆的發送信息和接收信息了。下面咱們來看看客戶端Socket是怎麼鏈接上服務器的。

      2、客戶端鏈接

      客戶端Socket鏈接相對來講比較簡單了，另外說明一下，在執行客戶端鏈接前，服務端Socket偵聽必須先啓動，否則會提示服務器拒絕鏈接的信息。

      一、建立IPEndPoint實例和套接字

 

1  //建立一個套接字
2             IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 6001);
3             clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

      這個跟服務端Socket偵聽差很少，下面一步由服務端Socket的偵聽模式變成鏈接模式。

      二、將套接字鏈接到遠程服務器

 1 //將套接字與遠程服務器地址相連
 2             try
 3              {
 4                clientSocket.Connect(ipep);
 5            }
 6            catch (SocketException ex)
 7            {
 8                MessageBox.Show("connect error: " + ex.Message);
 9                return;
10            }

      前面已說明，若是在執行Socket鏈接時，服務器的Socket偵聽沒有開啓的話，會產生一個SocketException異常，若是沒有異常發生，那恭喜你，你已經與服務器鏈接上了，接下來就能夠跟服務器通訊了。
  
      三、接收信息

 1 while (true)
 2              {
 3                //接收服務器信息
 4                int bufLen = 0;
 5                try
 6                {
 7                    bufLen = clientSocket.Available;
 8
 9                    clientSocket.Receive(data, 0, bufLen, SocketFlags.None);
10                    if (bufLen == 0)
11                    {
12                        continue;
13                    }
14                }
15                catch (Exception ex)
16                {
17                    MessageBox.Show("Receive Error:" + ex.Message);
18                    return;
19                }
20
21                string clientcommand = System.Text.Encoding.ASCII.GetString(data).Substring(0, bufLen);
22
23                lstClient.Items.Add(clientcommand);
24
25            }

      四、發送信息

1 //向服務器發送信息
2           
3             byte[] data = new byte[1024];
4             data = Encoding.ASCII.GetBytes(txtClient.Text);
5             clientSocket.Send(data, data.Length, SocketFlags.None);

      客戶端的發送信息和接收信息跟服務器的接收發送是同樣的，只不過一個是偵聽模式而另外一個是鏈接模式。

      如下是程序的運行界面，這些在源碼下載裏均可以看到：

      一、服務端界面：
      
      
      二、客戶端界面：
      

      好了，關於面向鏈接的Socket就講到這裏了，以實例爲主，但願對那些派得上用場的朋友可以看得明白。另外提一下，這裏服務端開啓偵聽服務、客戶端鏈接服務端都採用線程方式來實現，這樣服務端可以跟多個客戶端同時通訊，不用等候，固然還有另一種方式能夠實現那就是異步socket，關於這些能夠搜索博客園上的相關文章，已經有好多了。

Stop talking and create the future !