main.go @@ -30,6 +30,9 @@ // 初始化nsq nsqclient.InitNsqProducer() // 订阅设备变更 nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "sensor01", collector.HandleDeviceUpdate) collector.InitTask() select {}