btcd中对端发送的网络报文都在该处理函数：
func (p *Peer) inHandler() {
OnTx是一个函数接口，在初识化的时候注册的，注册代码如下：
在改函数func (sp *serverPeer) OnTx(_ *peer.Peer, msg *wire.MsgTx)中，把收到的交易消息放入msgchan消息队列
func (sm *SyncManager) QueueTx(tx *btcutil.Tx, peer *peerpkg.Peer, done chan struct{}) {
// Don‘t accept more transactions if we‘re shutting down.
if atomic.LoadInt32(&sm.shutdown) != 0 {
done <- struct{}{}
return
}
sm.msgChan <- &txMsg{tx: tx, peer: peer, reply: done}
}
从channel读取报文后，对消息的处理函数如下：
func (sm *SyncManager) handleTxMsg(tmsg *txMsg)
原文：https://www.cnblogs.com/xgcode/p/9126231.html