区块链网络的节点发现机制深入探讨

在startNode中，一旦本地主机创建完成，需要将其纳入到区块链网络（P2P网络），我们执行：

err = SetupDiscovery(ctx, host)

我们再次把此函数的的实现copy如下：

  1. // SetupDiscovery 建立发现机制，并将本地主机连接到所有已经发现的对等端（peer）
  2. func  SetupDiscovery(ctx context.Context, host host.Host)  error  {
  3.  // 开启一个DHT，用于对等端（peer）发现。
  4.  // 我们不仅仅是创建一个新的DHT，因为我们要求每一个端维护它自己的本地DHT副本，这样
  5.  // 以来，DHT的引导节点可以关闭，不会影响后续的对等端发现
  6.     kademliaDHT, err := dht.New(ctx, host)
  7.  if err !=  nil  {
  8.  panic(err)
  9.  }
  11.  // 引导DHT。在缺省设置下，这生成一个后台线程，每5分钟刷新对等端表格
  12.     log.Info("引导DHT")
  13.  if err = kademliaDHT.Bootstrap(ctx); err !=  nil  {
  14.  panic(err)
  15.  }
  16.  // 让我们首先连接到所有的引导节点（bootstrap nodes），它们会告诉我们网络中的其他节点
  17.  var wg sync.WaitGroup
  18.  for _, peerAddr :=  range dht.DefaultBootstrapPeers {
  19.         peerinfo, _ := peer.AddrInfoFromP2pAddr(peerAddr)
  20.         wg.Add(1)
  21.         //使用多个协程，加快连接处理
  22.        go  func()  {
  23.        defer wg.Done()
  24.        if err := host.Connect(ctx,  *peerinfo); err !=  nil  {
  25.           log.Error(err)
  26.          }  else  {
  27.           log.Info("连接已建立，使用的引导节点是:",  *peerinfo)
  28.          }
  29.       }()
  30.     }
  31.     wg.Wait()//阻塞，确保所有的协程全部返回
  32.     // 我们使用一个会合点“wlsell.com”来宣布我们的位置
  33.     // 这就像告诉你的朋友在某个具体的地点会合
  34.     log.Info("宣布我们自己...")
  35.     routingDiscovery := discovery.NewRoutingDiscovery(kademliaDHT)
  36.     discovery.Advertise(ctx, routingDiscovery,  "rendezvous:wlsell.com")
  37.     log.Info("成功宣布!")
  38.     // 现在，查找那些已经宣布的对等端
  39.     // 这就像你的朋友告诉你会合的地点
  40.     log.Info("搜索其它的对等端...")
  41.     peerChan, err := routingDiscovery.FindPeers(ctx,  "rendezvous:wlsell.com")
  42.     if err !=  nil  {
  43.        panic(err)
  44.     }
  46.   // 连接到所有新发现的对等端（peer）
  47.  for peer :=  range peerChan {
  48.        if peer.ID == host.ID()  {
  49.        continue//不连接自己
  50.  }
  51.  log.Debug("找到对等端:", peer)
  52.  log.Debug("正在连接到:", peer)
  53. err := host.Connect(context.Background(), peer)
  54.  if err !=  nil  {
  55.     log.Warningf("连接到对等端 %s:失败 %s\\n", peer.ID.Pretty(), err)
  56.     continue
  57.   }
  58.  log.Info("已经连接到:", peer)
  59.  }
  60.  return  nil
  61. }