package cfg import ( "cicv-data-closedloop/kinglong/common/log" "net" ) var TcpConnection net.Conn // InitTcpConfig 初始化TCP连接,用于发送时间窗口到从节点 func InitTcpConfig() { log.GlobalLogger.Info("主节点初始化TCP长连接 - 开始。") //var err error //socket := commonConfig.CloudConfig.Hosts[1].Ip + ":" + commonConfig.CloudConfig.TcpPort //for { // time.Sleep(time.Duration(1) * time.Second) // TcpConnection, err = net.Dial("tcp", socket) // if err != nil { // log.GlobalLogger.Error("主节点初始化TCP长连接 - 进行中:", err) // continue // } else { // log.GlobalLogger.Info("主节点初始化TCP长连接 - 成功:", socket) // break // } // //} }