p2p打洞源碼

㈠ 如何使用java實現tcp的p2p的打洞技術

公網設伺服器S, 2p點(P1.P2) 連S,過S雙方獲取對方公網IP.
P1 P2都向對方的(公網IP+任意埠)發起連接,當然無任何回應,但是會發生2件事
1 P1 P2都在自己的外網NAT上打了個連接對方的洞,這個洞會保持一會兒.
2 連接的時候S抓取到P1 P2 的NAT埠,然後將此埠發送給對方,
然後就可以想辦法連接了.

㈡ 如何使用java實現tcp的p2p的打洞技術

建立穿越NAT設備的p2p的TCP連接只比UDP復雜一點點，TCP協議的"打洞"從協議層來看是與UDP的"打洞"過程非常相似的。盡管如此，基於TCP協議的打洞至今為止還沒有被很好的理解，這也造成了對其提供支持的NAT設備不是很多。在NAT設備支持的前提下，基於TCP的"打洞"技術實際上與基於UDP的"打洞"技術一樣快捷、可靠。實際上，只要NAT設備支持的話，基於TCP的p2p技術的健壯性將比基於UDP的技術的更強一些，因為TCP協議的狀態機給出了一種標準的方法來精確的獲取某個TCP session的生命期，而UDP協議則無法做到這一點。

一. 套接字和TCP埠的重用
實現基於TCP協議的p2p"打洞"過程中，最主要的問題不是來自於TCP協議，而是來自於來自於應用程序的API介面。這是由於標準的伯克利(Berkeley)套接字的API是圍繞著構建客戶端/伺服器程序而設計的，API允許TCP流套接字通過調用connect()函數來建立向外的連接，或者通過listen()和accept函數接受來自外部的連接，但是，API不提供類似UDP那樣的，同一個埠既可以向外連接，又能夠接受來自外部的連接。而且更糟的是，TCP的套接字通常僅允許建立1對1的響應，即應用程序在將一個套接字綁定到本地的一個埠以後，任何試圖將第二個套接字綁定到該埠的操作都會失敗。
為了讓TCP"打洞"能夠順利工作，我們需要使用一個本地的TCP埠來監聽來自外部的TCP連接，同時建立多個向外的TCP連接。幸運的是，所有的主流操作系統都能夠支持特殊的TCP套接字參數，通常叫做"SO_REUSEADDR"，該參數允許應用程序將多個套接字綁定到本地的一個endpoint（只要所有要綁定的套接字都設置了SO_REUSEADDR參數即可）。BSD系統引入了SO_REUSEPORT參數,該參數用於區分埠重用還是地址重用，在這樣的系統裡面，上述所有的參數必須都設置才行。

㈢ 詳解P2P技術中的NAT穿透原理(轉載)

課程地址：零聲學院 WebRTC入門與提高 https://ke.qq.com/course/435382?tuin=137bb271

技術支持QQ群：782508536

最近介入測試P2P的相關邏輯，因此對NAT穿透原理做了一定程度的了解（當然也沒有很深入）。本篇文章也是綜合和參考了些網路上和文獻里的一些資料（文中沒有對引用處進行標記，請見諒）。寫本文的目的就是，用自己的語言描述了這個過程，同時也在描述過程中加入了一些自己的理解，形成一篇文章作為要點的記錄。對於這一塊的知識，自己也有很多盲點，還請各路大神多多指教。

NAT（Network Address Translation，網路地址轉換），也叫做網路掩蔽或者IP掩蔽。NAT是一種網路地址翻譯技術，主要是將內部的私有IP地址（private IP）轉換成可以在公網使用的公網IP（public IP）。

時光回到上個世紀80年代，當時的人們在設計網路地址的時候，覺得再怎麼樣也不會有超過32bits位長即2的32次冪台終端設備連入互聯網，再加上增加ip的長度（即使是從4位元組增到6位元組）對當時設備的計算、存儲、傳輸成本也是相當巨大的。後來逐漸發現IP地址不夠用了，然後就NAT就誕生了！（雖然ipv6也是解決辦法，但始終普及不開來，而且未來到底ipv6夠不夠用仍是未知）。

