C# Socket

??? Microsoft.Net Framework為應(yīng)用程序訪問(wèn)Internet提供了分層的、可擴(kuò)展的以及受管轄的網(wǎng)絡(luò)服務(wù)，其名字空間System.Net和System.Net.Sockets包含豐富的類可以開(kāi)發(fā)多種網(wǎng)絡(luò)應(yīng)用程序。.Net類采用的分層結(jié)構(gòu)允許應(yīng)用程序在不同的控制級(jí)別上訪問(wèn)網(wǎng)絡(luò)，開(kāi)發(fā)人員可以根據(jù)需要選擇針對(duì)不同的級(jí)別編制程序，這些級(jí)別幾乎囊括了Internet的所有需要--從socket套接字到普通的請(qǐng)求/響應(yīng)，更重要的是，這種分層是可以擴(kuò)展的，能夠適應(yīng)Internet不斷擴(kuò)展的需要。
??
??拋開(kāi)ISO/OSI模型的7層構(gòu)架，單從TCP/IP模型上的邏輯層面上看，.Net類可以視為包含3個(gè)層次：請(qǐng)求/響應(yīng)層、應(yīng)用協(xié)議層、傳輸層。WebReqeust和WebResponse 代表了請(qǐng)求/響應(yīng)層，支持Http、Tcp和Udp的類組成了應(yīng)用協(xié)議層，而Socket類處于傳輸層。可以如下示意：?
?

可見(jiàn)，傳輸層位于這個(gè)結(jié)構(gòu)的最底層，當(dāng)其上面的應(yīng)用協(xié)議層和請(qǐng)求/響應(yīng)層不能滿足應(yīng)用程序的特殊需要時(shí)，就需要使用這一層進(jìn)行Socket套接字編程。
??
??而在.Net中，System.Net.Sockets 命名空間為需要嚴(yán)密控制網(wǎng)絡(luò)訪問(wèn)的開(kāi)發(fā)人員提供了 Windows Sockets (Winsock) 接口的托管實(shí)現(xiàn)。System.Net 命名空間中的所有其他網(wǎng)絡(luò)訪問(wèn)類都建立在該套接字Socket實(shí)現(xiàn)之上，如TCPClient、TCPListener 和 UDPClient 類封裝有關(guān)創(chuàng)建到 Internet 的 TCP 和 UDP 連接的詳細(xì)信息；NetworkStream類則提供用于網(wǎng)絡(luò)訪問(wèn)的基礎(chǔ)數(shù)據(jù)流等，常見(jiàn)的許多Internet服務(wù)都可以見(jiàn)到Socket的蹤影，如Telnet、Http、Email、Echo等，這些服務(wù)盡管通訊協(xié)議Protocol的定義不同，但是其基礎(chǔ)的傳輸都是采用的Socket。
??
??其實(shí)，Socket可以象流Stream一樣被視為一個(gè)數(shù)據(jù)通道，這個(gè)通道架設(shè)在應(yīng)用程序端（客戶端）和遠(yuǎn)程服務(wù)器端之間，而后，數(shù)據(jù)的讀取（接收）和寫入（發(fā)送）均針對(duì)這個(gè)通道來(lái)進(jìn)行。

