System.Sockes命名空間了實(shí)現(xiàn) Berkeley 套接字接口。通過(guò)這個(gè)類(lèi),我們可以實(shí)現(xiàn)網(wǎng)絡(luò)計(jì)算機(jī)之間的消息傳輸和發(fā)送.而在我下面要討論的這個(gè)議題里,我們將討論的是用套節(jié)子實(shí)現(xiàn)文件的傳輸.這種方法有別于FTP協(xié)議實(shí)現(xiàn)的的文件傳輸方法,利用ftp的方法需要一個(gè)專(zhuān)門(mén)的服務(wù)器和客戶(hù)端,無(wú)疑于我們要實(shí)現(xiàn)的點(diǎn)對(duì)點(diǎn)的文件傳輸太為復(fù)雜了一些。在這里,我們實(shí)現(xiàn)一個(gè)輕量級(jí)的方法來(lái)實(shí)現(xiàn)點(diǎn)對(duì)點(diǎn)的文件傳輸,這樣就達(dá)到了intenet上任何兩個(gè)計(jì)算機(jī)的文件共享。
在兩臺(tái)計(jì)算機(jī)傳輸文件之前,必需得先有一臺(tái)計(jì)算機(jī)建立套節(jié)子連接并綁定一個(gè)固定得端口,并在這個(gè)端口偵聽(tīng)另外一臺(tái)計(jì)算機(jī)的連接請(qǐng)求。
socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp);
socket.Blocking = true ;
IPEndPoint computernode1 = new IPEndPoint(serverIpadress, 8080);
socket.Bind(computernode1);
socket.Listen(-1);
當(dāng)有其他的計(jì)算機(jī)發(fā)出連接請(qǐng)求的時(shí)候,被請(qǐng)求的計(jì)算機(jī)將對(duì)每一個(gè)連接請(qǐng)求分配一個(gè)線程,用于處理文件傳輸和其他服務(wù)。
while ( true )
? {
??? clientsock = socket.Accept();
??? if ( clientsock.Connected )
??? {
?????? Thread tc = new Thread(new ThreadStart(listenclient));
????? tc.Start();
??? }
? }
?
下面的代碼展示了listenclient方法是如何處理另外一臺(tái)計(jì)算機(jī)發(fā)送過(guò)來(lái)的請(qǐng)求。首先并對(duì)發(fā)送過(guò)來(lái)的請(qǐng)求字符串作出判斷,看看是何種請(qǐng)求,然后決定相應(yīng)的處理方法。
void listenclient()
{
? Socket sock = clientsock ;
? try
? {
??? while ( sock != null )
??? {
????? byte[] recs = new byte[32767];
????? int rcount = sock.Receive(recs,recs.Length,0) ;
????? string message = System.Text.Encoding.ASCII.GetString(recs) ;
???? //對(duì)message作出處理,解析處請(qǐng)求字符和參數(shù)存儲(chǔ)在cmdList 中
????????? execmd=cmdList[0];
????? sender = null ;
????? sender = new Byte[32767];
?
????? string parm1 = "";
//目錄列舉????
if ( execmd == "LISTING" )
????? {
??????? ListFiles(message);
??????? continue ;
????? }
//文件傳輸
????? if ( execmd == "GETOK" )
????? {
??????? cmd = "BEGINSEND "? + filepath + " " + filesize ;
??????? sender = new Byte[1024];
??????? sender = Encoding.ASCII.GetBytes(cmd);
??????? sock.Send(sender, sender.Length , 0 );
?????????????? //轉(zhuǎn)到文件下載處理
??????? DownloadingFile(sock);
??????? continue ;
????? }??
??? }
? }
? catch(Exception Se)
? {
??? string s = Se.Message;
??? Console.WriteLine(s);
? }
}
?
至此,基本的工作已經(jīng)完成了,下面我們看看如何處理文件傳輸?shù)摹?br />while(rdby < total && nfs.CanWrite)
? {
//從要傳輸?shù)奈募x取指定長(zhǎng)度的數(shù)據(jù)
len =fin.Read(buffed,0,buffed.Length) ;
??? //將讀取的數(shù)據(jù)發(fā)送到對(duì)應(yīng)的計(jì)算機(jī)
??? nfs.Write(buffed, 0,len);
??? //增加已經(jīng)發(fā)送的長(zhǎng)度
??? rdby=rdby+len ;?????????
? }
從上面的代碼可以看出是完成文件轉(zhuǎn)換成FileStream 流,然后通過(guò)NetworkStream綁定對(duì)應(yīng)的套節(jié)子,最后調(diào)用他的write方法發(fā)送到對(duì)應(yīng)的計(jì)算機(jī)。
我們?cè)倏纯唇邮芏耸侨绾谓邮軅鬏斶^(guò)來(lái)的流,并且轉(zhuǎn)換成文件的:
NetworkStream nfs = new NetworkStream(sock) ;
try
{
??????? //一直循環(huán)直到指定的文件長(zhǎng)度
??????? while(rby < size)
? {
????? byte[] buffer = new byte[1024] ;
????? //讀取發(fā)送過(guò)來(lái)的文件流
????? int i = nfs.Read(buffer,0,buffer.Length) ;
????? fout.Write(buffer,0,(int)i) ;
????? rby=rby+i ;
??? }?
? fout.Close() ;
?
從上面可以看出接受與發(fā)送恰好是互為相反的過(guò)程,非常簡(jiǎn)單。
至此,單方向的文件傳輸就完成了,只需要在每個(gè)對(duì)等的節(jié)點(diǎn)上同時(shí)實(shí)現(xiàn)上面的發(fā)送和接受的處理代碼就可以做到互相傳輸文件了。
?
?
=============================
?
Microsoft.Net Framework為應(yīng)用程序訪問(wèn)Internet提供了分層的、可擴(kuò)展的以及受管轄的網(wǎng)絡(luò)服務(wù),其名字空間System.Net和System.Net.Sockets包含豐富的類(lèi)可以開(kāi)發(fā)多種網(wǎng)絡(luò)應(yīng)用程序。.Net類(lèi)采用的分層結(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類(lèi)可以視為包含3個(gè)層次:請(qǐng)求/響應(yīng)層、應(yīng)用協(xié)議層、傳輸層。WebReqeust和WebResponse 代表了請(qǐng)求/響應(yīng)層,支持Http、Tcp和Udp的類(lèi)組成了應(yīng)用協(xié)議層,而Socket類(lèi)處于傳輸層。?
??
? 傳輸層位于這個(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)類(lèi)都建立在該套接字Socket實(shí)現(xiàn)之上,如TCPClient、TCPListener 和 UDPClient 類(lèi)封裝有關(guān)創(chuàng)建到 Internet 的 TCP 和 UDP 連接的詳細(xì)信息;NetworkStream類(lèi)則提供用于網(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)用程序端(客戶(hù)端)和遠(yuǎn)程服務(wù)器端之間,而后,數(shù)據(jù)的讀取(接收)和寫(xiě)入(發(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 類(lèi)是 Winsock32 API 提供的套接字服務(wù)的托管代碼版本。其中為實(shí)現(xiàn)網(wǎng)絡(luò)編程提供了大量的方法,大多數(shù)情況下,Socket 類(lèi)方法只是將數(shù)據(jù)封送到它們的本機(jī) Win32 副本中并處理任何必要的安全檢查。如果你熟悉Winsock API函數(shù),那么用Socket類(lèi)編寫(xiě)網(wǎng)絡(luò)程序會(huì)非常容易,當(dāng)然,如果你不曾接觸過(guò),也不會(huì)太困難,跟隨下面的解說(shuō),你會(huì)發(fā)覺(jué)使用Socket類(lèi)開(kāi)發(fā)windows 網(wǎng)絡(luò)應(yīng)用程序原來(lái)有規(guī)可尋,它們?cè)诖蠖鄶?shù)情況下遵循大致相同的步驟。
??
? 在使用之前,你需要首先創(chuàng)建Socket對(duì)象的實(shí)例,這可以通過(guò)Socket類(lèi)的構(gòu)造方法來(lái)實(shí)現(xiàn):
??
? public Socket(AddressFamily addressFamily,SocketType socketType,ProtocolType protocolType);
??
??
? 其中,addressFamily 參數(shù)指定 Socket 使用的尋址方案,socketType 參數(shù)指定 Socket 的類(lèi)型,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é)議類(lèi)型,如下面的示例所示:
??
? Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
??
??
? 一旦創(chuàng)建 Socket,在客戶(hù)端,你將可以通過(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)到用戶(hù)端的連接時(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類(lèi)型的參數(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ù)端口的組合稱(chēng)為終結(jié)點(diǎn),在 .NET 框架中正是由 EndPoint 類(lèi)表示這個(gè)終結(jié)點(diǎn),它提供表示網(wǎng)絡(luò)資源或服務(wù)的抽象,用以標(biāo)志網(wǎng)絡(luò)地址等信息。.Net同時(shí)也為每個(gè)受支持的地址族定義了 EndPoint 的子代;對(duì)于 IP 地址族,該類(lèi)為 IPEndPoint。IPEndPoint 類(lèi)包含應(yīng)用程序連接到主機(jī)上的服務(wù)所需的主機(jī)和端口信息,通過(guò)組合服務(wù)的主機(jī)IP地址和端口號(hào),IPEndPoint 類(lèi)形成到服務(wù)的連接點(diǎn)。
??
? 用到IPEndPoint類(lèi)的時(shí)候就不可避免地涉及到計(jì)算機(jī)IP地址,.Net中有兩種類(lèi)可以得到IP地址實(shí)例:
??
? IPAddress類(lèi):IPAddress 類(lèi)包含計(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 類(lèi):向使用 TCP/IP Internet 服務(wù)的應(yīng)用程序提供域名服務(wù)。其Resolve 方法查詢(xún) DNS 服務(wù)器以將用戶(hù)友好的域名(如"host.contoso.com")映射到數(shù)字形式的 Internet 地址(如 192.168.1.1)。Resolve方法 返回一個(gè) IPHostEnty 實(shí)例,該實(shí)例包含所請(qǐng)求名稱(chē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 類(lèi)支持兩種基本模式:同步和異步。其區(qū)別在于:在同步模式中,對(duì)執(zhí)行網(wǎng)絡(luò)操作的函數(shù)(如 Send 和 Receive)的調(diào)用一直等到操作完成后才將控制返回給調(diào)用程序。在異步模式中,這些調(diào)用立即返回。
??
? 另外,很多時(shí)候,Socket編程視情況不同需要在客戶(hù)端和服務(wù)器端分別予以實(shí)現(xiàn),在客戶(hù)端編制應(yīng)用程序向服務(wù)端指定端口發(fā)送請(qǐng)求,同時(shí)編制服務(wù)端應(yīng)用程序處理該請(qǐng)求,這個(gè)過(guò)程在上面的闡述中已經(jīng)提及;當(dāng)然,并非所有的Socket編程都需要你嚴(yán)格編寫(xiě)這兩端程序;視應(yīng)用情況不同,你可以在客戶(hù)端構(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è)面下載功能。用戶(hù)只需在窗體上輸入遠(yuǎn)程主機(jī)名(Dns 主機(jī)名或以點(diǎn)分隔的四部分表示法格式的 IP 地址)和預(yù)保存的本地文件名,并利用專(zhuān)門(mén)提供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);
? //寫(xiě)入文件
? fs.Write(content,0,content.Length);
? }
? catch(Exception fe)
?? {
?? MessageBox.Show("文件創(chuàng)建/寫(xiě)入錯(cuò)誤:"+fe.Message,"提示信息",MessageBoxButtons.RetryCancel,MessageBoxIcon.Information);
?? }
?? //禁用Socket
?? socket.Shutdown(SocketShutdown.Both);
?? //關(guān)閉Socket
?? socket.Close();
?? }
?? }
?
=============================================
?
Socket基本編程
服務(wù)端:
?
using System.Net;
?
using System.Net.Sockets;
?
using System.Text;
?
using System.Threading;
?
?
????????
?
???????? Thread mythread ;
?
???????? Socket socket;
?
?
// 清理所有正在使用的資源。
?
???????? protected override void Dispose( bool disposing )
?
???????? {
?
????????????? try
?
??????????? { ????????????
?
????????? socket.Close();//釋放資源
?
????????? mythread.Abort ( ) ;//中止線程
?
??????????? }
?
??????????? catch{ }
?
?
????????????? if( disposing )
?
????????????? {
?
?????????????????? if (components != null)
?
?????????????????? {
?
?????????????????????? components.Dispose();
?
?????????????????? }
?
????????????? }
?
????????????? base.Dispose( disposing );
?
???????? }???????
?
???????? public static IPAddress GetServerIP()
?
???????? {
?
????????????? IPHostEntry ieh=Dns.GetHostByName(Dns.GetHostName());
?
????????????? return ieh.AddressList[0];
?
???????? }
?
???????? private void BeginListen()
?
???????? {
?
????????????? IPAddress ServerIp=GetServerIP();
?
????????????? IPEndPoint iep=new IPEndPoint(ServerIp,8000);
?
????????????? socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
?
?????????????
?
????????????? byte[] byteMessage=new byte[100];?
?
????????????? this.label1.Text=iep.ToString();
?
????????????? socket.Bind(iep);?
?
//??????????? do
?
????????????? while(true)
?
????????????? {
?
?????????????????? try
?
?????????????????? {
?
?????????????????????? socket.Listen(5);
?
?????????????????????? Socket newSocket=socket.Accept();
?
?????????????????????? newSocket.Receive(byteMessage);
?
?
?????????????????????? string sTime = DateTime.Now.ToShortTimeString ( ) ;
?
?????????????????????? string msg=sTime+":"+"Message from:";
?
?????????????????????? msg+=newSocket.RemoteEndPoint.ToString()+Encoding.Default.GetString(byteMessage);
?
?????????????????????? this.listBox1.Items.Add(msg);
?
??????????????????????
?
?????????????????? }
?
?????????????????? catch(SocketException ex)
?
?????????????????? {
?
?????????????????????? this.label1.Text+=ex.ToString();
?
?????????????????? }
?
????????????? }
?
//??????????? while(byteMessage!=null);
?
???????? }
?
???????? //開(kāi)始監(jiān)聽(tīng)
?
???????? private void button1_Click(object sender, System.EventArgs e)
?
???????? {
?
????????????? try
?
????????????? {
?
?????????????????? mythread = new Thread(new ThreadStart(BeginListen));
?
?????????????????? mythread.Start();
?
?
????????????? }
?
????????????? catch(System.Exception er)
?
????????????? {
?
?????????????????? MessageBox.Show(er.Message,"完成",MessageBoxButtons.OK,MessageBoxIcon.Stop);
?
????????????? }???????????
?
???????? }
?
?
?
?
客戶(hù)端:
?
?
using System.Net;
?
using System.Net.Sockets;
?
using System.Text;
?
?
???????? private void button1_Click(object sender, System.EventArgs e)
?
???????? {
?
????????????? BeginSend();??????
?
???????? }
?
???????? private void BeginSend()
?
???????? {????????????
?
????????????? string ip=this.txtip.Text;
?
????????????? string port=this.txtport.Text;
?
?
????????????? IPAddress serverIp=IPAddress.Parse(ip);???????????
?
????????????? int serverPort=Convert.ToInt32(port);
?
????????????? IPEndPoint iep=new IPEndPoint(serverIp,serverPort);?
?
????????????? byte[] byteMessage;?
?
//??????????? do
?
//??????????? {
?
?????????????????? Socket socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
?
?????????????????? socket.Connect(iep);
?
?????????????
?
?????????????????? byteMessage=Encoding.ASCII.GetBytes(textBox1.Text);
?
?????????????????? socket.Send(byteMessage);
?
?????????????????? socket.Shutdown(SocketShutdown.Both);
?
?????????????????? socket.Close();
?
//??????????? }
?
//??????????? while(byteMessage!=null);
?
???????? }?
Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=1487041