zabbix服务器监控之了解agent的启动过程-阿里云开发者社区

zabbix功能介绍

Zabbix是一种开源的网络监控和管理工具，用于监测各种网络参数、服务器健康状况和网络服务的可用性。以下是Zabbix的主要功能介绍：

多种监控方式：

代理监控： 客户端安装Zabbix代理程序，通过代理程序向Zabbix服务器报告监控数据。
SNMP监控： 支持Simple Network Management Protocol，可以监控网络设备和其他支持SNMP的设备。
JMX监控： 支持Java Management Extensions，用于监控Java应用程序。
IPMI监控： 支持Intelligent Platform Management Interface，用于监控服务器硬件。

灵活的数据收集：

支持自定义监控项，可以监控各种性能参数，如CPU利用率、内存使用、磁盘空间等。
通过Zabbix Trapper协议，可以从其他系统或应用程序发送自定义数据到Zabbix服务器。

通知和报警：

支持灵活的报警配置，可以根据不同的条件设置报警规则。
可以通过多种方式发送报警通知，包括电子邮件、短信、声音等。
支持根据不同时间段和用户角色定义报警策略。

图形化监控：

提供实时监控和历史数据图表，方便用户可视化监控数据趋势。
支持自定义监控仪表盘，用户可以根据需要创建和定制仪表盘。

自动发现和配置：

支持自动发现新设备和服务，并自动进行监控配置。
可以通过模板来批量配置监控项，简化大规模部署的管理工作。

安全性和认证：

支持用户认证和授权，可以设置不同用户角色和权限。
通过SSL/TLS加密确保数据的安全传输。

报告和分析：

提供各种报告和分析工具，帮助用户了解系统性能和趋势。
可以导出数据并集成到其他分析工具中。

分布式监控：

支持分布式监控架构，适用于大规模和复杂的网络环境。

总体而言，Zabbix是一款强大而灵活的监控工具，适用于各种规模和类型的网络和服务器环境。其开源性质使其成为企业和组织中广泛使用的监控解决方案之一。

既然zabbix是依赖agent来收集数据的，那么agent的启动方式就非常重要了。下面，我们就来一起看看agent的启动方式。

agent的启动方式

zabbix中包含两种zabbix agent，今天我们介绍的是zabbix agent2，zabbix agent1已经停止维护了。zabbix agent2是zabbix agent的升级版，它支持更多的功能和更好的性能。它使用go语言编写，支持多平台。go语言的特点是编译后体积小，跨平台。在多线程方面，go语言比c/c++要强很多。这得益于go语言内置的并发机制。

下图是zabbix agent2的架构图。

zabbix agent2的启动方式有两种，一种是独立启动，一种是集成到zabbix server中。下面我们就从源码的角度来介绍一下它的启动过程。

zabbix_agent2,go

zabbix agent2的启动过程在zabbix_agent2.go文件中，它的入口函数是main。它的相对路径是：src\go\cmd\zabbix_agent2\zabbix_agent2.go。

让我们来分析一下main函数。

