基于p2p文件傳輸

1、基于 P2P 文件傳輸 1. P2P 簡介 對等網(wǎng)絡 P2P（peer-to-peer）技術是一種用于不同計算機用戶之間，不經(jīng)過中繼設備直接交換數(shù)據(jù)或服務的技術，其網(wǎng)絡通信方式如下圖所示： P2P 技術打破了傳統(tǒng)的 Client/Server 模式，在對等網(wǎng)絡中，每個節(jié)點的地位都是相同的，具備客戶端和服務器雙重特性，可以同時作為服務使用者和服務提供者。 P2P 技術有著廣闊的應用領域，目前主要的應用有文件交換、分布式計算、協(xié)同工作、分布

2、式搜索和電子商務等。 2. 主要的 P2P 模式 P2P 模式的變化經(jīng)歷了集中式、分布式、和混合式 3 個階段。P2P 技術起源于文件交換技術，在發(fā)展過程中，文件交換技術的演變最具代表性，下面介紹 P2P 模式的幾種形式： （1） 集中式對等網(wǎng)絡。集中式 P2P 模式由一個中心服務器來負責記錄共享信息以及反饋對這些信息的查詢。 每一個對等實體要對它所需共享的信息以及進行的通信負責， 根據(jù)需要下載它所需要的其他對等實體上的信息。 這種形式

3、具有中心化的特點，但是它不同于傳統(tǒng)意義于上的 Cleint/Server 模式。因為傳統(tǒng)意義上的Client/Server 模式采用的是一種壟斷的手段，所有資料都存放在服務器上，客戶機只能被動的從服務器上讀取信息， 并且客戶機之間不具有交互能力； 而集中式P2P 模式則是所有網(wǎng)上提供的資料都存放在提供資料的客戶機上， 服務器上只保留索引信息，此外服務器與對等實體以及對等實體之間都具有交互能力。 （2） 分布式對等網(wǎng)絡。在分布式 P2P

4、中，對等機通過與相鄰對等機之間的連接，遍歷整個網(wǎng)絡體系。每個對等機在功能上都是相似的，并沒有專門的服務器， 而對等機必須依靠它們所在的分布網(wǎng)絡來查找文件和定位其他對等機。這種無中心、純分布式系統(tǒng)不再是簡單的點到點通信，而是更高效、更復雜的網(wǎng)絡通信。 （3） 混合 P2P 網(wǎng)絡。集中式 P2P 有利于網(wǎng)絡資源的快速檢索，并且只要服務器能力足夠強大就可以無限擴展， 但是其中心化的模式容易遭到直接的攻擊； 分布式解決了抗攻擊的問題，但是又缺乏

5、快速搜索和可擴展性?；旌鲜?P2P 結合了集中式和分布式 P2P 優(yōu)點，在設計思想和處理能力上都進一步的優(yōu)化。它在分布式模式的基礎上，將用戶節(jié)點能力進行分類，使某些節(jié)點擔任特殊任務。 3. 實例-----基于 P2P 實現(xiàn)網(wǎng)絡文件傳輸 P2P 實現(xiàn)文件的傳輸有別于 FTP 協(xié)議實現(xiàn)的文件的傳輸方法， 利用 FTP 的方法需要一個專門的服務器和客戶端，而采用 P2P 的方法，只需要兩臺計算機，不需要設定服務器，即可實現(xiàn) Internet

6、上任何兩臺計算機的文件共享。 在兩臺計算機傳輸文件前，必須先有一臺計算機建立套接字連接，并綁定一個固定的端口，并在這個端口偵聽另外一臺計算機的連接請求。 普通用戶 網(wǎng)絡服務器 普通用戶 普通用戶 //不過，我感到奇怪的是，為什么不接著使用 mysocket 類，卻改用 WinSock API函數(shù)呢？ //答：上面的 mysocket 類是用來聊天用的，是異步的；而下面的 socket 是用來傳送文件用的，是同步的 socket； m_s

7、Listening=socket(AF_INET,SOCK_STREAM,0); if(m_sListening==INVALID_SOCKET) ::MessageBox(NULL,“執(zhí)行 socket(AF_INET,SOCK_STREAM,0); 出錯“,““,0); //執(zhí)行到下面一句出錯了，返回的是錯誤信息，為什么出錯呢？ //答：因為發(fā)生了端口沖突。我把端口號改成 3962 就不出錯了。 //調(diào)用 WinSock API 函

8、數(shù)，The bind function associates a local address with a socket. //If no error occurs, bind returns zero. Otherwise, it returns SOCKET_ERROR, and a specific error code can be retrieved by calling WSAGetLastError. rc=bind(m_

9、sListening,(LPSOCKADDR) //如果綁定 IP 地址和端口出錯，則 // if(!(rc==SOCKET_ERROR))//測試代碼 if(rc==SOCKET_ERROR) { int iErrorCode; char str1[100]; CString aaa; aaa=“Bind 錯誤\n“; iErrorCode=WSAGetLastError();//WSAENETDOWN /* // MessageId

10、: WSAEADDRINUSE // // MessageText: // // Only one usage of each socket address (protocol/network address/port) is normally permitted. // #define WSAEADDRINUSE 10048L */ sprintf(str1,“bind 函數(shù)返回的錯誤代碼是:%

11、d“,iErrorCode); ::MessageBox(NULL,str1,““,0); //因為用來顯示出錯信息的 View 窗口是 MainFrame 窗口的子窗口，所以，就用了這么一個名字(xxxDescendants) AfxGetMainWnd()->SendMessageToDescendants(WM_AGE1,(LPARAM)aaa.GetBuffer(0),1); aaa.ReleaseBuffer(); re