| | |
| | | package main |
| | | |
| | | import ( |
| | | "plc-recorder/msg" |
| | | "runtime" |
| | | |
| | | "plc-recorder/collector" |
| | |
| | | if runtime.GOOS == "windows" { |
| | | logFilePath = "log/plc-recorder.log" |
| | | } |
| | | |
| | | logger.InitLog(logFilePath, "debug", 15, false) |
| | | logger.Info("plc-recorde start!") |
| | | |
| | |
| | | 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 {} |
| | | } |