Influxdb启动流程分析

Influxdb启动流程

  1. Influxdb的启动代码实现在 cmd/influxd/main.go
  2. influxd支持下面几种启动命令
 backup               downloads a snapshot of a data node and saves it to disk 
 config               display the default configuration                        
 help                 display this help message                                
 restore              uses a snapshot of a data node to rebuild a cluster      
 run                  run node with existing configuration                     
 version              displays the InfluxDB version                            

我们启动的话通常是 influxd run -config [config file path]

  1. 简单看一下run命令相关的代码:
func (m *Main) Run(args ...string) error {
    name, args := cmd.ParseCommandName(args)

    // Extract name from args.
    switch name {
    case "", "run":
        cmd := run.NewCommand()

        // Tell the server the build details.
        cmd.Version = version
        cmd.Commit = commit
        cmd.Branch = branch

        if err := cmd.Run(args...); err != nil {
            return fmt.Errorf("run: %s", err)
        }

        signalCh := make(chan os.Signal, 1)
        signal.Notify(signalCh, os.Interrupt, syscall.SIGTERM)
        cmd.Logger.Info("Listening for signals")

        // Block until one of the signals above is received
        <-signalCh
        cmd.Logger.Info("Signal received, initializing clean shutdown...")
        go cmd.Close()

        // Block again until another signal is received, a shutdown timeout elapses,
        // or the Command is gracefully closed
        cmd.Logger.Info("Waiting for clean shutdown...")
        select {
        case <-signalCh:
            cmd.Logger.Info("Second signal received, initializing hard shutdown")
        case <-time.After(time.Second * 30):
            cmd.Logger.Info("Time limit reached, initializing hard shutdown")
        case <-cmd.Closed:
            cmd.Logger.Info("Server shutdown completed")
        }
        ...
    }

    return nil
}

主要就是cmd := run.NewCommand()创建cmd对象,然后调用其Run方法

  1. 我们来看一下Command.Run的实现
func (cmd *Command) Run(args ...string) error {
    // 解析参数
    options, err := cmd.ParseFlags(args...)

    ...
    
    // 解析配置文件,初始化各组件的配置信息
    config, err := cmd.ParseConfig(options.GetConfigPath())
     
    // 初始化logger
    if cmd.Logger, logErr = config.Logging.New(cmd.Stderr); logErr != nil {
        // assign the default logger
        cmd.Logger = logger.New(cmd.Stderr)
    }
    
    // 如果配置了pid file path, 就写pud
    cmd.writePIDFile(options.PIDFile)
    
    // 创建Server对象,并调用Open方法将 Server运行起来
    s, err := NewServer(config, buildInfo)
    ...
    if err := s.Open(); err != nil {
        return fmt.Errorf("open server: %s", err)
    }

    // 开如monitor server error信息
    go cmd.monitorServerErrors()
}
  1. 我们来过一下NewServer的实现, 它主要的功能就是依据配置Server对象和它管理的各个组件, 主要包括
Monitor
MetaClient
TSDBStore
Subscriber
PoinitsWriter
QueryExecutor
...
  1. 紧接着会调用Server.Open添加各种service,让各个组件运行起来
