fix

zhangqian

2023-11-02 0d776d70a4db593f04b515c568227b7415732a89

fix

 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.Laddr.IP, conn.Laddr.Port)
        fmt.Println("net.Connections ipPort", ipPort)
        if ipPort == conf.Conf.NsqConf.NsqdAddr && conn.Status == "ESTABLISHED" {
            return true