完善连接过程. 添加重连

zhangzengfei

2023-08-01 e8c97695dd6930465e66b8fac819301f03624512

 main.go

@@ -1,12 +1,17 @@
package main

import (
   "runtime"

   "plc-recorder/collector"
   "plc-recorder/config"
   "plc-recorder/logger"
   "plc-recorder/nsqclient"

   "github.com/rs/zerolog"
)

var logFilePath = "./log/plc-recorder.log"

func main() {
   // 初始化配置
@@ -16,11 +21,16 @@
   zerolog.SetGlobalLevel(zerolog.FatalLevel)

   // 初始化日志
   logger.InitLog("./log/plc-recorder.log", "debug", 15, false)
   if runtime.GOOS == "windows" {
      logFilePath = "log/plc-recorder.log"
   }
   logger.InitLog(logFilePath, "debug", 15, false)
   logger.Info("plc-recorde start!")

   // 初始化nsq
   nsqclient.InitNsqProducer()

   collector.InitTask()

   select {}
}