因此，NAT技術能夠興起的原因還是因為在我們國家公網IP地址太少了，不夠用，所以才會採取這種地址轉換的策略。可見，NAT的本質就是讓一群機器公用同一個IP，這樣就暫時解決了IP短缺的問題。

優勢其實上面已經剛剛討論過了，根據定義，比較容易看出，NAT可以同時讓多個計算機同時聯網，並隱藏其內網IP，因此也增加了內網的網路安全性；此外，NAT對來自外部的數據查看其NAT映射記錄，對沒有相應記錄的數據包進行拒絕，提高了網路安全性。

那麼，NAT與此同時也帶來一些弊端：首先是，NAT設備會對數據包進行編輯修改，這樣就降低了發送數據的效率；此外，各種協議的應用各有不同，有的協議是無法通過NAT的（不能通過NAT的協議還是蠻多的），這就需要通過穿透技術來解決。我們後面會重點討論穿透技術。

簡單的背景了解過後，下面介紹下NAT實現的主要方式，以及NAT都有哪些類型。

1）靜態NAT：也就是靜態地址轉換。是指一個公網IP對應一個私有IP，是一對一的轉換，同時注意，這里只進行了IP轉換，而沒有進行埠的轉換。舉個栗子：

2）NAPT：埠多路復用技術。與靜態NAT的差別是，NAPT不但要轉換IP地址，還要進行傳輸層的埠轉換。具體的表現形式就是，對外只有一個公網IP，通過埠來區別不同私有IP主機的數據。再舉個栗子。

通過上面NAT實現方式的介紹，我們其實不難看出，現實環境中NAPT的應用顯然是更廣泛的。因此下面就重點介紹下NAPT的主要類型有哪些。

對於NAPT我們主要分為兩大類：錐型NAT和對稱型NAT。其中錐型NAT又分：完全錐型，受限錐型和埠受限錐型。概括的說：對稱型NAT是一個請求對應一個埠；錐型NAT（非對稱NAT）是多個請求（外部發向內部）對應一個埠，只要源IP埠不變，無論發往的目的IP是否相同，在NAT上都映射為同一個埠，形象的看起來就像錐子一樣。下面分別介紹這四種類型及其差異。

1）完全錐型NAT（Full Cone NAT，後面簡稱FC）

特點：IP和埠都不受限。

表現形式：將來自內部同一個IP地址同一個埠號（IP_IN_A : PORT_IN_A）的主機監聽/請求，映射到公網IP某個埠（IP_OUT_B : PORT_OUT_B）的監聽。任意外部IP地址與埠對其自己公網的IP這個映射後的埠訪問（IP_OUT_B : PORT_OUT_B），都將重新定位到內部這個主機（IP_IN_A : PORT_IN_A）。該技術中，基於C/S架構的應用可以在任何一端發起連接。是不是很繞啊。再簡單一點的說，就是，只要客戶端，由內到外建立一個映射（NatIP:NatPort -> A:P1）之後，其他IP的主機B或埠A:P2都可以使用這個洞給客戶端發送數據。見下圖（）。

2）受限錐型NAT（Restricted Cone NAT）

特點：IP受限，埠不受限。

表現形式：與完全錐形NAT不同的是，在公網映射埠後，並不允許所有IP進行對於該埠的訪問，要想通信必需內部主機對某個外部IP主機發起過連接，然後這個外部IP主機就可以與該內部主機通信了，但埠不做限制。舉個栗子。當客戶端由內到外建立映射(NatIP:NatPort –> A:P1)，A機器可以使用他的其他埠（P2）主動連接客戶端，但B機器則不被允許。因為IP受限啦，但是埠隨便。見下圖（綠色是允許通信，紅色是禁止通信）。

3）埠受限型NAT（Port Restricted Cone NAT）

特點：IP和埠都受限。