version.Init(applicationName, tls.CopyrightMessage(), copyrightMessageMQTT(), copyrightMessageModbus())

  var confFlag string
  const (
    confDescription = "Path to the configuration file"
  )
  flag.StringVar(&confFlag, "config", confDefault, confDescription)
  flag.StringVar(&confFlag, "c", confDefault, confDescription+" (shorthand)")

  var foregroundFlag bool
  const (
    foregroundDefault     = true
    foregroundDescription = "Run Zabbix agent in foreground"
  )
  flag.BoolVar(&foregroundFlag, "foreground", foregroundDefault, foregroundDescription)
  flag.BoolVar(&foregroundFlag, "f", foregroundDefault, foregroundDescription+" (shorthand)")

  var testFlag string
  const (
    testDefault     = ""
    testDescription = "Test specified item and exit"
  )
  flag.StringVar(&testFlag, "test", testDefault, testDescription)
  flag.StringVar(&testFlag, "t", testDefault, testDescription+" (shorthand)")

  var printFlag bool
  const (
    printDefault     = false
    printDescription = "Print known items and exit"
  )
  flag.BoolVar(&printFlag, "print", printDefault, printDescription)
  flag.BoolVar(&printFlag, "p", printDefault, printDescription+" (shorthand)")

  var verboseFlag bool
  const (
    verboseDefault     = false
    verboseDescription = "Enable verbose output for metric testing or printing"
  )
  flag.BoolVar(&verboseFlag, "verbose", verboseDefault, verboseDescription)
  flag.BoolVar(&verboseFlag, "v", verboseDefault, verboseDescription+" (shorthand)")

  var versionFlag bool
  const (
    versionDefault     = false
    versionDescription = "Print program version and exit"
  )
  flag.BoolVar(&versionFlag, "version", versionDefault, versionDescription)
  flag.BoolVar(&versionFlag, "V", versionDefault, versionDescription+" (shorthand)")

  var remoteCommand string
  const remoteDefault = ""
  var remoteDescription = "Perform administrative functions (send 'help' for available commands) " +
    "(" + remoteCommandSendingTimeout.String() + " timeout)"
  flag.StringVar(&remoteCommand, "R", remoteDefault, remoteDescription)

  var helpFlag bool
  const (
    helpDefault     = false
    helpDescription = "Display this help message"
  )
  flag.BoolVar(&helpFlag, "help", helpDefault, helpDescription)
  flag.BoolVar(&helpFlag, "h", helpDefault, helpDescription+" (shorthand)")

  loadOSDependentFlags()
  flag.Parse()
  setServiceRun(foregroundFlag)

  if helpFlag {
    flag.Usage()
    os.Exit(0)
  }

  var argConfig, argTest, argPrint, argVersion, argVerbose bool

  // Need to manually check if the flag was specified, as default flag package
  // does not offer automatic detection. Consider using third party package.
  flag.Visit(func(f *flag.Flag) {
    switch f.Name {
    case "c", "config":
      argConfig = true
    case "t", "test":
      argTest = true
    case "p", "print":
      argPrint = true
    case "V", "version":
      argVersion = true
    case "v", "verbose":
      argVerbose = true
    }
  })

  if argVersion {
    version.Display([]string{fmt.Sprintf("Plugin communication protocol version is %s", comms.ProtocolVersion)})
    os.Exit(0)
  }

上面这段代码的作用是初始化Zabbix Agent 2的版本信息和相关协议的版权信息，以及一些命令行参数，用于配置Zabbix Agent 2的运行参数。这些参数包括配置文件路径、是否在前台运行、测试模式、打印模式、详细输出等。同时还会加载与操作系统相关的标志，

打开事件日志

  var err error
  if err = openEventLog(); err != nil {
    fatalExit("", err)
  }

  if err = validateExclusiveFlags(); err != nil {
    if eerr := eventLogErr(err); eerr != nil {
      err = fmt.Errorf("%s and %s", err, eerr)
    }
    fatalExit("", err)
  }

这段代码的主要功能是尝试打开事件日志并验证一些标志，如果出现任何错误，就调用 fatalExit 函数以退出程序并打印错误信息。

初始化配置文件

  if err = conf.Load(confFlag, &agent.Options); err != nil {
    if argConfig || !(argTest || argPrint) {
      if eerr := eventLogErr(err); eerr != nil {
        err = fmt.Errorf("%s and %s", err, eerr)
      }
      fatalExit("", err)
    }
    // create default configuration for testing options
    if !argConfig {
      _ = conf.Unmarshal([]byte{}, &agent.Options)
    }
  }

这段代码主要是对配置文件的加载和解析操作，同时对可能出现的错误进行了处理。如果没有错误，那么它会使用加载的配置信息；如果有错误，那么它会尝试使用默认的配置信息，同时会根据传入的命令行参数来决定是否输出详细的错误信息并终止程序。

验证配置文件

  if err = agent.ValidateOptions(&agent.Options); err != nil {
    if eerr := eventLogErr(err); eerr != nil {
      err = fmt.Errorf("%s and %s", err, eerr)
    }
    fatalExit("cannot validate configuration", err)
  }

