日志优化
This commit is contained in:
parent
723e618df2
commit
93d71c9a7e
|
@ -12,7 +12,7 @@ var (
|
||||||
)
|
)
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
Server = server.New(server.NetworkTCP)
|
Server = server.New(server.NetworkWebsocket)
|
||||||
Game = &app{
|
Game = &app{
|
||||||
World: builtin.NewWorld[int64, *Player](0),
|
World: builtin.NewWorld[int64, *Player](0),
|
||||||
}
|
}
|
||||||
|
|
|
@ -56,6 +56,7 @@ func (slf *event) RegConnectionClosedEvent(handle ConnectionClosedEventHandle) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (slf *event) OnConnectionClosedEvent(conn *Conn) {
|
func (slf *event) OnConnectionClosedEvent(conn *Conn) {
|
||||||
|
log.Debug("Server", zap.String("ConnectionClosed", conn.GetID()))
|
||||||
slf.Server.connections.Delete(conn.ip)
|
slf.Server.connections.Delete(conn.ip)
|
||||||
for _, handle := range slf.connectionClosedEventHandles {
|
for _, handle := range slf.connectionClosedEventHandles {
|
||||||
handle(conn)
|
handle(conn)
|
||||||
|
@ -72,6 +73,7 @@ func (slf *event) RegConnectionOpenedEvent(handle ConnectionOpenedEventHandle) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (slf *event) OnConnectionOpenedEvent(conn *Conn) {
|
func (slf *event) OnConnectionOpenedEvent(conn *Conn) {
|
||||||
|
log.Debug("Server", zap.String("ConnectionOpened", conn.GetID()))
|
||||||
slf.Server.connections.Set(conn.ip, conn)
|
slf.Server.connections.Set(conn.ip, conn)
|
||||||
for _, handle := range slf.connectionOpenedEventHandles {
|
for _, handle := range slf.connectionOpenedEventHandles {
|
||||||
handle(conn)
|
handle(conn)
|
||||||
|
|
|
@ -141,6 +141,7 @@ func (slf *Server) Run(addr string) error {
|
||||||
})
|
})
|
||||||
case NetworkHttp:
|
case NetworkHttp:
|
||||||
if slf.prod {
|
if slf.prod {
|
||||||
|
log.SetProd()
|
||||||
gin.SetMode(gin.ReleaseMode)
|
gin.SetMode(gin.ReleaseMode)
|
||||||
}
|
}
|
||||||
go func() {
|
go func() {
|
||||||
|
@ -237,6 +238,11 @@ func (slf *Server) IsProd() bool {
|
||||||
return slf.prod
|
return slf.prod
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// IsDev 是否为开发模式
|
||||||
|
func (slf *Server) IsDev() bool {
|
||||||
|
return !slf.prod
|
||||||
|
}
|
||||||
|
|
||||||
// Shutdown 停止运行服务器
|
// Shutdown 停止运行服务器
|
||||||
func (slf *Server) Shutdown(err error) {
|
func (slf *Server) Shutdown(err error) {
|
||||||
if slf.connections != nil {
|
if slf.connections != nil {
|
||||||
|
|
|
@ -12,10 +12,10 @@ import (
|
||||||
|
|
||||||
var (
|
var (
|
||||||
Logger *zap.Logger
|
Logger *zap.Logger
|
||||||
|
prod bool
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
debug = true
|
|
||||||
logPath = "./logs"
|
logPath = "./logs"
|
||||||
logTime = 7
|
logTime = 7
|
||||||
)
|
)
|
||||||
|
@ -52,7 +52,7 @@ func newLogger() *zap.Logger {
|
||||||
|
|
||||||
var cores zapcore.Core
|
var cores zapcore.Core
|
||||||
|
|
||||||
if debug {
|
if !prod {
|
||||||
cores = zapcore.NewTee(
|
cores = zapcore.NewTee(
|
||||||
zapcore.NewCore(encoder, zapcore.AddSync(os.Stdout), debugLevel),
|
zapcore.NewCore(encoder, zapcore.AddSync(os.Stdout), debugLevel),
|
||||||
)
|
)
|
||||||
|
@ -100,3 +100,7 @@ func Debug(msg string, fields ...zap.Field) {
|
||||||
func Error(msg string, fields ...zap.Field) {
|
func Error(msg string, fields ...zap.Field) {
|
||||||
Logger.Error(msg, fields...)
|
Logger.Error(msg, fields...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func SetProd() {
|
||||||
|
prod = true
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue