### 處理兩個chan通道的消息 ``` // HandleEvents 處理兩個chan通道的消息：Blocks和Transactions // 將block消息或transaction消息通過節點的通信通道發布（Publish）到全網 func HandleEvents(net *Network) { for { select { case block := <-net.Blocks: ? ? ? ? ? net.SendBlock("", block) case tnx := <-net.Transactions: //mine := false ? ? ? ? ? net.SendTx("", tnx) } } } ``` ### SendTx ``` func (net *Network) SendTx(peerId string, transaction *blockchain.Transaction) { ? ? memoryPool.Add(*transaction) tnx := Tx{net.Host.ID().Pretty(), transaction.Serializer()} payload := GobEncode(tnx) request := append(CmdToBytes("tx"), payload...) // 給全節點（FullNode）的通信通道發布此消息，全節點（FullNode）將進行處理 ? ? net.FullNodesChannel.Publish("接收到 Send transaction 命令", request, peerId) } ``` ### Publish（channel.go) ``` // Publish 發布消息 func (channel *Channel) Publish(message string, payload []byte, SendTo string) error { m := ChannelContent{ ? ? ? ? Message: message, ? ? ? ? SendFrom: ShortID(channel.self), ? ? ? ? SendTo: SendTo, ? ? ? ? Payload: payload, } ? ? msgBytes, err := json.Marshal(m) if err != nil { return err } //從Publish實現來看，pub系統實際上也是直接將msgBytes發送到全網，并不先做解析，因此構建的消息結構只有Data和Topic賦值了 //From和Seqno均設置為nil。這意味著必然接受到消息 return channel.topic.Publish(channel.ctx, msgBytes) ```