滴滴夜鶯nightingale v2版本 監控端口存活上報數據一直爲0修復

1. 小弟最近使用夜鶯監控系統v2版本時候，有一臺服務器9200端口報警，上報數據爲0，可是小弟我上服務器一看，發現已經監聽了，並且telnet和python socket均可以鏈接，這就納悶了，這是爲何呢？最後通過給官方提交issue，官方已經在v3版本修復了這個問題了，可是還在用v2版本的朋友們由於缺乏一些模塊，不太實用，因此就想着本身去修改一下源碼

    

    

    

    

2. 查看collector源碼，發現端口監控部分的代碼標紅部分須要修改
   

   func PortCollect(p *model.PortCollect) {
   value := 0
   if isListening(p.Port) {
   value = 1
   }

   item := core.GaugeValue("proc.port.listen", value, p.Tags)
   item.Step = int64(p.Step)
   item.Timestamp = time.Now().Unix()
   item.Endpoint = identity.Identity
   core.Push([]*dataobj.MetricValue{item})
   }

   func isListening(port int) bool {
   tcpAddress, err := net.ResolveTCPAddr("tcp4", fmt.Sprintf(":%v", port))
   if err != nil {
   logger.Errorf("net.ResolveTCPAddr(tcp4, :%v) fail: %v", port, err)
   return false
   }

   listener, err := net.ListenTCP("tcp", tcpAddress)
   if err != nil {
   logger.Debugf("cannot listen :%v(%v), so we think :%v is already listening", port, err, port)
   return true
   }
   listener.Close()

   return false
   }

   func isListen(port, timeout int, ip string) bool {
   var conn net.Conn
   var err error
   addr := fmt.Sprintf("%s:%d", ip, port)
   if timeout <= 0 {
   // default timeout 3 second
   timeout = 3
   }
   conn, err = net.DialTimeout("tcp", addr, time.Duration(timeout)*time.Second)
   if err != nil {
   return false
   }
   conn.Close()
   return true
   }

3. 用isListen函數去檢測端口存活
   func GetLocalIp() (result string) {
   addrs, err := net.InterfaceAddrs()
   result="127.0.0.1"
   if err != nil{
   fmt.Println(err)
   return result
   }
   for _, value := range addrs{
   if ipnet, ok := value.(*net.IPNet); ok && !ipnet.IP.IsLoopback(){
   if ipnet.IP.To4() != nil{
   result=ipnet.IP.String()
   return result
   }
   }
   }
   return result
   }

   
   

   func PortCollect(p *model.PortCollect) {
   value := 0
   local_ip := GetLocalIp()
   if isListen(p.Port, 1, "127.0.0.1") {
   value = 1
   } else if isListen(p.Port, 1, local_ip) {
   value = 1
   } else if isListen(p.Port, 1, "::1") {
   value = 1
   }

   item := core.GaugeValue("proc.port.listen", value, p.Tags)
   item.Step = int64(p.Step)
   item.Timestamp = time.Now().Unix()
   item.Endpoint = identity.Identity
   core.Push([]*dataobj.MetricValue{item})
   }

4. 去linux服務器編譯一下./control build collector, 發現好使了

    

    在此仍是要感謝滴滴的大佬們的解惑！