表現形式：該技術與受限錐形NAT相比更為嚴格。除具有受限錐形NAT特性，對於回復主機的埠也有要求。也就是說：只有當內部主機曾經發送過報文給外部主機（假設其IP地址為A且埠為P1）之後，外部主機才能以公網IP:PORT中的信息作為目標地址和目標埠，向內部主機發送UDP報文，同時，其請求報文的IP必須是A，埠必須為P1（使用IP地址為A，埠為P2，或者IP地址為B，埠為P1都將通信失敗）。例子見下圖。這一要求進一步強化了對外部報文請求來源的限制，從而較Restrictd Cone更具安全性。

4）對稱型NAT（Symmetric NAT）

特點：對每個外部主機或埠的會話都會映射為不同的埠（洞）。

表現形式：只有來自同一內部IP:PORT、且針對同一目標IP:PORT的請求才被NAT轉換至同一個公網（外部）IP:PORT，否則的話，NAT將為之分配一個新的外部（公網）IP:PORT。並且，只有曾經收到過內部主機請求的外部主機才能向內部主機發送數據包。內部主機用同一IP與同一埠與外部多IP通信。客戶端想和伺服器A（IP_A:PORT_A）建立連接，是通過NAT映射為NatIP:NatPortA來進行的。而客戶端和伺服器B（IP_B:PORT_B）建立連接，是通過NAT映射為NatIP:NatPortB來進行的。即同一個客戶端和不同的目標IP:PORT通信，經過NAT映射後的公網IP:PORT是不同的。此時，如果B想要和客戶端通信，也只能通過NatIP:NatPortB（也就是紫色的洞洞）來進行，而不能通過NatIP:NatPortA（也就是黃色的洞洞）。

以上，就是NAPT的四種NAT類型。可以看出由類型1）至類型4），NAT的限制是越來越大的。

根據上面的介紹，我們可以了解到，在實際的網路情況中，各個設備所處的網路環境是不同的。那麼，如果這些設備想要進行通信，首先判斷出設備所處的網路類型就是非常重要的一步。舉個例子來說：對於視頻會議和VoIP軟體，對位於不同NAT內部的主機通信需要靠伺服器來轉發完成，這樣就會增加伺服器的負擔。為了解決這種問題，要盡量使位於不同NAT內部的主機建立直接通信，其中，最重要的一點就是要判斷出NAT的類型，然後才能根據NAT的類型，設計出直接通信方案。不然的話，兩個都在NAT的終端怎麼通信呢？我們不知道對方的內網IP，即使把消息發到對方的網關，然後呢？網關怎麼知道這條消息給誰，而且誰允許網關這么做了？

為了解決這個問題，也就是處於內網的主機之間能夠穿越它們之間的NAT建立直接通信，已經提出了許多方法，STUN（Session Traversal Utilities for NAT，NAT會話穿越應用程序）技術就是其中比較重要的一種解決方法，並得到了廣泛的應用。在這個部分，我們將重點介紹下STUN技術的原理。（PS：除此之外，還有UPNP技術，ALG應用層網關識別技術，SBC會話邊界控制，ICE互動式連接建立，TURN中繼NAT穿越技術等等，本文不一一做介紹。）

STUN是一種網路協議，它允許位於NAT（或多重NAT）後的客戶端找出自己的公網地址，查出自己位於哪種類型的NAT之後以及NAT為某一個本地埠所綁定的Internet端埠。這些信息被用來在兩個同時處於NAT路由器之後的主機之間建立UDP通信。該協議由RFC 5389定義。STUN由三部分組成：STUN客戶端、STUN伺服器端、NAT路由器。STUN服務端部署在一台有著兩個公網IP的伺服器上。大概的結構參考下圖。STUN客戶端通過向伺服器端發送不同的消息類型，根據伺服器端不同的響應來做出相應的判斷，一旦客戶端得知了Internet端的UDP埠，通信就可以開始了。

STUN協議定義了三類測試過程來檢測NAT類型。

