明輝手游網(wǎng)中心:是一個免費提供流行視頻軟件教程、在線學習分享的學習平臺!

用Socket完成點對點的文件傳輸

[摘要]System.Sockes命名空間了實現(xiàn) Berkeley 套接字接口。通過這個類,我們可以實現(xiàn)網(wǎng)絡計算機之間的消息傳輸和發(fā)送.而在我下面要討論的這個議題里,我們將討論的是用套節(jié)子實現(xiàn)文件的傳輸.這...
System.Sockes命名空間了實現(xiàn) Berkeley 套接字接口。通過這個類,我們可以實現(xiàn)網(wǎng)絡計算機之間的消息傳輸和發(fā)送.而在我下面要討論的這個議題里,我們將討論的是用套節(jié)子實現(xiàn)文件的傳輸.這種方法有別于FTP協(xié)議實現(xiàn)的的文件傳輸方法,利用ftp的方法需要一個專門的服務器和客戶端,無疑于我們要實現(xiàn)的點對點的文件傳輸太為復雜了一些。在這里,我們實現(xiàn)一個輕量級的方法來實現(xiàn)點對點的文件傳輸,這樣就達到了intenet上任何兩個計算機的文件共享。

在兩臺計算機傳輸文件之前,必需得先有一臺計算機建立套節(jié)子連接并綁定一個固定得端口,并在這個端口偵聽另外一臺計算機的連接請求。

socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp);
socket.Blocking = true ;
IPEndPoint computernode1 = new IPEndPoint(serverIpadress, 8080);

socket.Bind(computernode1);

socket.Listen(-1);

當有其他的計算機發(fā)出連接請求的時候,被請求的計算機將對每一個連接請求分配一個線程,用于處理文件傳輸和其他服務。

while ( true )

{

clientsock = socket.Accept();

if ( clientsock.Connected )

{

Thread tc = new Thread(new ThreadStart(listenclient));

tc.Start();

}

}



下面的代碼展示了listenclient方法是如何處理另外一臺計算機發(fā)送過來的請求。首先并對發(fā)送過來的請求字符串作出判斷,看看是何種請求,然后決定相應的處理方法。

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) ;
//對message作出處理,解析處請求字符和參數(shù)存儲在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取指定長度的數(shù)據(jù)
len =fin.Read(buffed,0,buffed.Length) ;
//將讀取的數(shù)據(jù)發(fā)送到對應的計算機
nfs.Write(buffed, 0,len);
//增加已經(jīng)發(fā)送的長度
rdby=rdby+len ;
}
從上面的代碼可以看出是完成文件轉(zhuǎn)換成FileStream 流,然后通過NetworkStream綁定對應的套節(jié)子,最后調(diào)用他的write方法發(fā)送到對應的計算機。
我們再看看接受端是如何接受傳輸過來的流,并且轉(zhuǎn)換成文件的:
NetworkStream nfs = new NetworkStream(sock) ;
try
{
//一直循環(huán)直到指定的文件長度
while(rby < size)
{
byte[] buffer = new byte[1024] ;
//讀取發(fā)送過來的文件流
int i = nfs.Read(buffer,0,buffer.Length) ;
fout.Write(buffer,0,(int)i) ;
rby=rby+i ;
}
fout.Close() ;

從上面可以看出接受與發(fā)送恰好是互為相反的過程,非常簡單。
至此,單方向的文件傳輸就完成了,只需要在每個對等的節(jié)點上同時實現(xiàn)上面的發(fā)送和接受的處理代碼就可以做到互相傳輸文件了。