程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#基礎知識 >> 使用C#開發一個簡單的P2P應用

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

編輯:C#基礎知識

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

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

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

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

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

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

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

    ·該用戶的IP地址。

    ·它搜索到的文件名。

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

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

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

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


(圖1)

 

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

 1public MyTcpListener(int port) : base(port)
  2
  3public void StopMe() 
  4{
  5if ( this.Server != null )
  6
  7}
  8}
  9
 10public class Transfer
 11{
 12MyTcpListener tcpl;
 13
 14public Transfer()
 15{
 16OptionsLoader ol = new OptionsLoader(); 
 17int port = 8081;
 18if (ol.Port > 0)
 19{
 20port = ol.Port;
 21}
 22else
 23{
 24port = 8081;
 25
 26
 27this.tcpl = new MyTcpListener(port); 
 28}
 29
 30public void TransferShutdown()
 31
 32
 33public void ListenForPeers() 
 34
 35try
 36
 37
 38Encoding ASCII = Encoding.ASCII; 
 39
 40
 41tcpl.Start(); 
 42
 43
 44while (true)
 45
 46// 在有連接之前,Accept將處於阻塞狀態
 47Socket s = tcpl.AcceptSocket(); 
 48NetworkStream DataStream = new NetworkStream(s);
 49
 50String filename;
 51Byte[] Buffer = new Byte[256];
 52DataStream.Read(Buffer, 0, 256);
 53filename = Encoding.ASCII.GetString(Buffer);
 54StringBuilder sbFileName = new StringBuilder(filename);
 55StringBuilder sbFileName2 = sbFileName.Replace("", "");
 56FileStream fs = new FileStream(sbFileName2.ToString(), FileMode.Open, FileAccess.Read); 
 57BinaryReader reader = new BinaryReader(fs);
 58byte[] bytes = new byte[1024];
 59int read;
 60while((read = reader.Read(bytes, 0, bytes.Length)) != 0) 
 61{
 62DataStream.Write(bytes, 0, read);
 63}
 64reader.Close(); 
 65DataStream.Flush();
 66DataStream.Close();
 67}
 68}
 69catch(SocketException ex)
 70
 71MessageBox.Show(ex.ToString());
 72}
 73}
 74
 75public void DownloadToClient(String server, string remotefilename, string localfilename) 
 76{
 77try
 78{
 79TcpClient tcpc = new TcpClient(); 
 80Byte[] read = new Byte[1024]; 
 81
 82OptionsLoader ol = new OptionsLoader(); 
 83int port = 0;
 84if (ol.Port > 0)
 85{
 86port = ol.Port;
 87}
 88else
 89{
 90// 缺省的端口號,可以設置為使用的端口號
 91port = 8081;
 92
 93
 94
 95// 嘗試與服務器連接
 96IPHostEntry IPHost = Dns.Resolve(server); 
 97string []aliases = IPHost.Aliases; 
 98IPAddress[] addr = IPHost.AddressList; 
 99
100IPEndPoint ep = new IPEndPoint(addr[0], port);
101tcpc.Connect(ep);
102
103// 獲得流對象
104Stream s = tcpc.GetStream(); 
105Byte[] b = Encoding.ASCII.GetBytes(remotefilename.ToCharArray());
106s.Write( b, 0, b.Length );
107int bytes;
108FileStream fs = new FileStream(localfilename, FileMode.OpenOrCreate);
109BinaryWriter w = new BinaryWriter(fs);
110
111// 讀取流對象,並將其轉換為ASCII碼
112while( (bytes = s.Read(read, 0, read.Length)) != 0) 
113
114w.Write(read, 0, bytes);
115read = new Byte[1024]; 
116
117
118tcpc.Close();
119w.Close();
120fs.Close();
121}
122catch(Exception ex)
123{
124throw new Exception(ex.ToString()); 
125}
126
127}
128
129

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved