如何使用Golang实现微服务健康检查_Golang 服务健康监控实践

package main
<p>import (
"encoding/json"
"net/http"
"time"
)</p><p>type HealthResponse struct {
Status    string    <code>json:"status"</code>
Timestamp time.Time <code>json:"timestamp"</code>
}</p><p>func healthHandler(w http.ResponseWriter, r *http.Request) {
// 可在此处加入更复杂的逻辑，如数据库连接检测
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(HealthResponse{
Status:    "ok",
Timestamp: time.Now(),
})
}</p><p>func main() {
http.HandleFunc("/healthz", healthHandler)
http.ListenAndServe(":8080", nil)
}</p>

type DetailedHealth struct {
    Status       string            `json:"status"`
    Database     string            `json:"database"`
    Cache        string            `json:"cache"`
    Dependencies map[string]string `json:"dependencies"`
    Timestamp    time.Time         `json:"timestamp"`
}
<p>func detailedHealthHandler(dbPing, cachePing func() bool) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
status := "ok"
deps := make(map[string]string)</p><pre class='brush:php;toolbar:false;'>    if dbPing() {
        deps["database"] = "up"
    } else {
        deps["database"] = "down"
        status = "error"
    }

    if cachePing() {
        deps["redis"] = "up"
    } else {
        deps["redis"] = "down"
        status = "error"
    }

    w.Header().Set("Content-Type", "application/json")
    if status == "error" {
        w.WriteHeader(http.StatusServiceUnavailable)
    }
    json.NewEncoder(w).Encode(DetailedHealth{
        Status:       status,
        Database:     deps["database"],
        Cache:        deps["redis"],
        Dependencies: deps,
        Timestamp:    time.Now(),
    })
}

dbPing := func() bool {
    if err := db.Ping(); err != nil {
        return false
    }
    return true
}
http.HandleFunc("/health", detailedHealthHandler(dbPing, redisPing))

import "github.com/prometheus/client_golang/prometheus/promhttp"
<p>var (
healthStatus = prometheus.NewGaugeVec(
prometheus.GaugeOpts{
Name: "service_health_status",
Help: "Health status of the service and dependencies",
},
[]string{"component"},
)
)</p><p>func init() {
prometheus.MustRegister(healthStatus)
}</p><p>// 在健康检查中更新指标
if dbPing() {
healthStatus.WithLabelValues("database").Set(1)
} else {
healthStatus.WithLabelValues("database").Set(0)
}</p>

http.Handle("/metrics", promhttp.Handler())

func withTimeout(f func() bool, timeout time.Duration) bool {
    ch := make(chan bool, 1)
    go func() { ch <- f() }()
    select {
    case result := <-ch:
        return result
    case <-time.After(timeout):
        return false
    }
}

if !withTimeout(dbPing, 2*time.Second) {
    // 标记异常
}