作者： 劉彥青

本篇文章討論了一種設(shè)計P2P網(wǎng)絡(luò)應(yīng)用程序的簡單方法。 

　　盡管有許多P2P網(wǎng)絡(luò)不需要索引服務(wù)器或中央服務(wù)器，各客戶機(jī)之間可以互相直接通訊，但下面的圖1還是顯示了P2P網(wǎng)絡(luò)的基本工作原理，一般來說，P2P概念中包含一臺中央索引服務(wù)器，這臺服務(wù)器并不存儲有任何文件，它只存儲有登錄到該網(wǎng)絡(luò)上的所有用戶的信息、客戶端的ip地址以及用戶提供的供共享的文件，客戶機(jī)和服務(wù)器使用簡單的命令通過報路連接進(jìn)行通訊。 

　　當(dāng)客戶端A想要查找P2P網(wǎng)絡(luò)上其他客戶端提供共享的文件時，系統(tǒng)會執(zhí)行下面的操作： 

　　　·客戶端A以自己的用戶名登錄到索引服務(wù)器上。 

　　　·客戶端A向服務(wù)器注冊自己想提供給其他用戶共享的文件，以便其他用戶能夠查找到這些文件。 

　　　·客戶端A向服務(wù)器發(fā)出申請，查找與一定的輸入模式相匹配的文件。 

　　　·索引服務(wù)器在其數(shù)據(jù)庫中搜索給定的文件名，并將搜索到的如下的結(jié)果返回給客戶端A： 

　　　　·提供該文件的客戶端，例如客戶端B。 

　　　　·該用戶的IP地址。 

　　　　·它搜索到的文件名。 




　　一旦客戶端A選擇了下載選項，客戶端A就使用搜索返回的IP地址與客戶端B建立連接。 

　　　·一旦成功地建立起一個連接，就可以通知對方開始發(fā)送文件了。 

　　　·下載完成后，應(yīng)當(dāng)向索引服務(wù)器注冊你得到的共享文件的拷貝。 

　　這樣的P2P網(wǎng)絡(luò)可以用來共享任何類型的文件，它既可以用在局域網(wǎng)上，也可以作在互聯(lián)網(wǎng)上。

                       
C#語言由于其對網(wǎng)絡(luò)功能良好的支持，特別是內(nèi)置地支持TCPListener和TCPClient這二個類，使得利用它開發(fā)P2P應(yīng)用程序變得非常容易。下面就是一個使用C#開發(fā)的P2P應(yīng)用的例子： 

public MyTcpListener(int port) : base(port) 
{ 

} 
public void StopMe() 
{ 
if ( this.Server != null ) 
{ 
this.Server.Close(); 
} 
} 
} 

public class Transfer 
{ 
MyTcpListener tcpl; 

public Transfer() 
{ 
OptionsLoader ol = new OptionsLoader(); 
int port = 8081; 
if (ol.Port > 0) 
{ 
port = ol.Port; 
} 
else 
{ 
port = 8081; 
} 

this.tcpl = new MyTcpListener(port); 
} 

public void TransferShutdown() 
{ 
tcpl.StopMe(); 
} 

public void ListenForPeers() 
{ 
try 
{ 

Encoding ASCII = Encoding.ASCII; 


tcpl.Start(); 


while (true) 
{ 
// 在有連接之前，Accept將處于阻塞狀態(tài) 
Socket s = tcpl.AcceptSocket(); 
NetworkStream DataStream = new NetworkStream(s); 

String filename; 
Byte[] Buffer = new Byte[256]; 
DataStream.Read(Buffer, 0, 256); 
filename = Encoding.ASCII.GetString(Buffer);  StringBuilder sbFileName = new StringBuilder(filename); 
StringBuilder sbFileName2 = sbFileName.Replace("/", "http://"); 
FileStream fs = new FileStream(sbFileName2.ToString(), FileMode.Open, Fileaccess.Read); 
BinaryReader reader = new BinaryReader(fs); 
byte[] bytes = new byte[1024]; 
int read; 
while((read = reader.Read(bytes, 0, bytes.Length)) != 0) 
{ 
DataStream.Write(bytes, 0, read); 
} 
reader.Close(); 
DataStream.Flush(); 
DataStream.Close(); 
} 
} 
catch(SocketException ex) 
{ 
MessageBox.Show(ex.ToString()); 
} 
} 
public void DownloadToClient(String server, string remotefilename, stringlocalfilename) 
{ 
try 
{ 
TcpClient tcpc = new TcpClient(); 
Byte[] read = new Byte[1024]; 

OptionsLoader ol = new OptionsLoader(); 
int port = 0; 
if (ol.Port > 0) 
{ 
port = ol.Port; 
} 
else 
{ 
// 缺省的端口號，可以設(shè)置為使用的端口號 
port = 8081; 
} 


// 嘗試與服務(wù)器連接 
IPHostEntry IPHost = Dns.Resolve(server); 
string []aliases = IPHost.Aliases; 
IPAddress[] addr = IPHost.AddressList; 

IPEndPoint ep = new IPEndPoint(addr[0], port); 
tcpc.Connect(ep); 

// 獲得流對象 
Stream s = tcpc.GetStream(); 
Byte[] b = Encoding.ASCII.GetBytes(remotefilename.ToCharArray()); 
s.Write( b, 0, b.Length ); 
int bytes; 
FileStream fs = new FileStream(localfilename, FileMode.OpenOrCreate); 
BinaryWriter w = new BinaryWriter(fs); 

// 讀取流對象，并將其轉(zhuǎn)換為ASCII碼 
while( (bytes = s.Read(read, 0, read.Length)) != 0) 
{ 
w.Write(read, 0, bytes); 
read = new Byte[1024]; 
} 

tcpc.Close(); 
w.Close(); 
fs.Close(); 
} 
catch(Exception ex) 
{ 
throw new Exception(ex.ToString()); 
} 
} 
} 
}