这段代码首先调用 agent.ValidateOptions 函数来验证 agent.Options 配置选项的有效性。如果验证过程中出现错误，那么将调用 eventLogErr 函数来对错误进行处理，然后用 fmt.Errorf 创建一个新的错误信息，该错误信息包含了原始错误和 eventLogErr 产生的错误。最后，调用 fatalExit 函数以错误信息作为参数，以 "cannot validate configuration" 作为前缀输出错误信息并退出程序。

处理 Windows 服务

  if err = agent.ValidateOptions(&agent.Options); err != nil {
    if eerr := eventLogErr(err); eerr != nil {
      err = fmt.Errorf("%s and %s", err, eerr)
    }
    fatalExit("cannot validate configuration", err)
  }

这段代码首先调用 handleWindowsService 函数处理 Windows 服务相关操作。如果在这个过程中出现错误，那么将调用 eventLogErr 函数来对错误进行处理，然后用 fmt.Errorf 创建一个新的错误信息，该错误信息包含了原始错误和 eventLogErr 产生的错误。最后，调用 fatalExit 函数以错误信息作为参数，不添加任何前缀直接输出错误信息并退出程序。

  if remoteCommand != "" {
    if agent.Options.ControlSocket == "" {
      log.Errf("Cannot send remote command: ControlSocket configuration parameter is not defined")
      os.Exit(0)
    }

    if reply, err := remotecontrol.SendCommand(agent.Options.ControlSocket, remoteCommand,
      remoteCommandSendingTimeout); err != nil {
      log.Errf("Cannot send remote command: %s", err)
    } else {
      log.Infof(reply)
    }
    os.Exit(0)
  }

这段代码块是用于处理在Zabbix Agent 2启动时指定了远程命令（通过 -R 参数指定）。以下是对代码块的详细解释：

if remoteCommand != "" { ... }：检查是否指定了远程命令。
if agent.Options.ControlSocket == "" { ... }：检查是否配置了控制套接字（ControlSocket）。Zabbix Agent 2可以通过控制套接字接收远程命令。如果未配置控制套接字，将打印错误信息并退出程序。
if reply, err := remotecontrol.SendCommand(agent.Options.ControlSocket, remoteCommand, remoteCommandSendingTimeout); err != nil { ... }：如果控制套接字配置正常，使用remotecontrol.SendCommand函数发送远程命令。如果发送远程命令时出现错误，将打印错误信息。
log.Infof(reply)：如果成功发送远程命令，打印成功信息。
os.Exit(0)：程序执行完远程命令后立即退出。

这段代码的作用是，当用户在启动Zabbix Agent 2时使用了 -R 参数并指定了远程命令时，会通过控制套接字将该命令发送给Zabbix Agent 2。这个功能允许用户通过远程命令与Zabbix Agent 2进行交互，执行一些特定的操作。例如，用户可以通过远程命令查询某些信息、修改配置等。

初始化外部插件并获取与之通信的套接字

agent主程序与外部插件之间的通信是通过套接字实现的。Zabbix Agent 2在启动时，会初始化外部插件并获取与之通信的套接字。

  if pluginsocket, err = initExternalPlugins(&agent.Options); err != nil {
    fatalExit("cannot register plugins", err)
  }
  defer cleanUpExternal()

这段代码用于初始化外部插件并获取与之通信的套接字（pluginsocket）。以下是对代码块的详细解释：

initExternalPlugins(&agent.Options)：调用initExternalPlugins函数，该函数负责初始化和注册Zabbix Agent 2的外部插件。这些外部插件可能包括自定义的数据收集或处理模块。
pluginsocket, err = initExternalPlugins(&agent.Options)：将initExternalPlugins的返回值（套接字和错误信息）分配给变量pluginsocket和err。
defer cleanUpExternal()：使用defer关键字，确保在当前函数执行完毕后（即退出作用域）调用cleanUpExternal函数。cleanUpExternal函数用于在Zabbix Agent 2停止或发生致命错误时进行清理工作，关闭与外部插件通信的套接字等。
if err != nil { fatalExit("cannot register plugins", err) }：如果在初始化外部插件时发生错误，调用fatalExit函数，该函数用于以致命错误的方式退出程序，并打印错误信息。

总体而言，这段代码的作用是在Zabbix Agent 2启动时，初始化并注册外部插件，并获取与这些插件通信的套接字。在程序执行结束时，通过defer确保调用cleanUpExternal函数，以便在需要时执行必要的清理操作。

