精通Filecoin：Filecoin 源码之 Hello 协议

hello:=&Handler{host:h,genesis:gen,chainSyncCB:syncCallback,getHeaviestTipSet:getHeaviestTipSet,net:net,commitSha:commitSha,} 其中 host 对象为底层 libp2 提供的 Host 对象；genesis 为创世区块的 CID；chainSyncCB 为全节点对象的 syncCallBack 函数，用于从远程节点同步区块；getHeaviestTipSet 为 porcelain.API 对象的 ChainHead 方法（这个对象继承自 plumbing.API 对象，ChainHead 方法定义于后者），用于返回区块链头部的 tipset；net 表示当前的网络环境，比如测试网、正式网； 调用 host 对象的 SetStreamHandler 方法，设置自身的 handleNewStream 方法作为 /fil/hello/1.0.0 协议的处理器。

h.SetStreamHandler(protocol,hello.handleNewStream) 当连接建立时，通过后面注册的通知者，从而调用 sayHello 方法，在这个方法中打开一个 hello 协议的流，并发送 hello 消息。 调用 Host 对象的网络对象（即 swarm 对象）的 Notify 方法，把自身作为被通知者注册到网络对象上。

h.Network().Notify((*helloNotify)(hello)) 在这一步，通过调用 host 对象的 Network 方法，返回底层的 swarm 对象，然后把 hello 对象转化为 helloNotify 对象，最后调用 swarm 对象的 Notify 方法，从而当底层的 swarm 对象有任何事件发生时都会通知 helloNotify 对象（即 hello 对象）。

在 Hello 协议中我们只关心建立连接事件，所以 helloNotify 类型只实现了这个方法，其他方法都为空实现，具体如下：

typehelloNotifyHandler

func(hn*helloNotify)hello()*Handler{ return(*Handler)(hn) }

consthelloTimeout=time.Second*10

func(hn*helloNotify)Connected(nnet.Network,cnet.Conn){ gofunc(){ ctx,cancel:=context.WithTimeout(context.Background(),helloTimeout) defercancel() p:=c.RemotePeer() iferr:=hn.hello().sayHello(ctx,p);err!=nil{ log.Warningf("failedtosendhellohandshaketopeer%s:%s",p,err) } }() }

与此同时，当远程节点作为服务器，接收到我们发送的连接请求生成连接时，它的 swarm 对象也会通知它的所有 Notify 对象，从而也会它的前面注册的通知对象，即调用服务器商的 Connected 方法，从而调用它的 sayHello 方法向我们发送它的区块情况；因为第二步中，我们把 Hello 对象的 handleNewStream 方法注册为 Hello 协议的处理器，所以当节点接收到远程节点发送区块情况时，就会调用这个方法进行处理，这个方法又会调用调用全节点的 syncCallBack 方法进行区块同步处理。

sayHello 方法处理如下：

s,err:=h.host.NewStream(ctx,p,protocol)iferr!=nil{returnerr}defers.Close()//nolint:errcheck 调用自身的 getOurHelloMessage 方法，获取自身区块链顶端的信息。

msg:=h.getOurHelloMessage() 这个方法内部执行流程如下： 调用自身 getHeaviestTipSet 方法，获取区块链顶端的信息这个方法是 plumbing.API 对象 ChainHead 方法的引用。使用获取到的区块链信息，生成并返回消息对象 Message。 通过流发送区块信息到远程节点。handleNewStream 方法处理如下： 生成消息对象 Message，并从流中读取远程对等节点发送过来的内容到消息对象中。

varhelloMessageiferr:=cbu.NewMsgReader(s).ReadMsg(&hello);err!=nil{log.Debugf("badhellomessagefrompeer%s:%s",from,err)helloMsgErrCt.Inc(context.TODO(),1)s.Conn().Close()//nolint:errcheckreturn} 调用自身的 processHelloMessage 方法，处理远程节点发送的消息。这个方法代码如下：

func(h*Handler)processHelloMessage(frompeer.ID,msg*Message)error{if!msg.GenesisHash.Equals(h.genesis){returnErrBadGenesis}if(h.net=="devnet-test"||h.net=="devnet-user")&&msg.CommitSha!=h.commitSha{returnErrWrongVersion}

h.chainSyncCB(from,msg.HeaviestTipSetCids,msg.HeaviestTipSetHeight)returnnil

} 它的处理逻辑比较简单： 首先，检查远程节点发送的创世区块哈希是否自身的创世区块哈希相等。如果不等，直接返回错误。然后，检查网络类型。最终，调用自身的 chainSyncCB 方法，处理远程节点发送的区块信息。这个同步回调方法对象在全节点的启动方法 Start 中生成。它的主要生成就是根据远程节点发送的区块链最顶层的信息，生成一个 types/SortedCidSet 对象，然后调用 chain/syncer.go 中的 HandleNewTipset 方法来处理远程发送的区块信息。 根据前面处理消息的结果进行不同的处理。

switcherr:=h.processHelloMessage(from,&hello);err{caseErrBadGenesis:log.Debugf("genesiscid:%sdoesnotmatch:%s,disconnectingfrompeer:%s",&hello.GenesisHash,h.genesis,from)genesisErrCt.Inc(context.TODO(),1)s.Conn().Close()//nolint:errcheckreturncaseErrWrongVersion:log.Debugf("codenotatsameversion:peerhasversion%s,daemonhasversion%s,disconnectingfrompeer:%s",hello.CommitSha,h.commitSha,from)versionErrCt.Inc(context.TODO(),1)s.Conn().Close()//nolint:errcheckreturncasenil://ok,noopdefault:log.Error(err)}