更改路由

zhangqian

2023-11-03 53d80c839ad2aad0a0482ca43fca1fc3a95b9d1c

 nsq/nsq.go

@@ -93,8 +93,7 @@
      return false
   }
   for _, conn := range connections {
      fmt.Println("net.Connections:", conn)
      ipPort := fmt.Sprintf("%s:%s", conn.Laddr.IP, conn.Laddr.Port)
      ipPort := fmt.Sprintf("%s:%d", conn.Raddr.IP, conn.Raddr.Port)
      fmt.Println("net.Connections ipPort", ipPort)
      if ipPort == conf.Conf.NsqConf.NsqdAddr && conn.Status == "ESTABLISHED" {
         return true