配置和初始化日志系统

  var logType, logLevel int
  switch agent.Options.LogType {
  case "system":
    logType = log.System
  case "console":
    logType = log.Console
  case "file":
    logType = log.File
  }
  switch agent.Options.DebugLevel {
  case 0:
    logLevel = log.Info
  case 1:
    logLevel = log.Crit
  case 2:
    logLevel = log.Err
  case 3:
    logLevel = log.Warning
  case 4:
    logLevel = log.Debug
  case 5:
    logLevel = log.Trace
  }

  if err = log.Open(logType, logLevel, agent.Options.LogFile, agent.Options.LogFileSize); err != nil {
    fatalExit("cannot initialize logger", err)
  }

  zbxlib.SetLogLevel(logLevel)

这段代码主要用于配置和初始化日志系统，具体来说，它完成了以下操作：

日志类型和级别的映射：

通过检查 agent.Options.LogType 的值，将其映射到 logType，支持的类型包括 "system"、"console" 和 "file"。
通过检查 agent.Options.DebugLevel 的值，将其映射到 logLevel，支持的级别为 0 到 5。

初始化日志系统：

使用 log.Open 函数初始化日志系统，指定日志的类型、级别、日志文件名和文件大小。
如果初始化过程中出现错误，调用 fatalExit 函数，以致命错误的方式退出程序，并打印错误信息。

设置 Zabbix Agent 2 内部库（zbxlib）的日志级别：

使用 zbxlib.SetLogLevel 将 Zabbix Agent 2 内部库的日志级别设置为与刚才映射的 logLevel 相同的值。

总体来说，这段代码的作用是在 Zabbix Agent 2 启动时，根据配置文件中指定的日志类型和调试级别，初始化并配置日志系统。这有助于记录关键信息、警告和调试信息，以便后续故障排除和监控。

Zabbix Agent 2 启动时进行一些准备工作

addresses, err := serverconnector.ParseServerActive()
  if err != nil {
    fatalExit("cannot parse the \"ServerActive\" parameter", err)
  }

  if tlsConfig, err := agent.GetTLSConfig(&agent.Options); err != nil {
    fatalExit("cannot use encryption configuration", err)
  } else {
    if tlsConfig != nil {
      if err = tls.Init(tlsConfig); err != nil {
        fatalExit("cannot configure encryption", err)
      }
    }
  }

   if pidFile, err = pidfile.New(agent.Options.PidFile); err != nil {
    fatalExit("cannot initialize PID file", err)
  }
  defer pidFile.Delete()

  log.Infof("using configuration file: %s", confFlag)

  if err = keyaccess.LoadRules(agent.Options.AllowKey, agent.Options.DenyKey); err != nil {
    fatalExit("Failed to load key access rules", err)
    os.Exit(1)
  }

解析服务器活动地址（ServerActive）：

使用 serverconnector.ParseServerActive() 函数解析配置文件中的 "ServerActive" 参数。该参数通常指定 Zabbix 服务器用于主动连接到代理的地址。
如果解析过程中出现错误（err != nil），则调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

获取和配置 TLS（传输层安全）：

使用 agent.GetTLSConfig(&agent.Options) 函数获取 TLS 配置信息。这通常涉及到使用证书和密钥等信息进行安全通信。
如果获取 TLS 配置时出现错误，调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。
如果成功获取了 TLS 配置且配置不为 nil，则调用 tls.Init(tlsConfig) 函数来初始化 TLS。这一步是为了配置 Zabbix Agent 2 使用 TLS 进行安全通信。
如果初始化过程中出现错误，同样调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

初始化 PID 文件：

使用 pidfile.New(agent.Options.PidFile) 函数初始化一个 PID 文件对象。这用于管理 Zabbix Agent 2 进程的 PID（进程标识符）文件。
如果初始化 PID 文件过程中出现错误（err != nil），则调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。
使用 defer pidFile.Delete() 来确保在程序执行结束时（或函数返回时）删除 PID 文件。这是为了确保在程序退出时清理相关资源。

记录配置文件信息：

