FollowUp_Notice/Nats/Nats.go

package Nats

import (
	"FollowUp_Notice/conf"
	"fmt"
	"github.com/nats-io/nats.go"
)

var Nats *nats.Conn

func init() {
	fmt.Println("============Nats init============")
	var err error
	// 连接Nats服务器
	Nats, err = nats.Connect("nats://" + conf.NatsServer_Url)
	if err != nil {
		fmt.Println("nats 连接失败！")
		panic(err)
	}
	fmt.Println("nats OK！")

	go NatsInit()

}

func NatsInit() {

}