基于p2p文件傳輸

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

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

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

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

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

6、上任何兩臺計算機的文件共享。 在兩臺計算機傳輸文件前，必須先有一臺計算機建立套接字連接，并綁定一個固定的端口，并在這個端口偵聽另外一臺計算機的連接請求。 普通用戶 網(wǎng)絡(luò)服務(wù)器 普通用戶 普通用戶 //不過，我感到奇怪的是，為什么不接著使用 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