Test1： STUN Client通過埠{IP-C1:Port-C1}向STUN Server{IP-S1:Port-S1}發送一個Binding Request（沒有設置任何屬性）。STUN Server收到該請求後，通過埠{IP-S1:Port-S1}把它所看到的STUN Client的IP和埠{IP-M1,Port-M1}作為Binding Response的內容回送給STUN Client。 Test1#2：STUN Client通過埠{IP-C1:Port-C1}向STUN Server{IP-S2:Port-S2}發送一個Binding Request（沒有設置任何屬性）。STUN Server收到該請求後，通過埠{IP-S2:Port-S2}把它所看到的STUN Client的IP和埠{IP-M1#2,Port-M1#2}作為Binding Response的內容回送給STUN Client。

Test2： STUN Client通過埠{IP-C1:Port-C1}向STUN Server{IP-S1:Port-S1}發送一個Binding Request（設置了Change IP和Change Port屬性）。STUN Server收到該請求後，通過埠{IP-S2:Port-S2}把它所看到的STUN Client的IP和埠{IP-M2,Port-M2}作為Binding Response的內容回送給STUN Client。

Test3： STUN Client通過埠{IP-C1:Port-C1}向STUN Server{IP-S1:Port-S1}發送一個Binding Request（設置了Change Port屬性）。STUN Server收到該請求後，通過埠{IP-S1:Port-S2}把它所看到的STUN Client的IP和埠{IP-M3,Port-M3}作為Binding Response的內容回送給STUN Client。

STUN協議的輸出是： 1）公網IP和Port 2）防火牆是否設置 3）客戶端是否在NAT之後，及所處的NAT的類型

因此我們進而整理出，通過STUN協議，我們可以檢測的類型一共有以下七種：

A：公開的互聯網IP。主機擁有公網IP，並且沒有防火牆，可自由與外部通信 B：完全錐形NAT。 C：受限制錐形NAT。 D：埠受限制形NAT。 E：對稱型UDP防火牆。主機出口處沒有NAT設備,但有防火牆,且防火牆規則如下：從主機UDP埠A發出的數據包保持源地址，但只有從之前該主機發出包的目的IP/PORT發出到該主機埠A的包才能通過防火牆。 F：對稱型NAT G：防火牆限制UDP通信。

輸入和輸出准備好後，附上一張維基網路的流程圖，就可以描述STUN協議的判斷過程了。

STEP1：檢測客戶端是否有能力進行UDP通信以及客戶端是否位於NAT後 -- Test1 客戶端建立UDP socket，然後用這個socket向伺服器的（IP-1，Port-1）發送數據包要求伺服器返回客戶端的IP和Port，客戶端發送請求後立即開始接受數據包。重復幾次。 a）如果每次都超時收不到伺服器的響應，則說明客戶端無法進行UDP通信，可能是：G防火牆阻止UDP通信 b）如果能收到回應，則把伺服器返回的客戶端的（IP:PORT）同（Local IP: Local Port）比較： 如果完全相同則客戶端不在NAT後，這樣的客戶端是：A具有公網IP可以直接監聽UDP埠接收數據進行通信或者E。 否則客戶端在NAT後要做進一步的NAT類型檢測（繼續）。

STEP2：檢測客戶端防火牆類型 -- Test2 STUN客戶端向STUN伺服器發送請求，要求伺服器從其他IP和PORT向客戶端回復包： a）收不到伺服器從其他IP地址的回復，認為包前被前置防火牆阻斷，網路類型為E b）收到則認為客戶端處在一個開放的網路上，網路類型為A

STEP3：檢測客戶端NAT是否是FULL CONE NAT -- Test2 客戶端建立UDP socket然後用這個socket向伺服器的(IP-1,Port-1)發送數據包要求伺服器用另一對(IP-2,Port-2)響應客戶端的請求往回發一個數據包，客戶端發送請求後立即開始接受數據包。 重復這個過程若干次。 a）如果每次都超時，無法接受到伺服器的回應，則說明客戶端的NAT不是一個Full Cone NAT，具體類型有待下一步檢測（繼續）。 b）如果能夠接受到伺服器從(IP-2,Port-2)返回的應答UDP包，則說明客戶端是一個Full Cone NAT，這樣的客戶端能夠進行UDP-P2P通信。

