chenyh
/
vRp.CD2g_test
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

跨服nats默认配置

This commit is contained in:
kercylan98 2023-05-16 14:04:07 +08:00
parent ad1499e9b0
commit 859eb8b7e4
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/corss/nats.go
View File

@ -8,6 +8,7 @@ import (
"github.com/kercylan98/minotaur/utils/synchronization" "github.com/kercylan98/minotaur/utils/synchronization"
"github.com/nats-io/nats.go" "github.com/nats-io/nats.go"
"go.uber.org/zap" "go.uber.org/zap"
"time"
) )
func NewNats(url string, options ...NatsOption) *Nats { func NewNats(url string, options ...NatsOption) *Nats {
@ -37,6 +38,18 @@ type Nats struct {
func (slf *Nats) Init(server *server.Server, packetHandle func(serverId int64, packet []byte)) (err error) { func (slf *Nats) Init(server *server.Server, packetHandle func(serverId int64, packet []byte)) (err error) {
if slf.conn == nil { if slf.conn == nil {
if len(slf.options) == 0 {
slf.options = append(slf.options,
nats.ReconnectWait(time.Second*5),
nats.MaxReconnects(-1),
nats.DisconnectErrHandler(func(conn *nats.Conn, err error) {
log.Error("Cross.Nats", zap.String("info", "disconnect"), zap.Error(err))
}),
nats.ReconnectHandler(func(conn *nats.Conn) {
log.Info("Cross.Nats", zap.String("info", "reconnect"))
}),
)
}
slf.conn, err = nats.Connect(slf.url, slf.options...) slf.conn, err = nats.Connect(slf.url, slf.options...)
if err != nil { if err != nil {
return err return err