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 {} }