基于p2p文件傳輸

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

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

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

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

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

6、上任何兩臺(tái)計(jì)算機(jī)的文件共享。 在兩臺(tái)計(jì)算機(jī)傳輸文件前，必須先有一臺(tái)計(jì)算機(jī)建立套接字連接，并綁定一個(gè)固定的端口，并在這個(gè)端口偵聽(tīng)另外一臺(tái)計(jì)算機(jī)的連接請(qǐng)求。 普通用戶 網(wǎng)絡(luò)服務(wù)器 普通用戶 普通用戶 //不過(guò)，我感到奇怪的是，為什么不接著使用 mysocket 類，卻改用 WinSock API函數(shù)呢？ //答：上面的 mysocket 類是用來(lái)聊天用的，是異步的；而下面的 socket 是用來(lái)傳送文件用的，是同步的 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); 出錯(cuò)“,““,0); //執(zhí)行到下面一句出錯(cuò)了，返回的是錯(cuò)誤信息，為什么出錯(cuò)呢？ //答：因?yàn)榘l(fā)生了端口沖突。我把端口號(hào)改成 3962 就不出錯(cuò)了。 //調(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 地址和端口出錯(cuò)，則 // if(!(rc==SOCKET_ERROR))//測(cè)試代碼 if(rc==SOCKET_ERROR) { int iErrorCode; char str1[100]; CString aaa; aaa=“Bind 錯(cuò)誤\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ù)返回的錯(cuò)誤代碼是:%

11、d“,iErrorCode); ::MessageBox(NULL,str1,““,0); //因?yàn)橛脕?lái)顯示出錯(cuò)信息的 View 窗口是 MainFrame 窗口的子窗口，所以，就用了這么一個(gè)名字(xxxDescendants) AfxGetMainWnd()->SendMessageToDescendants(WM_AGE1,(LPARAM)aaa.GetBuffer(0),1); aaa.ReleaseBuffer(); re