Cold_DeductionNotice/Nats/NatsServer/NatsMqtt.go

package NatsServer

import (
	"Cold_DeductionNotice/lib"
	"Cold_DeductionNotice/logs"
)

func Mqtt_DeviceReal(msg []byte) {
	logs.Println("Nats =>", lib.FuncName(), string(msg))

	// 请求-响应， 向 test3 发布一个 `help me` 请求数据，设置超时间3秒，如果有多个响应，只接收第一个收到的消息
	lib.Nats.Publish("Mqtt_DeviceReal", msg)

}