作者：freewind
比原项目仓库：
Github地址：https://github.com/Bytom/bytom
Gitee地址：https://gitee.com/BytomBlockchain/bytom
我们知道，在使用bytomd init --chain_id mainnet/testnet/solonet初始化比原的时候，它会根据给定的chain_id的不同，使用不同的端口(参看config/toml.go#L29)：
mainnet（连接到主网）:46657testnet（连接到测试网）:46656solonet（本地单独节点）:46658
对于我来说，由于只需要对本地运行的一个比原节点进行分析，所以可以采用第3个chain_id，即solonet。这样它启动之后，不会与其它的节点主动连接，可以减少其它节点对于我们的干扰。
所以在启动的时候，我的命令是这样的：
cd cmd/bytomd ./bytomd init --chain_id solonet ./bytomd node
它就会监听46658端口，等待其它节点的连接。
连上看看
如果这时我们使用telnet来连接其46658端口，成功连接上之后，可以看到它会发给我们一些乱码，大概如下：
$ telnet localhost 46658 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. ??S??%?z???_?端??????U[e
我们也许会好奇，它发给我们的到底是什么？
但是这个问题留待下次回答，因为首先，比原节点必须能够监听这个端口，我们才能连上。所以这次我们的问题是：
比原在代码中是如何监听这个端口的?
端口已经写在config.toml中
在前面，当我们使用./bytomd init --chain_id solonet初始化比原以后，比原会在本地的数据目录中生成一个config.toml的配置文件，内容大约如下：
# This is a TOML config file. # For more information, see https://github.com/toml-lang/toml fast_sync = true db_backend = "leveldb" api_addr = "0.0.0.0:9888" chain_id = "solonet" [p2p] laddr = "tcp://0.0.0.0:46658" seeds = ""
其中[p2p]下面的laddr，就是该节点监听的地址和端口。
对于laddr = "tcp://0.0.0.0:46658"，它是意思是：
- 使用的是
tcp协议 - 监听的ip是
0.0.0.0，是指监听本机所有ip地址。这样该节点既允许本地访问，也允许外部主机访问。如果你只想让它监听某一个ip，手动修改该配置文件即可 46658，就是我们在这个问题中关注的端口了，它与该节点与其它节点交互数据使用的端口
比原在监听这个端口的时候，并不是如我最开始预期的直接调用net.Listen监听它。实际的过程要比这个复杂，因为比原设计了一个叫Switch的对象，用来统一管理与外界相关的事件，包括监听、连接、发送消息等。而Switch这个对象，又是在SyncManager中创建的。
启动直到进入Switch
所以我们首先需要知道，比原在源代码中是如何启动，并且一步步走进了Switch的世界。
首先还是当我们bytomd node启动比原时，对应的入口函数如下：
func main() {
cmd := cli.PrepareBaseCmd(commands.RootCmd, "TM", os.ExpandEnv(config.DefaultDataDir()))
cmd.Execute()
}
它又会根据传入的node参数，运行下面的函数：
cmd/bytomd/commands/run_node.go#L41
func runNode(cmd *cobra.Command, args []string) error {
// Create & start node
n := node.NewNode(config)
// ...
}
我们需要关注的是node.NewNode(config)函数，因为是在它里面创建了SyncManager：
func NewNode(config *cfg.Config) *Node {
// ...
syncManager, _ := netsync.NewSyncManager(config, chain, txPool, newBlockCh)
// ...
}
在创建SyncManager的时候，又创建了Switch:
func NewSyncManager(config *cfg.Config, chain *core.Chain, txPool *core.TxPool, newBlockCh chan *bc.Hash) (*SyncManager, error) {
// ...
manager.sw = p2p.NewSwitch(config.P2P, trustHistoryDB)
// ...
protocolReactor := NewProtocolReactor(chain, txPool, manager.sw, manager.blockKeeper, manager.fetcher, manager.peers, manager.newPeerCh, manager.txSyncCh, manager.dropPeerCh)
manager.sw.AddReactor("PROTOCOL", protocolReactor)
// Create & add listener
p, address := protocolAndAddress(manager.config.P2P.ListenAddress)
l := p2p.NewDefaultListener(p, address, manager.config.P2P.SkipUPNP, nil)
manager.sw.AddListener(l)
// ...
}
这里需要注意一下，上面创建的protocolReactor对象，是用来处理当有节点连接上端口后，双方如何交互的事情。跟这次问题“监听端口”没有直接关系，但是这里也可以注意一下。
然后又创建了一个DefaultListener对象，而监听端口的动作，就是在它里面发生的。Listener创建之后，将会添加到manager.sw（即Switch）中，用于在那边进行外界数据与事件的交互。
监听端口
NewDefaultListener中做的事情比较多，所以我们把它分成几块说：
func NewDefaul