使用C#開發一個簡單的P2P應用

2019-11-18 19:48:25

字體：大中小

來源：轉載

供稿：網友

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

　　當客戶端A想要查找P2P網絡上其他客戶端提供共享的文件時，系統會執行下面的操作：

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

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

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

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

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

　　　　·該用戶的IP地址。

　　　　·它搜索到的文件名。

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

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

　　　·下載完成后，應當向索引服務器注冊你得到的共享文件的拷貝。

　　這樣的P2P網絡可以用來共享任何類型的文件，它既可以用在局域網上，也可以作在互聯網上。

C#語言由于其對網絡功能良好的支持，特別是內置地支持TCPListener和TCPClient這二個類，使得利用它開發P2P應用程序變得非常容易。下面就是一個使用C#開發的P2P應用的例子：

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將處于阻塞狀態
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, File access.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, string localfilename)
{
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
{
// 缺省的端口號，可以設置為使用的端口號
port = 8081;
}

// 嘗試與服務器連接
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);

// 讀取流對象，并將其轉換為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());
}
}
}
}