使用 log.Infof("using configuration file: %s", confFlag) 将配置文件的路径信息记录到日志中。这有助于跟踪 Zabbix Agent 2 使用的配置文件。

加载密钥访问规则：

使用 keyaccess.LoadRules(agent.Options.AllowKey, agent.Options.DenyKey) 函数加载密钥访问规则。这些规则定义了允许和拒绝访问的密钥。
如果加载密钥访问规则过程中出现错误，调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。
在出现错误的情况下，调用 os.Exit(1) 来确保程序以非零状态码退出。一般来说，非零状态码表示程序执行过程中发生了错误。

启动 Zabbix Agent 2 的插件

if _, err = agent.InitUserParameterPlugin(agent.Options.UserParameter, agent.Options.UnsafeUserParameters,
    agent.Options.UserParameterDir); err != nil {
    fatalExit("cannot initialize user parameters", err)
  }

  if manager, err = scheduler.NewManager(&agent.Options); err != nil {
    fatalExit("cannot create scheduling manager", err)
  }

  // replacement of deprecated StartAgents
  if 0 != len(agent.Options.Server) {
    var listenIPs []string
    if listenIPs, err = serverlistener.ParseListenIP(&agent.Options); err != nil {
      fatalExit("cannot parse \"ListenIP\" parameter", err)
    }
    for i := 0; i < len(listenIPs); i++ {
      listener := serverlistener.New(i, manager, listenIPs[i], &agent.Options)
      listeners = append(listeners, listener)
    }
  }
  if err = loadOSDependentItems(); err != nil {
    fatalExit("cannot load os dependent items", err)
  }

  if foregroundFlag {
    if agent.Options.LogType != "console" {
      fmt.Println(greeting)
    }
  }

  manager.Start()

初始化用户参数插件：

使用 agent.InitUserParameterPlugin 函数初始化用户参数插件。这个插件允许用户自定义监控项和采集数据的方式。
如果初始化过程中出现错误（err != nil），则调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

创建调度管理器（scheduler.Manager）：

使用 scheduler.NewManager 函数创建调度管理器（manager）。调度管理器负责定期执行任务，如监控项的采集等。
如果创建调度管理器过程中出现错误，同样调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

替代废弃的 StartAgents 操作：

解析 "ListenIP" 参数，获取监听的 IP 地址列表。
遍历监听的 IP 地址列表，为每个 IP 地址创建一个服务器监听器（serverlistener）。
将这些监听器添加到 listeners 切片中。
检查配置中的服务器地址（agent.Options.Server）。如果有至少一个服务器地址配置，则执行以下操作：
这一部分代码涉及到废弃的 StartAgents 操作的替代方案。

加载与操作系统相关的项（os dependent items）：

使用 loadOSDependentItems 函数加载与操作系统相关的监控项。这可能涉及到采集与操作系统相关的性能数据或信息。
如果加载过程中出现错误，同样调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

前台模式输出欢迎信息：

如果运行在前台模式（foregroundFlag 为 true）且日志类型不是 "console"，则打印欢迎信息（greeting）到标准输出。

启动调度管理器：

使用 manager.Start() 启动调度管理器，开始定期执行任务。

这段代码的目的是在 Zabbix Agent 2 启动时进行初始化和准备工作，包括初始化用户参数插件、创建调度管理器、替代废弃的操作、加载与操作系统相关的监控项，并在前台模式下输出欢迎信息。这些操作都有助于确保代理能够正确执行监控任务和与 Zabbix 服务器进行通信。

