热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

btcd(Bitcoingo)启动流程

btcdMain流程简化版代码1.main包btcd.gopackagemainimport(runtimedebugruntimegithub.combtcsuitebtcdli

btcdMain 流程

《btcd (Bitcoin go)启动流程》

简化版代码

1. main包

btcd.go

package main
import (
"runtime/debug"
"runtime"
"github.com/btcsuite/btcd/limits"
"fmt"
"os"
"net"
"btcd-demo/database"
)
var (
cfg *config
)
func winServiceMain()(bool, error) {
fmt.Println("btcd service runing...")
return true, nil
}
func btcdMain(serverChan chan<- *server) error {
// 加载配置,解析命令行选项。
tcfg, _, err := loadConfig()
if err != nil {
return err
}
cfg = tcfg
interrupt := interruptListener()
defer btcdLog.Info("Shutdown complete")
// 打印版本信息
btcdLog.Infof("Version %s", version())
// 开启http服务器性能监测
if cfg.Profile != "" {
go func() {
listenAddr := net.JoinHostPort("", cfg.Profile)
btcdLog.Infof("Profile server listening on %s", listenAddr)
}()
}
// 开启cpu性能监测
if cfg.CPUProfile != "" {
btcdLog.Info("CPU Profile start")
}
// 升级老版本数据库相关文件路径
if err := doUpgrades(); err != nil {
btcdLog.Errorf("%v", err)
return err
}
// 是否有中断信号
if interruptRequested(interrupt) {
return nil
}
// 加载区块数据库
db, err := loadBlockDB()
if err != nil {
btcdLog.Errorf("%v", err)
return err
}
defer func() {
btcdLog.Info("Gracefully shutting down the database...")
db.Close()
}()
// 是否有中断信号
if interruptRequested(interrupt) {
return nil
}
// 删除地址索引,并退出程序
//
// 注意: 在这里删除顺序很重要,因为删除交易索引同时也会删除地址索引。
// 因为交易索引会依赖地址索引
if cfg.DropAddrIndex {
btcdLog.Info("Drop Address index done")
}
// 删除交易索引,并退出程序
if cfg.DropTxIndex {
btcdLog.Info("Drop transaction index done")
}
// 删除交易索引,并退出程序
if cfg.DropCfIndex {
btcdLog.Info("Drop cf(committed filter) index done")
}
// 创建服务器,并启动
server, err := newServer(cfg.Listeners, db, activeNetParams.Params, interrupt)
if err != nil {
btcdLog.Errorf("Failed to start server on %v: %v", cfg.Listeners, err)
return err
}
defer func(){
btcdLog.Infof("Gracefully shutting down the server...")
server.Stop()
server.WaitForShutdown()
}()
server.Start()
if serverChan != nil {
serverChan <- server
}
//挂起主线程,等待中断信号
<-interrupt
return nil
}
func loadBlockDB()(database.DB, error) {
return &database.SimpleDB{}, nil
}
func main() {
//设置cpu最大使用数量,这里全部使用
runtime.GOMAXPROCS(runtime.NumCPU())
//设置触发GC垃圾收集器阀值: 10% , 即 最新分布的内存大小/上次GC之后活动内存大小*100
debug.SetGCPercent(10)
//设置进程能打开的最大文件资源,即file descriptor数量。做linux系统中,所有资源(pipe, socket, file等等)都以文件形式出现。
if err := limits.SetLimits(); err != nil {
fmt.Printf("Failed to set limits: %v \n", err)
os.Exit(1)
}
if runtime.GOOS == "windows" {
isService, err := winServiceMain()
if err != nil {
fmt.Printf("Failed to start windows service: %v \n", err)
}
if isService {
os.Exit(0)
}
}
if err := btcdMain(nil); err != nil {
fmt.Printf("Failed to start btcd server: %v", err)
os.Exit(1)
}
}

config.go

package main
type config struct {
Profile string
CPUProfile string
DropAddrIndex bool
DropTxIndex bool
DropCfIndex bool
Listeners []string
}
// loadConfig 通过配置文件,命令行选项来初始化配置
//
// 配置处理按下面的流程进行:
// 1 ) 启动时,使用默认配置
// 2 ) 预解释命令行,检查是否有另外指定的配置文件
// 3 ) 加载配置文件,并覆盖默认设置
// 4 ) 解释命令行选项,覆盖或添加新指定的配置
//
func loadConfig()(*config, []string, error) {
return &config{}, nil, nil
}

log.go

package main
import "fmt"
type Level uint32
type sLoger struct {
}
var (
btcdLog = new(sLoger)
)
func (l *sLoger)Tracef(format string, params ...interface{}) {
}
func (l *sLoger)Debugf(format string, params ...interface{}) {
}
// Infof formats message according to format specifier and writes to
// log with LevelInfo.
func (l *sLoger)Infof(format string, params ...interface{}) {
fmt.Printf(format, params)
fmt.Println()
}
// Warnf formats message according to format specifier and writes to
// to log with LevelWarn.
func (l* sLoger)Warnf(format string, params ...interface{}) {
}
// Errorf formats message according to format specifier and writes to
// to log with LevelError.
func (l* sLoger)Errorf(format string, params ...interface{}) {
fmt.Printf(format, params)
fmt.Println()
}
// Criticalf formats message according to format specifier and writes to
// log with LevelCritical.
func (l* sLoger)Criticalf(format string, params ...interface{}) {
}
// Trace formats message using the default formats for its operands
// and writes to log with LevelTrace.
func (l* sLoger)Trace(v ...interface{}) {
}
// Debug formats message using the default formats for its operands
// and writes to log with LevelDebug.
func (l* sLoger)Debug(v ...interface{}) {
}
// Info formats message using the default formats for its operands
// and writes to log with LevelInfo.
func (l* sLoger)Info(v ...interface{}) {
fmt.Printf("%s\n", v)
}
// Warn formats message using the default formats for its operands
// and writes to log with LevelWarn.
func (l* sLoger)Warn(v ...interface{}) {
}
// Error formats message using the default formats for its operands
// and writes to log with LevelError.
func (l* sLoger)Error(v ...interface{}) {
}
// Critical formats message using the default formats for its operands
// and writes to log with LevelCritical.
func (l* sLoger)Critical(v ...interface{}) {
}
// Level returns the current logging level.
func (l* sLoger)Level() Level {
return 0
}
// SetLevel changes the logging level to the passed level.
func (l* sLoger)SetLevel(level Level) {
}

params.go

package main
import "btcd-demo/chaincfg"
var activeNetParams = &mainNetParams
type params struct {
* chaincfg.Params
}
var mainNetParams = params{
}

server.go

package main
import (
"btcd-demo/database"
"btcd-demo/chaincfg"
)
type server struct {
}
func newServer(listeners []string, db database.DB, chainParams *chaincfg.Params, interrupt <-chan struct{}) (*server, error) {
return &server{}, nil
}
func (s *server) Stop() error {
btcdLog.Info("Server stop done")
return nil
}
func (s *server) Start() error {
btcdLog.Info("Server start...")
return nil
}
func (s *server) WaitForShutdown() error {
btcdLog.Info("Server wait for shutdown")
return nil
}

singal.go

package main
func interruptListener() <-chan struct{} {
c := make(chan struct{})
return c
}
func interruptRequested(interrupted <-chan struct{}) bool {
select {
case <- interrupted:
return true
default:
}
return false
}

upgrade.go

package main
func doUpgrades() error {
btcdLog.Info("doUpgrades done")
return nil
}

version.go

package main
func version() string {
return "1.0"
}

2. database包

interface.go

package database
type DB interface {
Type() string
Close() error
}

driver.go

package database
import "fmt"
type SimpleDB struct {
}
func (db *SimpleDB) Type() string {
return "SimpleDB"
}
func (db *SimpleDB) Close() error {
fmt.Printf("Close db done \n")
return nil
}

3. chaincfg包

params.go

package chaincfg
type Params struct {
}

项目地址:

https://github.com/hawkit/btcd-demo/tree/v0.0.1


推荐阅读
  • 关键词:Golang, Cookie, 跟踪位置, net/http/cookiejar, package main, golang.org/x/net/publicsuffix, io/ioutil, log, net/http, net/http/cookiejar ... [详细]
  • 微软头条实习生分享深度学习自学指南
    本文介绍了一位微软头条实习生自学深度学习的经验分享,包括学习资源推荐、重要基础知识的学习要点等。作者强调了学好Python和数学基础的重要性,并提供了一些建议。 ... [详细]
  • 本文介绍了将mysql从5.6.15升级到5.7.15的详细步骤,包括关闭访问、备份旧库、备份权限、配置文件备份、关闭旧数据库、安装二进制、替换配置文件以及启动新数据库等操作。 ... [详细]
  • 使用nodejs爬取b站番剧数据,计算最佳追番推荐
    本文介绍了如何使用nodejs爬取b站番剧数据,并通过计算得出最佳追番推荐。通过调用相关接口获取番剧数据和评分数据,以及使用相应的算法进行计算。该方法可以帮助用户找到适合自己的番剧进行观看。 ... [详细]
  • EPICS Archiver Appliance存储waveform记录的尝试及资源需求分析
    本文介绍了EPICS Archiver Appliance存储waveform记录的尝试过程,并分析了其所需的资源容量。通过解决错误提示和调整内存大小,成功存储了波形数据。然后,讨论了储存环逐束团信号的意义,以及通过记录多圈的束团信号进行参数分析的可能性。波形数据的存储需求巨大,每天需要近250G,一年需要90T。然而,储存环逐束团信号具有重要意义,可以揭示出每个束团的纵向振荡频率和模式。 ... [详细]
  • Nginx使用(server参数配置)
    本文介绍了Nginx的使用,重点讲解了server参数配置,包括端口号、主机名、根目录等内容。同时,还介绍了Nginx的反向代理功能。 ... [详细]
  • 目录实现效果:实现环境实现方法一:基本思路主要代码JavaScript代码总结方法二主要代码总结方法三基本思路主要代码JavaScriptHTML总结实 ... [详细]
  • Centos7.6安装Gitlab教程及注意事项
    本文介绍了在Centos7.6系统下安装Gitlab的详细教程,并提供了一些注意事项。教程包括查看系统版本、安装必要的软件包、配置防火墙等步骤。同时,还强调了使用阿里云服务器时的特殊配置需求,以及建议至少4GB的可用RAM来运行GitLab。 ... [详细]
  • Java容器中的compareto方法排序原理解析
    本文从源码解析Java容器中的compareto方法的排序原理,讲解了在使用数组存储数据时的限制以及存储效率的问题。同时提到了Redis的五大数据结构和list、set等知识点,回忆了作者大学时代的Java学习经历。文章以作者做的思维导图作为目录,展示了整个讲解过程。 ... [详细]
  • 本文介绍了C++中省略号类型和参数个数不确定函数参数的使用方法,并提供了一个范例。通过宏定义的方式,可以方便地处理不定参数的情况。文章中给出了具体的代码实现,并对代码进行了解释和说明。这对于需要处理不定参数的情况的程序员来说,是一个很有用的参考资料。 ... [详细]
  • Firefox火狐浏览器关闭到http://detectportal.firefox.com的流量问题解决办法
    本文介绍了使用Firefox火狐浏览器时出现关闭到http://detectportal.firefox.com的流量问题,并提供了解决办法。问题的本质是因为火狐默认开启了Captive portal技术,当连接需要认证的WiFi时,火狐会跳出认证界面。通过修改about:config中的network.captive-portal-service.en的值为false,可以解决该问题。 ... [详细]
  • 本文讨论了一个关于cuowu类的问题,作者在使用cuowu类时遇到了错误提示和使用AdjustmentListener的问题。文章提供了16个解决方案,并给出了两个可能导致错误的原因。 ... [详细]
  • 个人学习使用:谨慎参考1Client类importcom.thoughtworks.gauge.Step;importcom.thoughtworks.gauge.T ... [详细]
  • 开发笔记:实验7的文件读写操作
    本文介绍了使用C++的ofstream和ifstream类进行文件读写操作的方法,包括创建文件、写入文件和读取文件的过程。同时还介绍了如何判断文件是否成功打开和关闭文件的方法。通过本文的学习,读者可以了解如何在C++中进行文件读写操作。 ... [详细]
  • Imtryingtofigureoutawaytogeneratetorrentfilesfromabucket,usingtheAWSSDKforGo.我正 ... [详细]
author-avatar
高粱_
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有