Golang HTTP API 服务异常终止，原因排查求助

在HTTP API服务异常终止的情况下，最常见的原因是资源泄漏或未处理的panic。根据你使用的库和代码模式，以下是几个需要排查的方向和相应的示例代码：

1. 数据库连接泄漏

使用gorp时，如果没有正确关闭数据库连接，会导致连接池耗尽：

// 错误的做法 - 连接未关闭
func getWeatherData() (*Weather, error) {
    db, err := sql.Open("mysql", "user:pass@/dbname")
    if err != nil {
        return nil, err
    }
    // 缺少 defer db.Close()
    
    var weather Weather
    err = db.QueryRow("SELECT * FROM weather LIMIT 1").Scan(&weather)
    return &weather, err
}

// 正确的做法
func getWeatherData() (*Weather, error) {
    db, err := sql.Open("mysql", "user:pass@/dbname")
    if err != nil {
        return nil, err
    }
    defer db.Close() // 确保连接关闭
    
    var weather Weather
    err = db.QueryRow("SELECT * FROM weather LIMIT 1").Scan(&weather)
    return &weather, err
}

2. HTTP响应体未关闭

在cron任务中调用http.Get后必须关闭响应体：

// 错误的做法
func fetchWeatherData() {
    resp, err := http.Get("http://api.wunderground.com/api/xxx")
    if err != nil {
        log.Printf("HTTP request failed: %v", err)
        return
    }
    // 缺少 resp.Body.Close()
    
    // 处理响应数据...
}

// 正确的做法
func fetchWeatherData() {
    resp, err := http.Get("http://api.wunderground.com/api/xxx")
    if err != nil {
        log.Printf("HTTP request failed: %v", err)
        return
    }
    defer resp.Body.Close() // 必须关闭响应体
    
    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        log.Printf("Read body failed: %v", err)
        return
    }
    
    // 处理body数据...
}

3. 添加全局panic恢复

在HTTP处理器中添加recover来捕获未处理的panic：

func withRecover(h httprouter.Handle) httprouter.Handle {
    return func(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
        defer func() {
            if err := recover(); err != nil {
                log.Printf("Recovered from panic: %v", err)
                http.Error(w, "Internal Server Error", http.StatusInternalServerError)
            }
        }()
        h(w, r, ps)
    }
}

// 注册路由时使用
router.GET("/api/0.2/weather", withRecover(weatherHandler))

4. 添加信号处理和优雅关闭

实现优雅关闭机制：

func main() {
    router := httprouter.New()
    router.GET("/api/0.2/weather", weatherHandler)
    
    server := &http.Server{
        Addr:    ":7000",
        Handler: router,
    }
    
    // 启动服务器
    go func() {
        if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
            log.Fatalf("Server failed: %v", err)
        }
    }()
    
    // 等待中断信号
    quit := make(chan os.Signal, 1)
    signal.Notify(quit, os.Interrupt, syscall.SIGTERM)
    <-quit
    
    log.Println("Shutting down server...")
    
    // 优雅关闭
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()
    
    if err := server.Shutdown(ctx); err != nil {
        log.Fatalf("Server forced to shutdown: %v", err)
    }
    
    log.Println("Server exited")
}

5. 添加内存监控

在代码中添加内存使用监控：

func startMemoryMonitor() {
    go func() {
        for {
            var m runtime.MemStats
            runtime.ReadMemStats(&m)
            log.Printf("Alloc = %v MiB, TotalAlloc = %v MiB, Sys = %v MiB, NumGC = %v",
                m.Alloc/1024/1024, m.TotalAlloc/1024/1024, m.Sys/1024/1024, m.NumGC)
            time.Sleep(30 * time.Second)
        }
    }()
}

在你的main函数中调用startMemoryMonitor()来监控内存使用情况。

6. 检查cron任务

确保cron任务不会累积：

c := cron.New()
// 使用带恢复的包装函数
c.AddFunc("*/10 * * * *", func() {
    defer func() {
        if err := recover(); err != nil {
            log.Printf("Cron job panic: %v", err)
        }
    }()
    fetchWeatherData()
})
c.Start()

建议先添加panic恢复和资源释放代码，然后观察服务运行情况。如果问题仍然存在，检查系统日志/var/log/messages或使用dmesg查看是否有OOM killer终止进程的记录。