而这里的manager.Start()函数，就是启动插件调度管理器，插件会注册到manager中，并开始定期执行任务。


  if err = configUpdateItemParameters(manager, &agent.Options); err != nil {
    fatalExit("cannot process configuration", err)
  }

  hostnames, err := agent.ValidateHostnames(agent.Options.Hostname)
  if err != nil {
    fatalExit("cannot parse the \"Hostname\" parameter", err)
  }
  agent.FirstHostname = hostnames[0]
  hostmessage := fmt.Sprintf("Zabbix Agent2 hostname: [%s]", agent.Options.Hostname)
  log.Infof(hostmessage)
  if foregroundFlag {
    if agent.Options.LogType != "console" {
      fmt.Println(hostmessage)
    }
    fmt.Println("Press Ctrl+C to exit.")
  }
  if err = resultcache.Prepare(&agent.Options, addresses, hostnames); err != nil {
    fatalExit("cannot prepare result cache", err)
  }

  serverConnectors = make([]*serverconnector.Connector, len(addresses)*len(hostnames))

  var idx int
  for i := 0; i < len(addresses); i++ {
    for j := 0; j < len(hostnames); j++ {
      if serverConnectors[idx], err = serverconnector.New(manager, addresses[i], hostnames[j], &agent.Options); err != nil {
        fatalExit("cannot create server connector", err)
      }
      serverConnectors[idx].Start()
      agent.SetHostname(serverConnectors[idx].ClientID(), hostnames[j])
      idx++
    }
  }
   agent.SetPerformTask(manager.PerformTask)

  for _, listener := range listeners {
    if err = listener.Start(); err != nil {
      fatalExit("cannot start server listener", err)
    }
  }

  if agent.Options.StatusPort != 0 {
    if err = statuslistener.Start(manager, confFlag); err != nil {
      fatalExit("cannot start HTTP listener", err)
    }
  }

  if err == nil {
    err = run()
  }

更新监控项参数配置：

调用 configUpdateItemParameters 函数，将配置文件中的监控项参数应用到调度管理器 (manager) 和 Zabbix Agent 2 的选项中。
如果更新配置过程中出现错误（err != nil），则调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

验证主机名参数：

调用 agent.ValidateHostnames 函数，解析和验证配置文件中的主机名参数 (agent.Options.Hostname)。
如果解析过程中出现错误，同样调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。
将解析后的主机名存储在 hostnames 变量中，并将第一个主机名设置为 agent.FirstHostname。

输出主机名信息：

根据解析后的主机名信息，构建一条主机名相关的信息字符串 (hostmessage)。
使用 log.Infof 函数将主机名信息记录到日志中。

在前台模式下输出主机名信息：

如果运行在前台模式 (foregroundFlag 为 true)，并且日志类型不是 "console"，则将主机名信息通过 fmt.Println 打印到标准输出。
输出提示信息，告知用户按 Ctrl+C 可以退出。

准备结果缓存：

调用 resultcache.Prepare 函数，准备用于缓存监控项结果的数据结构。
如果准备过程中出现错误，同样调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

创建并启动服务器连接器：

创建一个切片 serverConnectors 用于存储服务器连接器。
通过嵌套循环，为每个服务器地址和主机名组合创建一个服务器连接器。
如果创建连接器的过程中出现错误，同样调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。
启动每个连接器，并将连接器相关信息设置到 agent 对象中。

设置任务执行函数：

使用 agent.SetPerformTask 方法设置 Zabbix Agent 2 的执行任务函数为 manager.PerformTask。这意味着 Zabbix Agent 2 在后续的运行中将执行由调度管理器 (manager) 中指定的任务。

启动服务器监听器：

遍历 listeners 切片，其中包含了为每个监听 IP 地址创建的服务器监听器。
对每个监听器调用 listener.Start() 方法，以启动服务器监听器。如果启动过程中出现错误，调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。

启动 HTTP 监听器（如果配置了）：

调用 statuslistener.Start 方法，启动 HTTP 监听器。HTTP 监听器通常用于提供与 Zabbix Agent 2 的状态和性能相关的信息，以便通过 HTTP 接口查询。
如果启动过程中出现错误，同样调用 fatalExit 函数以致命错误的方式退出程序，并打印错误信息。
如果 Zabbix Agent 2 的配置中指定了 HTTP 监听端口（agent.Options.StatusPort != 0），则执行以下步骤：

运行主程序：

如果以上操作中没有发生错误（err == nil），则调用 run 函数，运行主程序。
主程序可能包含 Zabbix Agent 2 在运行时需要执行的主要逻辑。

结束程序

