feat: 添加对 zxid 使用的采集 (#1411)

* feat: 添加对 zxid 使用的采集

Signed-off-by: ruochen <wanxialianwei@gmail.com>

* chore(zookeeper):  parse zxid string

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* chore(zookeeper): update  inputs/zookeeper/zookeeper.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* chore(zookeeper): handle command not executed case in gatherSrvrResult

---------

Signed-off-by: ruochen <wanxialianwei@gmail.com>
Co-authored-by: kongfei605 <kongfei605@gmail.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: 3 people

inputs/zookeeper/zookeeper.go

@@ -157,6 +157,18 @@ func (ins *Instance) gatherOneHost(wg *sync.WaitGroup, slist *types.SampleList,
 
 	ins.gatherRuokResult(ruokConn, slist, tags)
 
+	srvrConn, err := ins.ZkConnect(zkHost)
+	if err != nil {
+		slist.PushFront(types.NewSample("", "zk_zxid", 0, tags))
+		log.Println("E! failed to connect zookeeper:", zkHost, "error:", err)
+		return
+	}
+
+	defer srvrConn.Close()
+
+	srvrConn.SetDeadline(time.Now().Add(time.Duration(ins.Timeout) * time.Second))
+	ins.gatherSrvrResult(srvrConn, slist, tags)
+
 }
 
 func (ins *Instance) gatherMntrResult(conn net.Conn, slist *types.SampleList, globalTags map[string]string) {
@@ -239,6 +251,30 @@ func (ins *Instance) gatherRuokResult(conn net.Conn, slist *types.SampleList, gl
 	}
 }
 
+func (ins *Instance) gatherSrvrResult(conn net.Conn, slist *types.SampleList, globalTags map[string]string) {
+	res := sendZookeeperCmd(conn, "srvr")
+	if strings.Contains(res, cmdNotExecutedSffx) {
+		log.Printf(commandNotAllowedTmpl, "srvr", conn.RemoteAddr().String())
+		slist.PushFront(types.NewSample("", "zk_zxid", 0, globalTags))
+		return
+	}
+	lines := strings.Split(res, "\n")
+
+	for _, l := range lines {
+		if !strings.HasPrefix(l, "Zxid:") {
+			continue
+		}
+		zxidStr := strings.TrimSpace(strings.Split(l, ":")[1])
+		zxid, err := strconv.ParseUint(zxidStr, 0, 64)
+		if err != nil {
+			log.Printf("E! failed to parse zxid: %s", err)
+			return
+		}
+		low4Bytes := zxid & 0xFFFFFFFF
+		slist.PushFront(types.NewSample("", "zk_zxid_used", low4Bytes, globalTags))
+	}
+}
+
 func sendZookeeperCmd(conn net.Conn, cmd string) string {
 	_, err := conn.Write([]byte(cmd))
 	if err != nil {