devpoint.cn

个人认为以太坊是区块链项目中带来技术重新认识和学习的不错的项目，特别是在P2P网络这一块。本文将介绍P2P网络中负责节点之间的通信连接和服务发现，本文的内容主要是对代码层级的理解，可能存在对其理解的错误，欢迎指点。包括以下两个方面：

• 种子节点初始化，节点发现
• 节点连接及相互通信

pending一种延迟处理逻辑，提供一个回调机制

• 当某一个操作发起异步请求时，就使用pending结构封装一个闭包，当收到异步回复后从pending列表取出这个闭包，执行回调，因此在这个回调里可以完成数据包校验等后处理，如findnode操作将更新k桶的操作暂存,再获取到异步回复后执行这个闭包完成k桶更新
• 提供多个回复接收功能，一个RPC请求可能会对应多个回复包，比如findnode对应多个neigbours回复包，此时可以提供多个pending进行逐个包校验

种子节点初始化及节点发现

这部分的逻辑的实现主要在p2p/discover/table.go中，在udp中newUDP方法调用newTable开始种子节点及节点的发现。

• newTable:执行该函数会传入Bootnodes信息，配置信息在params/bootnodes.go中，为初始连接节点，服务启动后就从这些节点开始进行节点的发现和扩散。关键执行方法
  • tab.setFallbackNodes：验证bootnodes信息，将节点信息赋值给tab.nursery
  • tab.seedRand：设置随机seed
  • tab.loadSeedNodes：将bootnodes加入路由表
  • tab.loop：创建goroutine发现节点并进行连接
    • tab.doRefresh：创建goroutine刷新所有节点（30分钟），并进行连接
    • tab.lookup：查找距离自己最近的节点
      • tab.closest：获取距离target最近的16个节点
      • tab.findnode：向最近的节点发起findnode请求，并增加处理neighborsPacket闭包的pending，具体实现为udp.go中的findnode，对于超过24小时没有接收到ping包的节点重新发送ping；对端节点接收到findnode请求后，查找附近的16个节点，并发送neighborsPacket

--

• findnode-neighbors 时序图

由于UDP有最大报文数限制，所以能够发送的邻近节点数目是有限的，需要拆包发送

节点连接及相互通信

P2P服务的启动位于p2p/server.go 中的Start()。

建立一个UDP连接服务discover.ListenUDP这个方法的关键实现是初始化三个通道，2个goroutine 。

• 三个通道

  • closing：关闭udp
  • gotreply：消息回复
  • addpending：pending消息处理

• 2个 goroutine

  • udp.loop()：主要监听t.gotreply和t.addpending
    • t.addpending：接收并增加一个闭包
    • t.gotreply：接收回复遍历，执行callback通知errC通道
  • udp.readLoop()：读取UDP数据包，执行t.handlePacket进行数据包处理
    • t.handlePacket：执行decodePacket对数据包进行解码，然后调用相应数据包的handle方法

网络传输四种数据包

• 数据包类型

const (
	pingPacket = iota + 1 // zero is 'reserved'
	pongPacket
	findnodePacket
	neighborsPacket
)

• 数据包结构

• ping-pong 时序图