zhangzengfei
2023-08-11 a335f66c4c520728be640ca4e7029ce6f45b8f3d
main.go
@@ -1,6 +1,7 @@
package main
import (
   "plc-recorder/msg"
   "runtime"
   "plc-recorder/collector"
@@ -24,6 +25,7 @@
   if runtime.GOOS == "windows" {
      logFilePath = "log/plc-recorder.log"
   }
   logger.InitLog(logFilePath, "debug", 15, false)
   logger.Info("plc-recorde start!")
@@ -31,9 +33,12 @@
   nsqclient.InitNsqProducer()
   // 订阅设备变更
   nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "sensor01", collector.HandleDeviceUpdate)
   go nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "plc-recorder", collector.HandleDeviceUpdate)
   collector.InitTask()
   // 测试数据
   go msg.TestSendDeviceLiveData()
   select {}
}