perf: 优化代码结构,去除无用代码,去除重复代码

This commit is contained in:
kercylan98
2023-07-11 19:35:08 +08:00
parent a23e48b087
commit 47b8a333eb
12 changed files with 49 additions and 58 deletions
+7 -3
View File
@@ -11,6 +11,10 @@ import (
"time"
)
const (
nasMark = "Cross.Nats"
)
func NewNats(url string, options ...NatsOption) *Nats {
n := &Nats{
url: url,
@@ -43,10 +47,10 @@ func (slf *Nats) Init(server *server.Server, packetHandle func(serverId int64, p
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))
log.Error(nasMark, zap.String("info", "disconnect"), zap.Error(err))
}),
nats.ReconnectHandler(func(conn *nats.Conn) {
log.Info("Cross.Nats", zap.String("info", "reconnect"))
log.Info(nasMark, zap.String("info", "reconnect"))
}),
)
}
@@ -59,7 +63,7 @@ func (slf *Nats) Init(server *server.Server, packetHandle func(serverId int64, p
message := slf.messagePool.Get()
defer slf.messagePool.Release(message)
if err := json.Unmarshal(msg.Data, &message); err != nil {
log.Error("Cross.Nats", zap.Error(err))
log.Error(nasMark, zap.Error(err))
return
}
packetHandle(message.ServerId, message.Packet)