??可見(jiàn)，在應(yīng)用程序端或者服務(wù)器端創(chuàng)建了Socket對(duì)象之后，就可以使用Send/SentTo方法將數(shù)據(jù)發(fā)送到連接的Socket,或者使用Receive/ReceiveFrom方法接收來(lái)自連接Socket的數(shù)據(jù)；
??
??針對(duì)Socket編程，.NET 框架的 Socket 類是 Winsock32 API 提供的套接字服務(wù)的托管代碼版本。其中為實(shí)現(xiàn)網(wǎng)絡(luò)編程提供了大量的方法，大多數(shù)情況下，Socket 類方法只是將數(shù)據(jù)封送到它們的本機(jī) Win32 副本中并處理任何必要的安全檢查。如果你熟悉Winsock API函數(shù)，那么用Socket類編寫網(wǎng)絡(luò)程序會(huì)非常容易，當(dāng)然，如果你不曾接觸過(guò)，也不會(huì)太困難，跟隨下面的解說(shuō)，你會(huì)發(fā)覺(jué)使用Socket類開(kāi)發(fā)windows 網(wǎng)絡(luò)應(yīng)用程序原來(lái)有規(guī)可尋，它們?cè)诖蠖鄶?shù)情況下遵循大致相同的步驟。
??
??在使用之前，你需要首先創(chuàng)建Socket對(duì)象的實(shí)例，這可以通過(guò)Socket類的構(gòu)造方法來(lái)實(shí)現(xiàn)：
??
??public Socket(AddressFamily addressFamily,SocketType socketType,ProtocolType protocolType);
??
??
??其中，addressFamily 參數(shù)指定 Socket 使用的尋址方案，socketType 參數(shù)指定 Socket 的類型，protocolType 參數(shù)指定 Socket 使用的協(xié)議。
??
??下面的示例語(yǔ)句創(chuàng)建一個(gè) Socket，它可用于在基于 TCP/IP 的網(wǎng)絡(luò)（如 Internet）上通訊。
??
??Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
??
??
??若要使用 UDP 而不是 TCP，需要更改協(xié)議類型，如下面的示例所示：
??
??Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
??
??
??一旦創(chuàng)建 Socket，在客戶端，你將可以通過(guò)Connect方法連接到指定的服務(wù)器，并通過(guò)Send/SendTo方法向遠(yuǎn)程服務(wù)器發(fā)送數(shù)據(jù)，而后可以通過(guò)Receive/ReceiveFrom從服務(wù)端接收數(shù)據(jù)；而在服務(wù)器端，你需要使用Bind方法綁定所指定的接口使Socket與一個(gè)本地終結(jié)點(diǎn)相聯(lián)，并通過(guò)Listen方法偵聽(tīng)該接口上的請(qǐng)求，當(dāng)偵聽(tīng)到用戶端的連接時(shí)，調(diào)用Accept完成連接的操作，創(chuàng)建新的Socket以處理傳入的連接請(qǐng)求。使用完 Socket 后，記住使用 Shutdown 方法禁用 Socket，并使用 Close 方法關(guān)閉 Socket。其間用到的方法/函數(shù)有：
??
??Socket.Connect方法:建立到遠(yuǎn)程設(shè)備的連接
??public void Connect(EndPoint remoteEP)（有重載方法）
??Socket.Send 方法:從數(shù)據(jù)中的指示位置開(kāi)始將數(shù)據(jù)發(fā)送到連接的 Socket。
??public int Send(byte[], int, SocketFlags);(有重載方法)
??Socket.SendTo 方法 將數(shù)據(jù)發(fā)送到特定終結(jié)點(diǎn)。
??public int SendTo(byte[], EndPoint);（有重載方法）
??Socket.Receive方法:將數(shù)據(jù)從連接的 Socket 接收到接收緩沖區(qū)的特定位置。
??public int Receive(byte[],int,SocketFlags);
??Socket.ReceiveFrom方法：接收數(shù)據(jù)緩沖區(qū)中特定位置的數(shù)據(jù)并存儲(chǔ)終結(jié)點(diǎn)。
??public int ReceiveFrom(byte[], int, SocketFlags, ref EndPoint);
??Socket.Bind 方法：使 Socket 與一個(gè)本地終結(jié)點(diǎn)相關(guān)聯(lián)：
??public void Bind( EndPoint localEP );
??Socket.Listen方法：將 Socket 置于偵聽(tīng)狀態(tài)。
??public void Listen( int backlog );
??Socket.Accept方法:創(chuàng)建新的 Socket 以處理傳入的連接請(qǐng)求。
??public Socket Accept();
??Socket.Shutdown方法:禁用某 Socket 上的發(fā)送和接收
??public void Shutdown( SocketShutdown how );
??Socket.Close方法:強(qiáng)制 Socket 連接關(guān)閉
??public void Close();
??
??
??可以看出，以上許多方法包含EndPoint類型的參數(shù)，在Internet中，TCP/IP 使用一個(gè)網(wǎng)絡(luò)地址和一個(gè)服務(wù)端口號(hào)來(lái)唯一標(biāo)識(shí)設(shè)備。網(wǎng)絡(luò)地址標(biāo)識(shí)網(wǎng)絡(luò)上的特定設(shè)備；端口號(hào)標(biāo)識(shí)要連接到的該設(shè)備上的特定服務(wù)。網(wǎng)絡(luò)地址和服務(wù)端口的組合稱為終結(jié)點(diǎn)，在 .NET 框架中正是由 EndPoint 類表示這個(gè)終結(jié)點(diǎn)，它提供表示網(wǎng)絡(luò)資源或服務(wù)的抽象，用以標(biāo)志網(wǎng)絡(luò)地址等信息。.Net同時(shí)也為每個(gè)受支持的地址族定義了 EndPoint 的子代；對(duì)于 IP 地址族，該類為 IPEndPoint。IPEndPoint 類包含應(yīng)用程序連接到主機(jī)上的服務(wù)所需的主機(jī)和端口信息，通過(guò)組合服務(wù)的主機(jī)IP地址和端口號(hào)，IPEndPoint 類形成到服務(wù)的連接點(diǎn)。
??
??用到IPEndPoint類的時(shí)候就不可避免地涉及到計(jì)算機(jī)IP地址，.Net中有兩種類可以得到IP地址實(shí)例：
??
??IPAddress類：IPAddress 類包含計(jì)算機(jī)在 IP 網(wǎng)絡(luò)上的地址。其Parse方法可將 IP 地址字符串轉(zhuǎn)換為 IPAddress 實(shí)例。下面的語(yǔ)句創(chuàng)建一個(gè) IPAddress 實(shí)例：
??
??IPAddress myIP = IPAddress.Parse("192.168.1.2");
??
??
??Dns 類：向使用 TCP/IP Internet 服務(wù)的應(yīng)用程序提供域名服務(wù)。其Resolve 方法查詢 DNS 服務(wù)器以將用戶友好的域名（如"host.contoso.com"）映射到數(shù)字形式的 Internet 地址（如 192.168.1.1）。Resolve方法 返回一個(gè) IPHostEnty 實(shí)例，該實(shí)例包含所請(qǐng)求名稱的地址和別名的列表。大多數(shù)情況下，可以使用 AddressList 數(shù)組中返回的第一個(gè)地址。下面的代碼獲取一個(gè) IPAddress 實(shí)例，該實(shí)例包含服務(wù)器 host.contoso.com 的 IP 地址。
??
??IPHostEntry ipHostInfo = Dns.Resolve("host.contoso.com");
??IPAddress ipAddress = ipHostInfo.AddressList[0];
??
??
??你也可以使用GetHostName方法得到IPHostEntry實(shí)例：
??
??IPHosntEntry hostInfo=Dns.GetHostByName("host.contoso.com")
??
??
??在使用以上方法時(shí)，你將可能需要處理以下幾種異常：
??
??SocketException異常：訪問(wèn)Socket時(shí)操作系統(tǒng)發(fā)生錯(cuò)誤引發(fā)
??
??ArgumentNullException異常：參數(shù)為空引用引發(fā)
??
??ObjectDisposedException異常：Socket已經(jīng)關(guān)閉引發(fā)
??
??在掌握上面得知識(shí)后，下面的代碼將該服務(wù)器主機(jī)（ host.contoso.com的 IP 地址與端口號(hào)組合，以便為連接創(chuàng)建遠(yuǎn)程終結(jié)點(diǎn)：
??
??IPEndPoint ipe = new IPEndPoint(ipAddress,11000);
??
??
??確定了遠(yuǎn)程設(shè)備的地址并選擇了用于連接的端口后，應(yīng)用程序可以嘗試建立與遠(yuǎn)程設(shè)備的連接。下面的示例使用現(xiàn)有的 IPEndPoint 實(shí)例與遠(yuǎn)程設(shè)備連接，并捕獲可能引發(fā)的異常：
??
??try {
?? s.Connect(ipe);//嘗試連接
??}
??//處理參數(shù)為空引用異常
?? catch(ArgumentNullException ae) {
?? Console.WriteLine("ArgumentNullException : {0}", ae.ToString());
??}
??//處理操作系統(tǒng)異常
?? catch(SocketException se) {
?? Console.WriteLine("SocketException : {0}", se.ToString());
??}
?? catch(Exception e) {
?? Console.WriteLine("Unexpected exception : {0}", e.ToString());
??}
??
??
??需要知道的是：Socket 類支持兩種基本模式：同步和異步。其區(qū)別在于：在同步模式中，對(duì)執(zhí)行網(wǎng)絡(luò)操作的函數(shù)（如 Send 和 Receive）的調(diào)用一直等到操作完成后才將控制返回給調(diào)用程序。在異步模式中，這些調(diào)用立即返回。
??
??另外，很多時(shí)候，Socket編程視情況不同需要在客戶端和服務(wù)器端分別予以實(shí)現(xiàn)，在客戶端編制應(yīng)用程序向服務(wù)端指定端口發(fā)送請(qǐng)求，同時(shí)編制服務(wù)端應(yīng)用程序處理該請(qǐng)求，這個(gè)過(guò)程在上面的闡述中已經(jīng)提及；當(dāng)然，并非所有的Socket編程都需要你嚴(yán)格編寫這兩端程序；視應(yīng)用情況不同，你可以在客戶端構(gòu)造出請(qǐng)求字符串，服務(wù)器相應(yīng)端口捕獲這個(gè)請(qǐng)求，交由其公用服務(wù)程序進(jìn)行處理。以下事例語(yǔ)句中的字符串就向遠(yuǎn)程主機(jī)提出頁(yè)面請(qǐng)求：
??
??string Get = "GET / HTTP/1.1\r\nHost: " + server + "\r\nConnection: Close\r\n\r\n";
??
??
??遠(yuǎn)程主機(jī)指定端口接受到這一請(qǐng)求后，就可利用其公用服務(wù)程序進(jìn)行處理而不需要另行編制服務(wù)器端應(yīng)用程序。
??
??綜合運(yùn)用以上闡述的使用Visual C#進(jìn)行Socket網(wǎng)絡(luò)程序開(kāi)發(fā)的知識(shí)，下面的程序段完整地實(shí)現(xiàn)了Web頁(yè)面下載功能。用戶只需在窗體上輸入遠(yuǎn)程主機(jī)名（Dns 主機(jī)名或以點(diǎn)分隔的四部分表示法格式的 IP 地址）和預(yù)保存的本地文件名，并利用專門提供Http服務(wù)的80端口，就可以獲取遠(yuǎn)程主機(jī)頁(yè)面并保存在本地機(jī)指定文件中。如果保存格式是.htm格式，你就可以在Internet瀏覽器中打開(kāi)該頁(yè)面。適當(dāng)添加代碼，你甚至可以實(shí)現(xiàn)一個(gè)簡(jiǎn)單的瀏覽器程序。?
??