STEP4：檢測客戶端NAT是否是SYMMETRIC NAT -- Test1#2 客戶端建立UDP socket然後用這個socket向伺服器的(IP-1,Port-1)發送數據包要求伺服器返回客戶端的IP和Port, 客戶端發送請求後立即開始接受數據包。 重復這個過程直到收到回應（一定能夠收到，因為第一步保證了這個客戶端可以進行UDP通信）。 用同樣的方法用一個socket向伺服器的(IP-2,Port-2)發送數據包要求伺服器返回客戶端的IP和Port。 比較上面兩個過程從伺服器返回的客戶端(IP,Port),如果兩個過程返回的(IP,Port)有一對不同則說明客戶端為Symmetric NAT，這樣的客戶端無法進行UDP-P2P通信（檢測停止）因為對稱型NAT，每次連接埠都不一樣，所以無法知道對稱NAT的客戶端，下一次會用什麼埠。否則是Restricted Cone NAT，是否為Port Restricted Cone NAT有待檢測（繼續）。

STEP5：檢測客戶端NAT是Restricted Cone 還是 Port Restricted Cone -- Test3 客戶端建立UDP socket然後用這個socket向伺服器的(IP-1,Port-1)發送數據包要求伺服器用IP-1和一個不同於Port-1的埠發送一個UDP 數據包響應客戶端, 客戶端發送請求後立即開始接受數據包。重復這個過程若干次。如果每次都超時，無法接受到伺服器的回應，則說明客戶端是一個Port Restricted Cone NAT，如果能夠收到伺服器的響應則說明客戶端是一個Restricted Cone NAT。以上兩種NAT都可以進行UDP-P2P通信。

通過以上過程，至此，就可以分析和判斷出客戶端是否處於NAT之後，以及NAT的類型及其公網IP，以及判斷客戶端是否具備P2P通信的能力了。當然這是自己個人筆記的第一篇，後面，再作一篇筆記《NAT穿透原理淺析（二）》分析下不同NAT類型的穿透打洞策略。

㈣ Java Socket 實現P2P

主動發起的會話的可以看成Client用socket、、被動接受的看成Server用ServerSocket、、、按你的做法、、A既有socket還有ServerSocket、、、socket用來主動連接其他客戶端、、、ServerSocket用於監聽其他客戶端是否發來連接請求

㈤ 誰知道p2p信貸系統源碼有哪幾種語言呢能詳細介紹下嗎

介紹下目前幾款主流的網貸系統源碼開發語言：
1. Java語言。java技術具有卓越的通用性、高效性、平台移植性和安全性，廣泛應用於個人PC、數據中心、游戲控制台、科學超級計算機、行動電話和互聯網等，優勢非常明顯。也是目前網貸系統製作最佳開發語言。
2. .NET語言。.NET可生成伸縮性和穩定性更好的應用程序，並提供更好的安全保護。鑒於安全性也是網貸源碼開發中會考慮使用的一種語言。
3. PHP語言。PHP語言也是目前用的非常多的一款開發語言，語法吸收了C語言、Java和Perl的特點，易於學習，使用廣泛，主要適用於Web開發領域。優勢非常明顯，支持幾乎所有流行的資料庫以及操作系統；最重要的是PHP可以用C、C++進行程序的擴展等等。如果考慮程序移植的話就比較麻煩了。以上內容摘自迪蒙網貸系統網路，希望對你有幫助。

㈥ 廣域網實現p2p文件傳輸 如何實現nat穿透 求java或C++源代碼

假設有兩台分別處於各自的私有網路中的主機：A和B；N1和N2是兩個NAT設備；S是一個使用了一個眾所周知的、從全球任何地方都能訪問得到的IP地址的公共伺服器
步驟一：A和B分別和S建立UDP連接；NAT設備N1和N2創建UDP轉換狀態並分配臨時的外部埠號
步驟二：S將這些埠號傳回A和B
步驟三：A和B通過轉換好的埠直接聯繫到對方的NAT設備；NAT設備則利用先前創建的轉換狀態將分組發往A和B

源碼已發送請查收

㈦ IPFS(四) 源碼解讀之-p2p

package p2p

