日志增加不显示堆栈的Error函数,跨服增加重试
This commit is contained in:
parent
58801855fd
commit
eae290fb68
|
@ -6,6 +6,7 @@ import (
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
"reflect"
|
"reflect"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
@ -43,6 +44,8 @@ func WithTicker(size int, autonomy bool) Option {
|
||||||
// - 通常情况下crossName仅需一个即可
|
// - 通常情况下crossName仅需一个即可
|
||||||
func WithCross(crossName string, serverId int64, cross Cross) Option {
|
func WithCross(crossName string, serverId int64, cross Cross) Option {
|
||||||
return func(srv *Server) {
|
return func(srv *Server) {
|
||||||
|
start:
|
||||||
|
{
|
||||||
srv.id = serverId
|
srv.id = serverId
|
||||||
if srv.cross == nil {
|
if srv.cross == nil {
|
||||||
srv.cross = map[string]Cross{}
|
srv.cross = map[string]Cross{}
|
||||||
|
@ -52,11 +55,13 @@ func WithCross(crossName string, serverId int64, cross Cross) Option {
|
||||||
srv.PushMessage(MessageTypeCross, serverId, packet)
|
srv.PushMessage(MessageTypeCross, serverId, packet)
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error("WithCross", zap.Int64("ServerID", serverId), zap.String("Cross", reflect.TypeOf(cross).String()))
|
log.Info("Cross", zap.Int64("ServerID", serverId), zap.String("Cross", reflect.TypeOf(cross).String()), zap.String("State", "WaitNatsRun"))
|
||||||
panic(err)
|
time.Sleep(1 * time.Second)
|
||||||
|
goto start
|
||||||
}
|
}
|
||||||
log.Info("Cross", zap.Int64("ServerID", serverId), zap.String("Cross", reflect.TypeOf(cross).String()))
|
log.Info("Cross", zap.Int64("ServerID", serverId), zap.String("Cross", reflect.TypeOf(cross).String()))
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// WithTLS 通过安全传输层协议TLS创建服务器
|
// WithTLS 通过安全传输层协议TLS创建服务器
|
||||||
|
|
|
@ -113,6 +113,10 @@ func Error(msg string, fields ...zap.Field) {
|
||||||
fmt.Println(string(debug.Stack()))
|
fmt.Println(string(debug.Stack()))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func ErrorHideStack(msg string, fields ...zap.Field) {
|
||||||
|
logger.Error(msg, fields...)
|
||||||
|
}
|
||||||
|
|
||||||
// ErrorWithStack 通过额外的堆栈信息打印错误日志
|
// ErrorWithStack 通过额外的堆栈信息打印错误日志
|
||||||
func ErrorWithStack(msg, stack string, fields ...zap.Field) {
|
func ErrorWithStack(msg, stack string, fields ...zap.Field) {
|
||||||
logger.Error(msg, fields...)
|
logger.Error(msg, fields...)
|
||||||
|
|
Loading…
Reference in New Issue