如何在Golang中实现微服务故障自愈_Golang微服务故障自愈方法汇总

func doWithRetry(client *http.Client, url string) (*http.Response, error) {
    var resp *http.Response
    var err error
    backoff := time.Millisecond * 100
    for i := 0; i < 3; i++ {
        resp, err = client.Get(url)
        if err == nil {
            return resp, nil
        }
        time.Sleep(backoff)
        backoff *= 2 // 指数增长
    }
    return nil, err
}

var cb *gobreaker.CircuitBreaker
<p>func init() {
var st gobreaker.Settings
st.Name = "remote-service"
st.MaxConcurrentCalls = 5
st.Interval = 5 <em> time.Second
st.Timeout = 10 </em> time.Second
st.ReadyToTrip = func(counts gobreaker.Counts) bool {
return counts.ConsecutiveFailures > 3
}
cb = gobreaker.NewCircuitBreaker(st)
}</p><p>func callRemoteService() (string, error) {
result, err := cb.Execute(func() (interface{}, error) {
resp, err := http.Get("<a href="https://www.php.cn/link/1ba2e3e63336e31e2474cac0fd74bb40">https://www.php.cn/link/1ba2e3e63336e31e2474cac0fd74bb40</a>")
if err != nil {
return nil, err
}
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
return string(body), nil
})
if err != nil {
return "", err
}
return result.(string), nil
}

func healthHandler(w http.ResponseWriter, r *http.Request) {
    // 检查数据库、Redis等依赖
    if db.Ping() != nil {
        http.Error(w, "DB unreachable", http.StatusServiceUnavailable)
        return
    }
    w.WriteHeader(http.StatusOK)
    w.Write([]byte("OK"))
}

livenessProbe:
  httpGet:
    path: /health
    port: 8080
  initialDelaySeconds: 10
  periodSeconds: 5