2

间歇性地，我看到通过我的自定义日志中间件将截断的 json 对象写入 loggly。我已经确认传出记录实际上在我的代码中被截断。

日志用 zerolog 格式化，然后在 stdout 和 loggly 之间输出。

我使用的 loggly 包已经很老了，但似乎只是io.Writer用缓冲区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
4

1 回答 1

0

在退出程序之前刷新 loggly 客户端应该这样做。

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")
}
于 2022-02-22T12:18:12.250 回答