if err != nil {
    log.Errf("cannot start agent: %s", err.Error())
  }

  if agent.Options.StatusPort != 0 {
    statuslistener.Stop()
  }
  for _, listener := range listeners {
    listener.Stop()
  }
  for i := 0; i < len(serverConnectors); i++ {
    serverConnectors[i].StopConnector()
  }
  monitor.Wait(monitor.Input)

  manager.Stop()

  monitor.Wait(monitor.Scheduler)

  for i := 0; i < len(serverConnectors); i++ {
    serverConnectors[i].StopCache()
  }
  monitor.Wait(monitor.Output)
  farewell := fmt.Sprintf("Zabbix Agent 2 stopped. (%s)", version.Long())
  log.Infof(farewell)

  if foregroundFlag && agent.Options.LogType != "console" {
    fmt.Println(farewell)
  }

  waitServiceClose()

这段代码是在 Zabbix Agent 2 停止运行时执行的清理和关闭操作。以下是每个部分的作用：

检查启动错误：

如果在 Zabbix Agent 2 启动阶段发生了错误（err != nil），则记录错误信息到日志中，表明 Zabbix Agent 2 无法正常启动。

停止 HTTP 监听器（如果配置了）：

如果 Zabbix Agent 2 的配置中指定了 HTTP 监听端口（agent.Options.StatusPort != 0），则调用 statuslistener.Stop() 方法停止 HTTP 监听器。

停止服务器监听器：

遍历 listeners 切片，其中包含了为每个监听 IP 地址创建的服务器监听器。
对每个监听器调用 listener.Stop() 方法，以停止服务器监听器。

停止服务器连接器：

遍历 serverConnectors 切片，其中包含了为每个服务器地址和主机名组合创建的服务器连接器。
对每个连接器调用 serverConnectors[i].StopConnector() 方法，以停止服务器连接器。

等待输入监控器的完成：

调用 monitor.Wait(monitor.Input) 方法，等待输入监控器的完成。这可能涉及到等待尚未处理的输入任务完成。

停止调度管理器：

调用 manager.Stop() 方法，停止调度管理器的运行。这将导致 Zabbix Agent 2 停止定期执行任务。

等待调度监控器的完成：

调用 monitor.Wait(monitor.Scheduler) 方法，等待调度监控器的完成。这可能涉及到等待尚未处理的调度任务完成。

停止服务器连接器的缓存：

再次遍历 serverConnectors 切片，对每个连接器调用 serverConnectors[i].StopCache() 方法，以停止服务器连接器的缓存。

等待输出监控器的完成：

调用 monitor.Wait(monitor.Output) 方法，等待输出监控器的完成。这可能涉及到等待尚未处理的输出任务完成。

输出停止信息：

构建包含 Zabbix Agent 2 版本信息的停止信息字符串 (farewell)。
使用 log.Infof 方法将停止信息记录到日志中。

在前台模式下输出停止信息：

如果运行在前台模式 (foregroundFlag 为 true) 且日志类型不是 "console"，则通过 fmt.Println 打印停止信息到标准输出。

等待服务关闭：

调用 waitServiceClose() 方法，等待服务关闭。这可能是一个与操作系统服务相关的操作。

总体来说，这段代码的作用是在 Zabbix Agent 2 停止运行时进行一系列的清理和关闭操作，包括停止监听器、连接器、监控器等，并输出停止信息。这些步骤有助于确保 Zabbix Agent 2 在停止时能够完成必要的清理工作。

zabbix服务器监控之了解agent的启动过程

zabbix功能介绍

agent的启动方式

zabbix_agent2,go

打开事件日志

初始化配置文件

验证配置文件

处理 Windows 服务

初始化外部插件并获取与之通信的套接字

配置和初始化日志系统

Zabbix Agent 2 启动时进行一些准备工作

启动 Zabbix Agent 2 的插件

结束程序

热门文章

最新文章

相关课程

相关电子书

相关实验场景

推荐镜像

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

zabbix服务器监控之了解agent的启动过程

zabbix功能介绍

agent的启动方式

zabbix_agent2,go

打开事件日志

初始化配置文件

验证配置文件

处理 Windows 服务

初始化外部插件并获取与之通信的套接字

配置和初始化日志系统

Zabbix Agent 2 启动时进行一些准备工作

启动 Zabbix Agent 2 的插件

结束程序

热门文章

最新文章

相关课程

相关电子书

相关实验场景

推荐镜像