Golang Web服务启动后日志无法输出至stdout问题求助

问题描述 #

使用Golang开发处理SNS HTTP请求的应用，部署在Kubernetes容器中。应用启动后仅能看到Server starting on port 8080日志，后续请求的调试打印（fmt.Printf/Println）和请求日志都无法输出到stdout，但错误请求能正常返回对应的HTTP错误。尝试过刷新日志、切换打印方式、显式调用os.Stdout.Sync()等方法，均无效。

代码片段如下：

func main() {
    // Configure logging
    //log.SetOutput(io.MultiWriter(os.Stdout))
    //log.SetFlags(log.LstdFlags | log.Lshortfile | log.LUTC)

    port := os.Getenv("PORT")
    if port == "" {
        port = "8080"
    }

    // Register handler
    http.HandleFunc("/sns", handleSNS)

    addr := fmt.Sprintf(":%s", port)
    fmt.Printf("Server starting on port %s\n", port)
    os.Stdout.Sync()

    if err := http.ListenAndServe(addr, nil); err != nil {
        fmt.Printf("Failed to start server: %v\n", err)
        os.Stdout.Sync()
        os.Exit(1)
    }
}
func handleSNS(w http.ResponseWriter, r *http.Request) {
    fmt.Println("Received HTTP request at /sns")
    os.Stdout.Sync()
    if r.Method != http.MethodPost {
        fmt.Println(os.Stdout, "Invalid method: %s", r.Method)
        os.Stdout.Sync()
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }
    // Read the raw body for logging
    body, err := io.ReadAll(r.Body)
    if err != nil {
        fmt.Println(os.Stdout, "Error reading request body: %v", err)
        os.Stdout.Sync()
        http.Error(w, "Error reading request", http.StatusBadRequest)
        return
    }
...

问题原因 #

1. fmt.Println调用错误：在handleSNS函数中，错误地将os.Stdout作为第一个参数传入fmt.Println。fmt.Println默认输出到os.Stdout，无需显式传入，这种写法会导致输出格式混乱，甚至日志内容被当作参数处理，无法正常输出。
2. 日志输出工具选择不当：注释掉了标准库log的配置，fmt的输出在容器环境中可能存在缓冲异常，即便调用Sync()也无法保证日志正常输出。
3. 请求路径或转发配置问题：虽然能返回HTTP错误，但可能存在请求路径不匹配（比如请求/sns/而非/sns），或Kubernetes的Service/Ingress配置错误，导致请求未真正到达处理函数。

解决步骤 #

1. 修复fmt输出调用错误 #

修正handleSNS中错误的fmt.Println调用，改用正确的格式化输出方式：

func handleSNS(w http.ResponseWriter, r *http.Request) {
    fmt.Println("Received HTTP request at /sns")
    os.Stdout.Sync()
    if r.Method != http.MethodPost {
        // 替换错误写法，改用fmt.Printf或正确的fmt.Println
        fmt.Printf("Invalid method: %s\n", r.Method)
        os.Stdout.Sync()
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }
    // Read the raw body for logging
    body, err := io.ReadAll(r.Body)
    if err != nil {
        fmt.Printf("Error reading request body: %v\n", err)
        os.Stdout.Sync()
        http.Error(w, "Error reading request", http.StatusBadRequest)
        return
    }
...

2. 切换到标准库log输出日志 #

启用注释掉的log配置，log包在容器环境中输出更稳定，无需手动调用Sync()：

func main() {
    // Configure logging
    log.SetFlags(log.LstdFlags | log.Lshortfile | log.LUTC)
    log.SetOutput(os.Stdout)

    port := os.Getenv("PORT")
    if port == "" {
        port = "8080"
    }

    // Register handler
    http.HandleFunc("/sns", handleSNS)

    addr := fmt.Sprintf(":%s", port)
    log.Printf("Server starting on port %s\n", port)

    if err := http.ListenAndServe(addr, nil); err != nil {
        log.Fatalf("Failed to start server: %v\n", err)
    }
}

func handleSNS(w http.ResponseWriter, r *http.Request) {
    log.Println("Received HTTP request at /sns")
    if r.Method != http.MethodPost {
        log.Printf("Invalid method: %s", r.Method)
        http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
        return
    }
    // Read the raw body for logging
    body, err := io.ReadAll(r.Body)
    if err != nil {
        log.Printf("Error reading request body: %v", err)
        http.Error(w, "Error reading request", http.StatusBadRequest)
        return
    }
...
}

3. 验证请求转发与路径匹配 #

• 检查Kubernetes的Service/Ingress配置，确认/sns路径正确转发到应用容器的8080端口。
• 在容器内直接用curl测试：curl -X GET http://localhost:8080/sns，查看容器日志是否有输出。

4. 检查容器日志查看方式 #

使用kubectl logs <pod-name> -f实时跟踪日志，避免因日志刷新延迟导致错过输出；确认Pod配置未重定向stdout/stderr到其他位置。

内容的提问来源于stack exchange，提问作者Jeremy Cowan