zhangzengfei
2023-08-11 a335f66c4c520728be640ca4e7029ce6f45b8f3d
main.go
@@ -1,6 +1,7 @@
package main
import (
   "plc-recorder/msg"
   "runtime"
   "plc-recorder/collector"
@@ -24,13 +25,20 @@
   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 {}
}