自定义gin日志记录中间件截断日志
自定义gin日志记录中间件截断日志
提问于 2022-02-13 16:17:11
间歇性地，我看到被截断的json对象正在通过我的自定义日志记录中间件被写入日志。我已经确认输出记录实际上在我的代码中被截断了。
日志用zerolog格式化，然后在stdout和loggly之间输出。
我使用的这个笨拙的包非常旧，但似乎只是实现了一个带有缓冲区https://github.com/segmentio/go-loggly的https://github.com/segmentio/go-loggly。
我担心的是，gin是在日志写入缓冲区之前终止上下文，而写入是短的吗？但在杜松子酒文档提供的例子中，我没有看到任何不同之处。我已经删除了同样多的无关代码，这些代码仍然存在这个问题。
写入STDOUT的日志已经完成，但是通过loggly包发送的日志正在被截断。
package main
import (
"io"
"os"
"github.com/gin-gonic/gin"
"github.com/rs/zerolog"
"github.com/segmentio/go-loggly"
)
var logglyClient *loggly.Client
func init() {
logglyToken := "potato"
logglyClient = loggly.New(logglyToken)
}
func NewLogger() zerolog.Logger {
writers := []io.Writer{zerolog.ConsoleWriter{Out: os.Stdout}}
writers = append(writers, logglyClient)
multiWriter := zerolog.MultiLevelWriter(writers...)
logger := zerolog.New(multiWriter).With().Timestamp().Logger()
return logger
}
func GinMiddleware() gin.HandlerFunc {
return func(gctx *gin.Context) {
logger := NewLogger()
logger.Info().Msg("API request")
gctx.Next()
}
}
func main() {
router := gin.New()
router.Use(GinMiddleware())
logger := NewLogger()
router.GET("/ping", func(c *gin.Context) {
c.JSON(200, gin.H{
"message": "pong",
})
})
logger.Info().Msg("Server Listening!")
router.Run(":8080")
}与以下正在使用的软件包
github.com/gin-gonic/gin v1.7.7
github.com/rs/zerolog v1.26.0
github.com/segmentio/go-loggly v0.5.0回答 1
Stack Overflow用户
发布于 2022-02-22 12:18:12
在退出程序之前，先冲洗一下这个笨拙的客户端就可以了。
https://github.com/segmentio/go-loggly/blob/7a70408c3650c37ba8e58a934f686d0c44cb9b58/loggly.go#L216
func main() {
defer logglyClient.Flush()
router := gin.New()
router.Use(GinMiddleware())
logger := NewLogger()
router.GET("/ping", func(c *gin.Context) {
c.JSON(200, gin.H{
"message": "pong",
})
})
logger.Info().Msg("Server Listening!")
router.Run(":8080")
}除此之外，您还必须实现服务器的优雅关闭，以防止程序的突然退出顺序。
Gin文档有一个例子
https://chenyitian.gitbooks.io/gin-web-framework/content/docs/38.html
func main() {
router := gin.Default()
router.GET("/", func(c *gin.Context) {
time.Sleep(5 * time.Second)
c.String(http.StatusOK, "Welcome Gin Server")
})
srv := &http.Server{
Addr: ":8080",
Handler: router,
}
go func() {
// service connections
if err := srv.ListenAndServe(); err != nil {
log.Printf("listen: %s\n", err)
}
}()
// Wait for interrupt signal to gracefully shutdown the server with
// a timeout of 5 seconds.
quit := make(chan os.Signal)
signal.Notify(quit, os.Interrupt)
<-quit
log.Println("Shutdown Server ...")
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
if err := srv.Shutdown(ctx); err != nil {
log.Fatal("Server Shutdown:", err)
}
log.Println("Server exiting")
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/71102571
复制相关文章
相似问题
腾讯云开发者
