Wx_MP/Nats/Server/NatsWx.go

package NatsSwever

import (
	"Wx_MP/lib"
	"Wx_MP/logs"
	"time"
)

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

	// 请求-响应， 向 test3 发布一个 `help me` 请求数据，设置超时间3秒，如果有多个响应，只接收第一个收到的消息
	msg, err := lib.Nats.Request("Wx2_BasicMessage_Text", str, 3*time.Second)
	if err != nil {
		logs.PrintlnE("Wx_BasicMessage_Text:", err)
	} else {
		logs.Println("Nats => Wx2_BasicMessage_Text : %s\n", string(msg.Data))
		return string(msg.Data)
	}

	return ""
}

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

	// 请求-响应， 向 test3 发布一个 `help me` 请求数据，设置超时间3秒，如果有多个响应，只接收第一个收到的消息
	msg, err := lib.Nats.Request("Wx_BasicMessage_Event_QRCode", str, 3*time.Second)
	if err != nil {
		logs.PrintlnE("Wx_BasicMessage_Event:", err)
	} else {
		logs.Println("Nats => Wx_BasicMessage_Event : %s\n", string(msg.Data))
		return string(msg.Data)
	}

	return ""
}