zhangzengfei
2023-08-11 a335f66c4c520728be640ca4e7029ce6f45b8f3d
main.go
@@ -1,12 +1,18 @@
package main
import (
   "plc-recorder/msg"
   "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 +22,23 @@
   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()
   // 订阅设备变更
   go nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "plc-recorder", collector.HandleDeviceUpdate)
   collector.InitTask()
   // 测试数据
   go msg.TestSendDeviceLiveData()
   select {}
}