Golang如何实现容器健康检查_Golang 容器健康管理实践

package main

import (
    "encoding/json"
    "net/http"
    "time"
)

func main() {
    mux := http.NewServeMux()

    // 健康检查接口
    mux.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
        // 可加入数据库连接、依赖服务探测等逻辑
        if isHealthy() {
            w.WriteHeader(http.StatusOK)
            json.NewEncoder(w).Encode(map[string]string{"status": "ok", "timestamp": time.Now().UTC().String()})
        } else {
            w.WriteHeader(http.ServiceUnavailable)
            json.NewEncoder(w).Encode(map[string]string{"status": "unhealthy"})
        }
    })

    // 就绪检查可根据业务状态定制
    mux.HandleFunc("/readyz", func(w http.ResponseWriter, r *http.Request) {
        if isReady() {
            w.WriteHeader(http.StatusOK)
        } else {
            w.WriteHeader(http.StatusServiceUnavailable)
        }
    })

    http.ListenAndServe(":8080", mux)
}

func isHealthy() bool {
    // 实现具体健康判断逻辑，例如 ping 数据库
    return true
}

func isReady() bool {
    // 检查是否完成初始化、配置加载、缓存预热等
    return true
}

livenessProbe:
  httpGet:
    path: /healthz
    port: 8080
  initialDelaySeconds: 30
  periodSeconds: 10
  timeoutSeconds: 5
  failureThreshold: 3

readinessProbe:
  httpGet:
    path: /readyz
    port: 8080
  initialDelaySeconds: 10
  periodSeconds: 5
  timeoutSeconds: 3
  failureThreshold: 3