Cold_handle/Nats/NatsServer/NatsMqtt.go

package NatsServer

import (
	"Cold_mqtt/lib"
	"Cold_mqtt/logs"
)

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

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

}