// Open opens the meta and data store and all services.
func (s *Server) Open() error {
    // 创建并运行一个tcp的连接复用器
    ln, err := net.Listen("tcp", s.BindAddress)
    if err != nil {
        return fmt.Errorf("listen: %s", err)
    }
    s.Listener = ln

    // Multiplex listener.
    mux := tcp.NewMux()
    go mux.Serve(ln)

    // 添加各种service
    s.appendMonitorService()  // 
    s.appendPrecreatorService(s.config.Precreator) //预创建ShardGroup
    s.appendSnapshotterService() //使用上面的tcp连接复用器,处理snapshot相关的请求
    s.appendContinuousQueryService(s.config.ContinuousQuery) // 连续query服务
    s.appendHTTPDService(s.config.HTTPD) //http服务,接收并处理所有客户端的请求
    s.appendRetentionPolicyService(s.config.Retention) //依据RetentionPolicy周期性的作清理
    
    // Graphite, Collectd, OpenTSDB都会对其实TSDB数据格式的支持
    for _, i := range s.config.GraphiteInputs {
        if err := s.appendGraphiteService(i); err != nil {
            return err
        }
    }
    for _, i := range s.config.CollectdInputs {
        s.appendCollectdService(i)
    }
    for _, i := range s.config.OpenTSDBInputs {
        if err := s.appendOpenTSDBService(i); err != nil {
            return err
        }
    }
    for _, i := range s.config.UDPInputs {
        s.appendUDPService(i)
    }

    ...
    
    // Open TSDB store.
    if err := s.TSDBStore.Open(); err != nil {
        return fmt.Errorf("open tsdb store: %s", err)
    }

    // Open the subscriber service
    if err := s.Subscriber.Open(); err != nil {
        return fmt.Errorf("open subscriber: %s", err)
    }

    // Open the points writer service
    if err := s.PointsWriter.Open(); err != nil {
        return fmt.Errorf("open points writer: %s", err)
    }

    s.PointsWriter.AddWriteSubscriber(s.Subscriber.Points())

    for _, service := range s.Services {
        if err := service.Open(); err != nil {
            return fmt.Errorf("open service: %s", err)
        }
    }

    ...

    return nil
}

图解Influxd的启动流程

influxdb_run.png

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏XAI

SpringMVC+MongoDB+Maven整合(微信回调Oauth授权)

个人小程序。里面是基于百度大脑 腾讯优图做的人脸检测。是关于人工智能的哦。 2017年第一篇自己在工作中的总结文档。土豪可以打赏哦。 https://git.o...

8827
来自专栏IT技术精选文摘

Spring Boot使用过滤器和拦截器分别实现REST接口简易安全认证

8372
来自专栏猿天地

Spring Boot Async异步执行任务

异步调用就是不用等待结果的返回就执行后面的逻辑,同步调用则需要等带结果再执行后面的逻辑。

1702
来自专栏Android 研究

APK安装流程详解4——安装中关于so库的那些事

不同的Android手机使用不同的CPU,因此支持不同的指令集。CPU与指令集的每种组合都有其自己的应用二进制接口(或ABI)。"ABI"精确定义了"运行时,应...

3131
来自专栏分布式系统进阶

Kafka运维填坑Kafka源码分析-汇总

调用Runtime.getRuntime.halt(1)直接暴力退出了. 可参考Kafka issue: Unclean leader election an...

5900
来自专栏美码师

补习系列-springboot中的几种Scope

HTTP 头(Header)是一种附加内容,独立于请求内容和响应内容。 HTTP 协议中的大量特性都通过Header信息交互来实现,比如内容编解码、缓存、连接保...

832
来自专栏函数式编程语言及工具

Akka-Cluster(1)- Cluster Singleton 单例节点

关于cluster-singleton我在前面的博文已经介绍过,在这篇我想回顾一下它的作用和使用方法。首先,cluster-singleton就是集群某个节点上...

1213
来自专栏程序员互动联盟

【专业技术】Python爬虫:抓取手机APP的传输数据

1、抓取APP数据包 方法详细可以参考这篇博文:http://my.oschina.net/jhao104/blog/605963 得到超级课程表登录...

3745
来自专栏java思维导图

Spring思维导图,让Spring不再难懂(mvc篇)

在前面 生活就像海洋,只有意志坚强的人才能到达彼岸。已经很久没有发文章了呀,想必大家都挂念我了,哈哈。温故而知新,今天一起来复习一下spring mvc的内容吧...

3913
来自专栏ImportSource

Spring的三种Circuit Breaker

今天我们分享的内容是在spring下的三种circuit breaker的做法。接下来我们分别演示spring cloud netflix hystrix、sp...

7398

扫码关注云+社区

领取腾讯云代金券