兄弟連Go語(yǔ)言+區(qū)塊鏈技術(shù)培訓(xùn)以太坊源碼分析(39)geth啟動(dòng)流程分析

1、 11/11兄弟連Go語(yǔ)言+區(qū)鏈技術(shù)培訓(xùn)以太坊源碼分析(39）geth啟動(dòng)流程分析geth是我們的go-ethereum最主要的一個(gè)命令行工具。 也是我們的各種網(wǎng)絡(luò)的接入點(diǎn)(主網(wǎng)絡(luò)main-net 測(cè)試網(wǎng)絡(luò)test-net 和私有網(wǎng)絡(luò))。支持運(yùn)行在全節(jié)點(diǎn)模式或者輕量級(jí)節(jié)點(diǎn)模式。 其他程序可以通過(guò)它暴露的JSON RPC調(diào)用來(lái)訪問(wèn)以太坊網(wǎng)絡(luò)的功能。如果什么命令都不輸入直接運(yùn)行g(shù)eth。 就會(huì)默認(rèn)啟動(dòng)一個(gè)全節(jié)點(diǎn)模式的節(jié)點(diǎn)。 連接到主網(wǎng)絡(luò)。 我們看看啟動(dòng)的主要流程是什么，涉及到了那些組件。# 啟動(dòng)的main函數(shù) cmd/geth/main.go看到main函數(shù)一上來(lái)就直接運(yùn)行了。 最開(kāi)始看的時(shí)候是有

2、點(diǎn)懵逼的。 后面發(fā)現(xiàn)go語(yǔ)言里面有兩個(gè)默認(rèn)的函數(shù)，一個(gè)是main()函數(shù)。一個(gè)是init()函數(shù)。 go語(yǔ)言會(huì)自動(dòng)按照一定的順序先調(diào)用所有包的init()函數(shù)。然后才會(huì)調(diào)用main()函數(shù)。func main() if err := app.Run(os.Args); err != nil fmt.Fprintln(os.Stderr, err)os.Exit(1)main.go的init函數(shù)app是一個(gè)三方包gopkg.in/urfave/cli.v1的實(shí)例。 這個(gè)三方包的用法大致就是首先構(gòu)造這個(gè)app對(duì)象。 通過(guò)代碼配置app對(duì)象的行為，提供一些回調(diào)函數(shù)。然后運(yùn)行的時(shí)候直接在main函數(shù)里

3、面運(yùn)行 app.Run(os.Args)就行了。import (.gopkg.in/urfave/cli.v1)var (app = utils.NewApp(gitCommit, the go-ethereum command line interface)/ flags that configure the nodenodeFlags = cli.Flagutils.IdentityFlag,utils.UnlockedAccountFlag,utils.PasswordFileFlag,utils.BootnodesFlag,.rpcFlags = cli.Flagutils.RPCEn

4、abledFlag,utils.RPCListenAddrFlag,.whisperFlags = cli.Flagutils.WhisperEnabledFlag,.)func init() / Initialize the CLI app and start Geth/ Action字段表示如果用戶(hù)沒(méi)有輸入其他的子命令的情況下，會(huì)調(diào)用這個(gè)字段指向的函數(shù)。app.Action = gethapp.HideVersion = true / we have a command to print the versionapp.Copyright = Copyright 2013-2017 The

5、go-ethereum Authors/ Commands 是所有支持的子命令app.Commands = cli.Command/ See chaincmd.go:initCommand,importCommand,exportCommand,removedbCommand,dumpCommand,/ See monitorcmd.go:monitorCommand,/ See accountcmd.go:accountCommand,walletCommand,/ See consolecmd.go:consoleCommand,attachCommand,javascriptComman

6、d,/ See misccmd.go:makecacheCommand,makedagCommand,versionCommand,bugCommand,licenseCommand,/ See config.godumpConfigCommand,sort.Sort(cli.CommandsByName(app.Commands)/ 所有能夠解析的Optionsapp.Flags = append(app.Flags, nodeFlags.)app.Flags = append(app.Flags, rpcFlags.)app.Flags = append(app.Flags, consol

7、eFlags.)app.Flags = append(app.Flags, debug.Flags.)app.Flags = append(app.Flags, whisperFlags.)app.Before = func(ctx *cli.Context) error runtime.GOMAXPROCS(runtime.NumCPU()if err := debug.Setup(ctx); err != nil return err/ Start system runtime metrics collectiongo metrics.CollectProcessMetrics(3 * t

8、ime.Second)utils.SetupNetwork(ctx)return nilapp.After = func(ctx *cli.Context) error debug.Exit()console.Stdin.Close() / Resets terminal mode.return nil如果我們沒(méi)有輸入任何的參數(shù)，那么會(huì)自動(dòng)調(diào)用geth方法。/ geth is the main entry point into the system if no special subcommand is ran./ It creates a default node based on the

9、command line arguments and runs it in/ blocking mode, waiting for it to be shut down./ 如果沒(méi)有指定特殊的子命令，那么geth是系統(tǒng)主要的入口。/ 它會(huì)根據(jù)提供的參數(shù)創(chuàng)建一個(gè)默認(rèn)的節(jié)點(diǎn)。并且以阻塞的模式運(yùn)行這個(gè)節(jié)點(diǎn)，等待著節(jié)點(diǎn)被終止。func geth(ctx *cli.Context) error node := makeFullNode(ctx)startNode(ctx, node)node.Wait()return nilmakeFullNode函數(shù)，func makeFullNode(ctx *cl

10、i.Context) *node.Node / 根據(jù)命令行參數(shù)和一些特殊的配置來(lái)創(chuàng)建一個(gè)nodestack, cfg := makeConfigNode(ctx)/ 把eth的服務(wù)注冊(cè)到這個(gè)節(jié)點(diǎn)上面。 eth服務(wù)是以太坊的主要的服務(wù)。 是以太坊功能的提供者。utils.RegisterEthService(stack, &cfg.Eth)/ Whisper must be explicitly enabled by specifying at least 1 whisper flag or in dev mode/ Whisper是一個(gè)新的模塊，用來(lái)進(jìn)行加密通訊的功能。 需要顯式的提供參數(shù)來(lái)啟

11、用，或者是處于開(kāi)發(fā)模式。shhEnabled := enableWhisper(ctx)shhAutoEnabled := !ctx.GlobalIsSet(utils.WhisperEnabledFlag.Name) & ctx.GlobalIsSet(utils.DevModeFlag.Name)if shhEnabled | shhAutoEnabled if ctx.GlobalIsSet(utils.WhisperMaxMessageSizeFlag.Name) cfg.Shh.MaxMessageSize = uint32(ctx.Int(utils.WhisperMaxMessa

12、geSizeFlag.Name)if ctx.GlobalIsSet(utils.WhisperMinPOWFlag.Name) cfg.Shh.MinimumAcceptedPOW = ctx.Float64(utils.WhisperMinPOWFlag.Name)/ 注冊(cè)Shh服務(wù)utils.RegisterShhService(stack, &cfg.Shh)/ Add the Ethereum Stats daemon if requested.if cfg.Ethstats.URL != / 注冊(cè) 以太坊的狀態(tài)服務(wù)。 默認(rèn)情況下是沒(méi)有啟動(dòng)的。utils.RegisterEthSta

13、tsService(stack, cfg.Ethstats.URL)/ Add the release oracle service so it boots along with node./ release oracle服務(wù)是用來(lái)查看客戶(hù)端版本是否是最新版本的服務(wù)。/ 如果需要更新。 那么會(huì)通過(guò)打印日志來(lái)提示版本更新。/ release 是通過(guò)智能合約的形式來(lái)運(yùn)行的。 后續(xù)會(huì)詳細(xì)討論這個(gè)服務(wù)。if err := stack.Register(func(ctx *node.ServiceContext) (node.Service, error) config := release.Confi

14、gOracle: relOracle,Major: uint32(params.VersionMajor),Minor: uint32(params.VersionMinor),Patch: uint32(params.VersionPatch),commit, _ := hex.DecodeString(gitCommit)copy(config.Commit:, commit)return release.NewReleaseService(ctx, config); err != nil utils.Fatalf(Failed to register the Geth release o

15、racle service: %v, err)return stackmakeConfigNode。 這個(gè)函數(shù)主要是通過(guò)配置文件和flag來(lái)生成整個(gè)系統(tǒng)的運(yùn)行配置。func makeConfigNode(ctx *cli.Context) (*node.Node, gethConfig) / Load defaults.cfg := gethConfigEth: eth.DefaultConfig,Shh: whisper.DefaultConfig,Node: defaultNodeConfig(),/ Load config file.if file := ctx.GlobalString

16、(configFileFlag.Name); file != if err := loadConfig(file, &cfg); err != nil utils.Fatalf(%v, err)/ Apply flags.utils.SetNodeConfig(ctx, &cfg.Node)stack, err := node.New(&cfg.Node)if err != nil utils.Fatalf(Failed to create the protocol stack: %v, err)utils.SetEthConfig(ctx, stack, &cfg.Eth)if ctx.Gl

17、obalIsSet(utils.EthStatsURLFlag.Name) cfg.Ethstats.URL = ctx.GlobalString(utils.EthStatsURLFlag.Name)utils.SetShhConfig(ctx, stack, &cfg.Shh)return stack, cfgRegisterEthService/ RegisterEthService adds an Ethereum client to the stack.func RegisterEthService(stack *node.Node, cfg *eth.Config) var err

18、 error/ 如果同步模式是輕量級(jí)的同步模式。 那么啟動(dòng)輕量級(jí)的客戶(hù)端。if cfg.SyncMode = downloader.LightSync err = stack.Register(func(ctx *node.ServiceContext) (node.Service, error) return les.New(ctx, cfg) else / 否則會(huì)啟動(dòng)全節(jié)點(diǎn)err = stack.Register(func(ctx *node.ServiceContext) (node.Service, error) fullNode, err := eth.New(ctx, cfg)if

19、 fullNode != nil & cfg.LightServ 0 / 默認(rèn)LightServ的大小是0 也就是不會(huì)啟動(dòng)LesServer/ LesServer是給輕量級(jí)節(jié)點(diǎn)提供服務(wù)的。ls, _ := les.NewLesServer(fullNode, cfg)fullNode.AddLesServer(ls)return fullNode, err)if err != nil Fatalf(Failed to register the Ethereum service: %v, err)startNode/ startNode boots up the system node and

20、all registered protocols, after which/ it unlocks any requested accounts, and starts the RPC/IPC interfaces and the/ miner.func startNode(ctx *cli.Context, stack *node.Node) / Start up the node itselfutils.StartNode(stack)/ Unlock any account specifically requestedks := stack.AccountManager().Backen

21、ds(keystore.KeyStoreType)0.(*keystore.KeyStore)passwords := utils.MakePasswordList(ctx)unlocks := strings.Split(ctx.GlobalString(utils.UnlockedAccountFlag.Name), ,)for i, account := range unlocks if trimmed := strings.TrimSpace(account); trimmed != unlockAccount(ctx, ks, trimmed, i, passwords)/ Regi

22、ster wallet event handlers to open and auto-derive walletsevents := make(chan accounts.WalletEvent, 16)stack.AccountManager().Subscribe(events)go func() / Create an chain state reader for self-derivationrpcClient, err := stack.Attach()if err != nil utils.Fatalf(Failed to attach to self: %v, err)stat

23、eReader := ethclient.NewClient(rpcClient)/ Open any wallets already attachedfor _, wallet := range stack.AccountManager().Wallets() if err := wallet.Open(); err != nil log.Warn(Failed to open wallet, url, wallet.URL(), err, err)/ Listen for wallet event till terminationfor event := range events swit

24、ch event.Kind case accounts.WalletArrived:if err := event.Wallet.Open(); err != nil log.Warn(New wallet appeared, failed to open, url, event.Wallet.URL(), err, err)case accounts.WalletOpened:status, _ := event.Wallet.Status()log.Info(New wallet appeared, url, event.Wallet.URL(), status, status)if event.Wallet.URL().Scheme = ledger event.Wallet.SelfDerive(accounts.DefaultLedgerBaseDerivationPath, stateReader) else event.Wallet.SelfDerive(accounts.DefaultBaseDerivationPath, stateReader)case accounts.WalletDropped:log.Info(Old wallet dropped, url, event.W