设为首页 加入收藏

TOP

学习RadonDB源码(一)(一)
2019-05-23 14:32:45 】 浏览:217
Tags:学习 RadonDB 源码

1. 可能是开始也可能是结束

RadonDB是国内知名云服务提供商青云开源的一款产品,下面是一段来自官方的介绍:

QingCloud RadonDB 是基于 MySQL 研发的新一代分布式关系型数据库,可无限水平扩展,支持分布式事务,具备金融级数据强一致性,满足企业级核心数据库对大容量、高并发、高可靠及高可用的极致要求。

做DBA的都知道关系型数据库在分布式数据库方面堪称举步维艰,虽然很多高手或者公司都开源了自己的中间件,但是很少有公司像青云这样将自己商用的成套解决方案直接开源的。可能开源版本和商用版本之间有很多功能差异,不过从解决方案的完整性角度来看,RadonDB堪称是良心产品了。

而且RadonDB的还有一个明显的好处是用Go编写的,而且现在的代码量也不算大,对于一个学习Go语言的人来说这是一个极好的项目。另外还有一点,RadonDB模拟了完整的MySQL Server端,里面有一项核心的东西叫做SQL解析器和优化器的,刚好可以借此机会从源码角度学习一下其思想。要知道MySQL虽然开源,但是整个项目都是用C编写的,很难看懂。

我打算用闲暇时间好好学习一下RadonDB源码,当然我可能半途而废,所以,这一篇可能是开始也可能是结束。

2. 入口的radon.go文件

这个文件在“radon/src/radon”目录下,代码只有区区82行,不过这是整个RadonDB的入口。

这段代码中利用了不少flag包用于接收参数,首先映入眼帘的是一堆import,此处就不加赘述了,因为毕竟只是引入了包,至于做什么的,代码写了就能知道。

接下来是包的初始化:

var (
    flagConf string
)

func init() {
    flag.StringVar(&flagConf, "c", "", "radon config file")
    flag.StringVar(&flagConf, "config", "", "radon config file")
}

flag是一个很好用的包,用于接收命令行参数,至于怎么用可以参考网上的资料。这个init()函数很有意思,这个函数会在很多书的“包初始化”一节来讲述,其实记住几个顺序就可以:

  1. 初始化导入的包;
  2. 在包级别为声明的变量计算并分配初始值;
  3. 执行包内的init函数。

这是包的初始化顺序,那么回到radon.go,初始化顺序也是一目了然的。

init函数不能被引用

接下来是一个简单的usage函数:

func usage() {
    fmt.Println("Usage: " + os.Args[0] + " [-c|--config] <radon-config-file>")
}

仅仅是为了打印命令行的帮助,在引用的时候才有效,现在只是声明。

而后就是程序的主入口main函数了,这段函数的最开始就执行了这样一句:

runtime.GOMAXPROCS(runtime.NumCPU())

声明了逻辑处理单元,数量和CPU核数相当,这一点在之前讲goroutine的笔记中讲述过。

紧接着,程序将获得一些关键的环境信息:

build := build.GetInfo()

虽然只有一句,但是背后的东西还是很丰富的:

func GetInfo() Info {
    return Info{
        GoVersion: runtime.Version(),
        Tag:       "8.0.0-" + tag,
        Time:      time,
        Git:       git,
        Platform:  platform,
    }
}

这是一种典型的结构体的初始化方式,如果对结构体不熟悉,建议也是百度一下相关资料。

这些打印出信息的东西无非就是一些显示输出,跟我们平时启动Spring的时候打印那个炫酷的SPRING banner没什么区别,接来下才是处理一些要紧的东西,比如处理配置:

    // config
    flag.Usage = func() { usage() }
    flag.Parse()
    if flagConf == "" {
        usage()
        os.Exit(0)
    }

    conf, err := config.LoadConfig(flagConf)
    if err != nil {
        log.Panic("radon.load.config.error[%v]", err)
    }
    log.SetLevel(conf.Log.Level)

其中的flag.Usage是函数变量,函数变量是一个新颖的概念,举一个例子说明:

func square(n int) int { return n*n }

f := square
//打印9
fmt.Println(f(3))

flag包中的Usage本身就是个函数变量。

上面这段业务代码主要做了这么几件事情:

  • 解析flag,得到命令行参数;
  • 判断参数是否为空,为空则打印使用说明并退出;
  • 加载配置项,并做异常处理;
  • 设置日志级别。

我们先不说紧接着要启动的Monitor了,这是一个性能指标监控,并不在我的学习范围内。

    // Proxy.
    proxy := proxy.NewProxy(log, flagConf, build.Tag, conf)
    proxy.Start()

代理是每个人写程序都挺喜欢写的名字。proxy是一个自行编写的包,我们来看看NewProxy的时候做了什么:

func NewProxy(log *xlog.Log, path string, serverVersion string, conf *config.Config) *Proxy {
    audit := audit.NewAudit(log, conf.Audit)
    router := router.NewRouter(log, conf.Proxy.MetaDir, conf.Router)
    scatter := backend.NewScatter(log, conf.Proxy.MetaDir)
    syncer := syncer.NewSyncer(log, conf.Proxy.MetaDir, conf.Proxy.PeerAddress, router, scatter)
    plugins := plugins.NewPlugin(log, conf, router, scatter)
    return &Proxy{
        log:           log,
        conf:          conf,
        confPath:      path,
        audit:         audit,
        router:        router,
        scatter:       scatter,
        syncer:        syncer,
        plugins:       plugins,
        sessions:      NewSessions(log),
        iptable:       NewIPTable(log, conf.Proxy),
        throttle:      xbase.NewThrottle(0),
        serverVersion: serverVersion,
    }
}

这段代码倒是很简单,就是利用入参中的配置项,声明了一系列的变量,并将这些变量封装在一个结构体内,然后返回。至于这些变量都是干什么的,我下次再说,这次只跟踪

首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇关于goquery的“non-standard imp.. 下一篇Docker 系列之 基础入门

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目