實(shí)現(xiàn)此功能的主要源代碼如下：
??
??//"開(kāi)始"按鈕事件
??private void button1_Click(object sender, System.EventArgs e) {
?? //取得預(yù)保存的文件名
?? string fileName=textBox3.Text.Trim();
?? //遠(yuǎn)程主機(jī)
?? string hostName=textBox1.Text.Trim();
?? //端口
?? int port=Int32.Parse(textBox2.Text.Trim());
?? //得到主機(jī)信息
?? IPHostEntry ipInfo=Dns.GetHostByName(hostName);
?? //取得IPAddress[]
?? IPAddress[] ipAddr=ipInfo.AddressList;
?? //得到ip
?? IPAddress ip=ipAddr[0];
?? //組合出遠(yuǎn)程終結(jié)點(diǎn)
?? IPEndPoint hostEP=new IPEndPoint(ip,port);
?? //創(chuàng)建Socket 實(shí)例
?? Socket socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
?? try
?? {
?? //嘗試連接
?? socket.Connect(hostEP);
?? }
?? catch(Exception se)
?? {
?? MessageBox.Show("連接錯(cuò)誤"+se.Message,"提示信息
?? ,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information);
??}
??//發(fā)送給遠(yuǎn)程主機(jī)的請(qǐng)求內(nèi)容串
??string sendStr="GET / HTTP/1.1\r\nHost: " + hostName +
??"\r\nConnection: Close\r\n\r\n";
?? //創(chuàng)建bytes字節(jié)數(shù)組以轉(zhuǎn)換發(fā)送串
?? byte[] bytesSendStr=new byte[1024];
?? //將發(fā)送內(nèi)容字符串轉(zhuǎn)換成字節(jié)byte數(shù)組
?? bytesSendStr=Encoding.ASCII.GetBytes(sendStr);
??try
??{
??//向主機(jī)發(fā)送請(qǐng)求
??socket.Send(bytesSendStr,bytesSendStr.Length,0);
??}
??catch(Exception ce)
?? {
?? MessageBox.Show("發(fā)送錯(cuò)誤:"+ce.Message,"提示信息
?? ,MessageBoxButtons.RetryCancel,MessageBoxIcon.Information);
?? }
?? //聲明接收返回內(nèi)容的字符串
?? string recvStr="";
?? //聲明字節(jié)數(shù)組，一次接收數(shù)據(jù)的長(zhǎng)度為1024字節(jié)
?? byte[] recvBytes=new byte[1024];
?? //返回實(shí)際接收內(nèi)容的字節(jié)數(shù)
?? int bytes=0;
??//循環(huán)讀取，直到接收完所有數(shù)據(jù)
??while(true)
??{
??bytes=socket.Receive(recvBytes,recvBytes.Length,0);
??//讀取完成后退出循環(huán)
??if(bytes<=0)
??break;
??//將讀取的字節(jié)數(shù)轉(zhuǎn)換為字符串
??recvStr+=Encoding.ASCII.GetString(recvBytes,0,bytes);
??}
??//將所讀取的字符串轉(zhuǎn)換為字節(jié)數(shù)組
??byte[] content=Encoding.ASCII.GetBytes(recvStr);
?? try
?? {
?? //創(chuàng)建文件流對(duì)象實(shí)例
?? FileStream fs=new FileStream(fileName,FileMode.OpenOrCreate,FileAccess.ReadWrite);
??//寫入文件
??fs.Write(content,0,content.Length);
??}
??catch(Exception fe)
?? {
?? MessageBox.Show("文件創(chuàng)建/寫入錯(cuò)誤:"+fe.Message,"提示信息",MessageBoxButtons.RetryCancel,MessageBoxIcon.Information);
?? }
?? //禁用Socket
?? socket.Shutdown(SocketShutdown.Both);
?? //關(guān)閉Socket
?? socket.Close();
?? }
?? }
??
??
??程序在WindowsXP中文版、.Net Frameworkd 中文正式版、Visual Studio.Net中文正式版下調(diào)試通過(guò)
+++++++++++++++++++++++++++
C#的Socket程序（TCP）

