Yunlot/Nats/Nats.go

package Nats

import (
	"Yunlot/Nats/NatsServer"
	"Yunlot/conf"
	"Yunlot/lib"
	"Yunlot/logs"
	"github.com/nats-io/nats.go"
	"time"
)

func init() {
	go NatsInit()
}

func NatsInit() {
	time.Sleep(time.Second * 3)
	var err error
	// 连接Nats服务器
	lib.Nats, err = nats.Connect("nats://" + conf.NatsServer_Url)
	if err != nil {
		logs.Println("nats 连接失败！")
		panic(any(err))
	}
	logs.Println("nats OK！")

	go NatsServer.NatsServer_Device()
	go NatsServer.NatsServer_Product()

}