nsq/msg_handler.go
@@ -118,6 +118,7 @@ key := strings.ReplaceAll(keys[i], "\r", "") address := cast.ToInt(strings.ReplaceAll(addresses[i], "\r", "")) plc_address.Set(key, address) logx.Infof("plc address set ok: key:%v, address:%v", key, address) } //通知回复收到 ReceivedMessageChan <- &ReceivedMessage{