其實(shí)只要用到Socket聯(lián)接，基本上就得使用Thread，是交叉使用的。
C#封裝的Socket用法基本上不算很復(fù)雜，只是不知道托管之后的Socket有沒(méi)有其他性能或者安全上的問(wèn)題。
在C#里面能找到的最底層的操作也就是socket了，概念不做解釋。
程序模型如下：
WinForm程序 ： 啟動(dòng)端口偵聽(tīng)；監(jiān)視Socket聯(lián)接情況；定期關(guān)閉不活動(dòng)的聯(lián)接；
Listener：處理Socket的Accept函數(shù)，偵聽(tīng)新鏈接，建立新Thread來(lái)處理這些聯(lián)接（Connection）。
Connection：處理具體的每一個(gè)聯(lián)接的會(huì)話。

1：WinForm如何啟動(dòng)一個(gè)新的線程來(lái)啟動(dòng)Listener：
?????? //start the server
??????? private void btn_startServer_Click(object sender, EventArgs e)
??????? {
??????????? //this.btn_startServer.Enabled = false;
??????????? Thread _createServer = new Thread(new ThreadStart(WaitForConnect));
??????????? _createServer.Start();
??????? }
??????? //wait all connections
??????? private void WaitForConnect()
??????? {
??????????? SocketListener listener = new SocketListener(Convert.ToInt32(this.txt_port.Text));
???????????? listener.StartListening();
??????? }
因?yàn)閭陕?tīng)聯(lián)接是一個(gè)循環(huán)等待的函數(shù)，所以不可能在WinForm的線程里面直接執(zhí)行，不然Winform也就是無(wú)法繼續(xù)任何操作了，所以才指定一個(gè)新的線程來(lái)執(zhí)行這個(gè)函數(shù)，啟動(dòng)偵聽(tīng)循環(huán)。
這一個(gè)新的線程是比較簡(jiǎn)單的，基本上沒(méi)有啟動(dòng)的參數(shù)，直接指定處理函數(shù)就可以了。
2：Listener如何啟動(dòng)循環(huán)偵聽(tīng)，并且啟動(dòng)新的帶有參數(shù)的線程來(lái)處理Socket聯(lián)接會(huì)話。
先看如何建立偵聽(tīng)：（StartListening函數(shù)）
IPEndPoint localEndPoint = new IPEndPoint(_ipAddress, _port);
??????? // Create a TCP/IP socket.
??????? Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
??????????? // Bind the socket to the local endpoint and? listen for incoming connections.
??????????? try
??????????? {
??????????????? listener.Bind(localEndPoint);
??????????????? listener.Listen(20);//20 trucks

??????????????? // Start listening for connections.
??????????????? while (true)
??????????????? {
?????????????????? // here will be suspended while waiting for a new connection.
??????????????????? Socket connection = listener.Accept();
??????????????????? Logger.Log("Connect", connection.RemoteEndPoint.ToString());//log it, new connection
??????????????? ……
?????????? }
???????? }……
基本步驟比較簡(jiǎn)單：
建立本機(jī)的IPEndPoint對(duì)象，表示以本機(jī)為服務(wù)器，在指定端口偵聽(tīng)；
然后綁定到一個(gè)偵聽(tīng)Socket上；
進(jìn)入while循環(huán)，等待新的聯(lián)接；
如果有新的聯(lián)接，那么建立新的socket來(lái)對(duì)應(yīng)這個(gè)聯(lián)接的會(huì)話。
?? 值得注意的就是這一句聯(lián)接代碼：listener.Accept()。執(zhí)行這一句的時(shí)候，程序就在這個(gè)地方等待，直到有新的聯(lián)檢請(qǐng)求的時(shí)候程序才會(huì)執(zhí)行下一句。這是同步執(zhí)行，當(dāng)然也可以異步執(zhí)行。
?
?? 新的聯(lián)接Socket建立了（Accept之后），對(duì)于這些新的socket該怎么辦呢？他們依然是一個(gè)循環(huán)等待，所以依然需要建立新的Thread給這些Socket去處理會(huì)話（接收/發(fā)送消息），而這個(gè)Thread就要接收參數(shù)了。
?? Thread本身是不能接收參數(shù)的，為了讓它可以接收參數(shù)，可以采用定義新類，添加參數(shù)作為屬性的方法來(lái)解決。
?? 因?yàn)槊恳粋€(gè)Socket是一個(gè)Connection周期，所以我定義了這么一個(gè)類public class Connection。這個(gè)類至少有這樣一個(gè)構(gòu)造函數(shù)public Connection(Socket socket); 之所以這么做，就是為了把Socket參數(shù)傳給這個(gè)Connection對(duì)象，然后好讓Listener啟動(dòng)這個(gè)Thread的時(shí)候，Thread可以知道他正在處理哪一個(gè)Socket。
??? 具體處理的方法：（在Listener的StartListening函數(shù)，ocket connection = listener.Accept();之后）
??? Connection gpsCn = new Connection(connection);
??????????????????? //each socket will be wait for data. keep the connection.
??????????????????? Thread thread = new Thread(new ThreadStart(gpsCn.WaitForSendData));
??????????????????? thread.Name = connection.RemoteEndPoint.ToString();
??????????????????? thread.Start();
?如此一來(lái)，這個(gè)新的socket在Accept之后就在新的Thread中運(yùn)行了。
?? 3：Connection的會(huì)話處理
?? 建立了新的Connection（也就是socket），遠(yuǎn)程就可以和這個(gè)socket進(jìn)行會(huì)話了，無(wú)非就是send和receive。
?? 現(xiàn)在先看看怎么寫的這個(gè)線程運(yùn)行的Connection. WaitForSendData函數(shù)
??? while (true)
??????????? {
??????????????? bytes = new byte[1024];
??????????????? string data = "";
??????????????? //systm will be waiting the msg of receive envet. like Accept();
??????????????? //here will be suspended while waiting for socket income msg.
??????????????? int bytesRec = this._connection.Receive(bytes);
??????????????? _lastConnectTime = DateTime.Now;
??????????????? if (bytesRec == 0)//close envent
??????????????? {
??????????????????? Logger.Log("Close Connection", _connection.RemoteEndPoint.ToString());
??????????????????? break;
??????????????? }
??????????????? data += Encoding.ASCII.GetString(bytes, 0, bytesRec);
??????????????? //…….handle your data.
???????????? }
可以看到這個(gè)處理的基本步驟如下：
?? 執(zhí)行Receive函數(shù)，接收遠(yuǎn)程socket發(fā)送的信息；
?? 把信息從字節(jié)轉(zhuǎn)換到string；
?? 處理該信息，然后進(jìn)入下一個(gè)循環(huán)，繼續(xù)等待socket發(fā)送新的信息。
值得注意的有幾個(gè)：
?? 1：Receive函數(shù)。這個(gè)函數(shù)和Listener的Accept函數(shù)類似。在這個(gè)地方等待執(zhí)行，如果沒(méi)有新的消息，這個(gè)函數(shù)就不會(huì)執(zhí)行下一句，一直等待。
?? 2：接收的是字節(jié)流，需要轉(zhuǎn)化成字符串
?? 3：判斷遠(yuǎn)程關(guān)閉聯(lián)接的方式
?? 4：如果對(duì)方的消息非常大，還得循環(huán)接收這個(gè)data。
4：如何管理這些聯(lián)接（thread）
通過(guò)上邊的程序，基本上可以建立一個(gè)偵聽(tīng)，并且處理聯(lián)接會(huì)話。但是如何管理這些thread呢？不然大量產(chǎn)生thread可是一個(gè)災(zāi)難。
管理的方法比較簡(jiǎn)單，在Listener里面我定義了一個(gè)靜態(tài)的哈希表(static public Hashtable Connections=new Hashtable();)，存儲(chǔ)Connection實(shí)例和它對(duì)應(yīng)的Thread實(shí)例。而connection中也加入了一個(gè)最后聯(lián)接時(shí)間的定義（private DateTime _lastConnectTime;）。在新鏈接建立的時(shí)候（Listener的Accept()之后）就把Connection實(shí)例和Thread實(shí)例存到哈希表中；在Connection的Receive的時(shí)候修改最后聯(lián)接時(shí)間。這樣我們就可以知道該Connection在哪里，并且會(huì)話是否活躍。
然后在Winform程序里頭可以管理這些會(huì)話了，設(shè)置設(shè)置超時(shí)。

轉(zhuǎn)載于:https://www.cnblogs.com/borcala/archive/2008/01/22/1049255.html

總結(jié)

以上是生活随笔為你收集整理的C# Socket与实现的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。