import (
"context"
"errors"
"time"

net "gx/ipfs//go-libp2p-net"
manet "gx/ipfs//go-multiaddr-net"
ma "gx/ipfs//go-multiaddr"
pro "gx/ipfs//go-libp2p-protocol"
pstore "gx/ipfs//go-libp2p-peerstore"
p2phost "gx/ipfs//go-libp2p-host"
peer "gx/ipfs//go-libp2p-peer"
)
//P2P結構保存當前正在運行的流/監聽器的信息
// P2P structure holds information on currently running streams/listeners
type P2P struct {
//監聽器
Listeners ListenerRegistry
//數據流
Streams StreamRegistry
//節點ID
identity peer.ID
//節點地址
peerHost p2phost.Host
//一個線程安全的對等節點存儲
peerstore pstore.Peerstore
}
//創建一個新的p2p結構
// NewP2P creates new P2P struct
//這個新的p2p結構不包含p2p結構中的監聽器和數據流
func NewP2P(identity peer.ID, peerHost p2phost.Host, peerstore pstore.Peerstore) *P2P {
return &P2P{
identity: identity,
peerHost: peerHost,
peerstore: peerstore,
}
}
//新建一個數據流 工具方法 構建一個有節點id，內容和協議的流
func (p2p P2P) newStreamTo(ctx2 context.Context, p peer.ID, protocol string) (net.Stream, error) {
//30s 後會自動timeout
ctx, cancel := context.WithTimeout(ctx2, time.Second 30) //TODO: configurable?
defer cancel()
err := p2p.peerHost.Connect(ctx, pstore.PeerInfo{ID: p})
if err != nil {
return nil, err
}

return p2p.peerHost.NewStream(ctx2, p, pro.ID(protocol))
}
//對話為遠程監聽器創建新的P2P流
//創建一個新的p2p流實現對對話的監聽
// Dial creates new P2P stream to a remote listener
//Multiaddr是一種跨協議、跨平台的表示格式的互聯網地址。它強調明確性和自我描述。
//對內接收
func (p2p P2P) Dial(ctx context.Context, addr ma.Multiaddr, peer peer.ID, proto string, bindAddr ma.Multiaddr) ( ListenerInfo, error) {
//獲取一些節點信息 network, host, nil
lnet, _, err := manet.DialArgs(bindAddr)
if err != nil {
return nil, err
}
//監聽信息
listenerInfo := ListenerInfo{
//節點身份
Identity: p2p.identity,
////應用程序協議標識符。
Protocol: proto,
}
//調用newStreamTo 通過ctx（內容） peer（節點id） proto（協議標識符） 參數獲取一個新的數據流
remote, err := p2p.newStreamTo(ctx, peer, proto)
if err != nil {
return nil, err
}
//network協議標識
switch lnet {
//network為"tcp", "tcp4", "tcp6"
case "tcp", "tcp4", "tcp6":
//從監聽器獲取新的信息 nla.Listener, nil
listener, err := manet.Listen(bindAddr)
if err != nil {
if err2 := remote.Reset(); err2 != nil {
return nil, err2
}
return nil, err
}
//將獲取的新信息保存到listenerInfo
listenerInfo.Address = listener.Multiaddr()
listenerInfo.Closer = listener
listenerInfo.Running = true
//開啟接受
go p2p.doAccept(&listenerInfo, remote, listener)

default:
return nil, errors.New("unsupported protocol: " + lnet)
}

return &listenerInfo, nil
}
//
func (p2p *P2P) doAccept(listenerInfo *ListenerInfo, remote net.Stream, listener manet.Listener) {
//關閉偵聽器並刪除流處理程序
defer listener.Close()
//Returns a Multiaddr friendly Conn
//一個有好的 Multiaddr 連接
local, err := listener.Accept()
if err != nil {
return
}

stream := StreamInfo{
//連接協議
Protocol: listenerInfo.Protocol,
//定位節點
LocalPeer: listenerInfo.Identity,
//定位節點地址
LocalAddr: listenerInfo.Address,
//遠程節點
RemotePeer: remote.Conn().RemotePeer(),
//遠程節點地址
RemoteAddr: remote.Conn().RemoteMultiaddr(),
//定位
Local: local,
//遠程
Remote: remote,
//注冊碼
Registry: &p2p.Streams,
}
//注冊連接信息
p2p.Streams.Register(&stream)
//開啟節點廣播
stream.startStreaming()
}
//偵聽器將流處理程序包裝到偵聽器中
// Listener wraps stream handler into a listener
type Listener interface {
Accept() (net.Stream, error)
Close() error
}
//P2PListener保存關於偵聽器的信息
// P2PListener holds information on a listener
type P2PListener struct {
peerHost p2phost.Host
conCh chan net.Stream
proto pro.ID
ctx context.Context
cancel func()
}
//等待偵聽器的連接
// Accept waits for a connection from the listener
func (il *P2PListener) Accept() (net.Stream, error) {
select {
case c := <-il.conCh:
return c, nil
case <-il.ctx.Done():
return nil, il.ctx.Err()
}
}
//關閉偵聽器並刪除流處理程序
// Close closes the listener and removes stream handler
func (il *P2PListener) Close() error {
il.cancel()
il.peerHost.RemoveStreamHandler(il.proto)
return nil
}
// Listen創建新的P2PListener
// Listen creates new P2PListener
func (p2p P2P) registerStreamHandler(ctx2 context.Context, protocol string) ( P2PListener, error) {
ctx, cancel := context.WithCancel(ctx2)

list := &P2PListener{
peerHost: p2p.peerHost,
proto: pro.ID(protocol),
conCh: make(chan net.Stream),
ctx: ctx,
cancel: cancel,
}

p2p.peerHost.SetStreamHandler(list.proto, func(s net.Stream) {
select {
case list.conCh <- s:
case <-ctx.Done():
s.Reset()
}
})

return list, nil
}
// NewListener創建新的p2p偵聽器
// NewListener creates new p2p listener
//對外廣播
func (p2p P2P) NewListener(ctx context.Context, proto string, addr ma.Multiaddr) ( ListenerInfo, error) {
//調用registerStreamHandler 構造一個新的listener
listener, err := p2p.registerStreamHandler(ctx, proto)
if err != nil {
return nil, err
}
//構造新的listenerInfo
listenerInfo := ListenerInfo{
Identity: p2p.identity,
Protocol: proto,
Address: addr,
Closer: listener,
Running: true,
Registry: &p2p.Listeners,
}

go p2p.acceptStreams(&listenerInfo, listener)
//注冊連接信息
p2p.Listeners.Register(&listenerInfo)

return &listenerInfo, nil
}
//接受流
func (p2p *P2P) acceptStreams(listenerInfo *ListenerInfo, listener Listener) {
for listenerInfo.Running {
//一個有好的 遠程 連接
remote, err := listener.Accept()
if err != nil {
listener.Close()
break
}

}
//取消注冊表中的p2p偵聽器
p2p.Listeners.Deregister(listenerInfo.Protocol)
}
// CheckProtoExists檢查是否注冊了協議處理程序
// mux處理程序
// CheckProtoExists checks whether a protocol handler is registered to
// mux handler
func (p2p *P2P) CheckProtoExists(proto string) bool {
protos := p2p.peerHost.Mux().Protocols()

for _, p := range protos {
if p != proto {
continue
}
return true
}
return false
}

㈧ 什麼是p2p網貸平台源碼網貸源碼有哪些

網貸，又稱為p2p網路借貸。P2P是英文peer to peer的縮寫，意即「個人對個人」。網路信貸起源於英國，隨後發展到美國、德國和其他國家，其典型的模式為：網路信貸公司提供平台，由借貸雙方自由競價，撮合成交。資金借出人獲取利息收益，並承擔風險；資金借入人到期償還本金，網路信貸公司收取中介服務費。p2p網貸平台源碼基本上是不可能給公開下載的，網上有部分p2p網貸源碼泄露了，那源碼也是被修改過很多次的了，會隱藏也多bug的。下載安裝後期維護成本很高，還不利於二次開發！你可以去看看迪蒙的網貸系統，中國網貸系統第一品牌，安全可靠，功能也很齊全，完全能滿足企業定製開發需求。