在startNode中,一旦本地主机创建完成,需要将其纳入到区块链网络(P2P网络),我们执行:
err = SetupDiscovery(ctx, host)
我们再次把此函数的的实现copy如下:
```
// SetupDiscovery 建立发现机制,并将本地主机连接到所有已经发现的对等端(peer)
func SetupDiscovery(ctx context.Context, host host.Host) error {
// 开启一个DHT,用于对等端(peer)发现。
// 我们不仅仅是创建一个新的DHT,因为我们要求每一个端维护它自己的本地DHT副本,这样
// 以来,DHT的引导节点可以关闭,不会影响后续的对等端发现
kademliaDHT, err := dht.New(ctx, host)
if err != nil {
panic(err)
}
// 引导DHT。在缺省设置下,这生成一个后台线程,每5分钟刷新对等端表格
log.Info("引导DHT")
if err = kademliaDHT.Bootstrap(ctx); err != nil {
panic(err)
}
// 让我们首先连接到所有的引导节点(bootstrap nodes),它们会告诉我们网络中的其他节点
var wg sync.WaitGroup
for _, peerAddr := range dht.DefaultBootstrapPeers {
peerinfo, _ := peer.AddrInfoFromP2pAddr(peerAddr)
wg.Add(1)
//使用多个协程,加快连接处理
go func() {
defer wg.Done()
if err := host.Connect(ctx, *peerinfo); err != nil {
log.Error(err)
} else {
log.Info("连接已建立,使用的引导节点是:", *peerinfo)
}
}()
}
wg.Wait()//阻塞,确保所有的协程全部返回
// 我们使用一个会合点“wlsell.com”来宣布我们的位置
// 这就像告诉你的朋友在某个具体的地点会合
log.Info("宣布我们自己...")
routingDiscovery := discovery.NewRoutingDiscovery(kademliaDHT)
discovery.Advertise(ctx, routingDiscovery, "rendezvous:wlsell.com")
log.Info("成功宣布!")
// 现在,查找那些已经宣布的对等端
// 这就像你的朋友告诉你会合的地点
log.Info("搜索其它的对等端...")
peerChan, err := routingDiscovery.FindPeers(ctx, "rendezvous:wlsell.com")
if err != nil {
panic(err)
}
// 连接到所有新发现的对等端(peer)
for peer := range peerChan {
if peer.ID == host.ID() {
continue//不连接自己
}
log.Debug("找到对等端:", peer)
log.Debug("正在连接到:", peer)
err := host.Connect(context.Background(), peer)
if err != nil {
log.Warningf("连接到对等端 %s:失败 %s\\n", peer.ID.Pretty(), err)
continue
}
log.Info("已经连接到:", peer)
}
return nil
}
```
- 重要更新说明
- linechain发布
- linechain新版设计
- 引言一
- 引言二
- 引言三
- vs-code设置及开发环境设置
- BoltDB数据库应用
- 关于Go语言、VS-code的一些Tips
- 区块链的架构
- 网络通信与区块链
- 单元测试
- 比特币脚本语言
- 关于区块链的一些概念
- 区块链组件
- 区块链第一版:基本原型
- 区块链第二版:增加工作量证明
- 区块链第三版:持久化
- 区块链第四版:交易
- 区块链第五版:实现钱包
- 区块链第六版:实现UTXO集
- 区块链第七版:网络
- 阶段小结
- 区块链第八版:P2P
- P2P网络架构
- 区块链网络层
- P2P区块链最简体验
- libp2p建立P2P网络的关键概念
- 区块链结构层设计与实现
- 用户交互层设计与实现
- 网络层设计与实现
- 建立节点发现机制
- 向区块链网络请求区块信息
- 向区块链网络发布消息
- 运行区块链
- LineChain
- 系统运行流程
- Multihash
- 区块链网络的节点发现机制深入探讨
- DHT
- Bootstrap
- 连接到所有引导节点
- Advertise
- 搜索其它peers
- 连接到搜到的其它peers
- 区块链网络的消息订发布-订阅机制深入探讨
- LineChain:适用于智能合约编程的脚本语言支持
- LineChain:解决分叉问题
- LineChain:多重签名
- libp2p升级到v0.22版本
- 以太坊基础
- 重温以太坊的树结构
- 世界状态树
- (智能合约)账户存储树
- 交易树
- 交易收据树
- 小结
- 以太坊的存储结构
- 以太坊状态数据库
- MPT
- 以太坊POW共识算法
- 智能合约存储
- Polygon Edge
- block结构
- transaction数据结构
- 数据结构小结
- 关于本区块链的一些说明
- UML工具-PlantUML
- libp2p介绍
- JSON-RPC
- docker制作:启动多个应用系统
- Dockerfile
- docker-entrypoint.sh
- supervisord.conf
- docker run
- nginx.conf
- docker基础操作整理
- jupyter计算交互环境
- git技巧一
- git技巧二
- 使用github项目的最佳实践
- windows下package管理工具