~~~ package main import ( "fmt" "github.com/sony/gobreaker" "os" "time" ) var num = 0 func main() { // 創建一個熔斷器 breaker := gobreaker.NewCircuitBreaker(gobreaker.Settings{ Name: "example-circuit-breaker", Timeout: 1 * time.Second, ReadyToTrip: func(counts gobreaker.Counts) bool { // 自定義觸發條件，例如：失敗率達到50% failureRatio := float64(counts.TotalFailures) / float64(counts.Requests) return counts.Requests >= 10 && failureRatio >= 0.5 }, OnStateChange: func(name string, from gobreaker.State, to gobreaker.State) { // 熔斷狀態變化時的自定義處理 fmt.Printf("Circuit Breaker state changed from %v to %v\n", from, to) }, //打開狀態 (Open)：一旦觸發了熔斷條件，熔斷器將進入打開狀態，暫時拒絕所有請求。 //半開狀態 (Half-Open)：在指定的間隔時間（由 Interval 參數定義）后，熔斷器將嘗試切換到半開狀態。在半開狀態下，它允許一些請求通過，以測試服務是否已經恢復。 //關閉狀態 (Closed)：如果半開狀態下的請求成功，熔斷器將切換回關閉狀態，允許所有請求通過。這表示服務已經恢復正常。 //再次打開狀態 (Open)：如果半開狀態下的請求仍然失敗，熔斷器將再次進入打開狀態，以防止繼續向不穩定的服務發送請求。 Interval: 10 * time.Second, // 指定切換到半開狀態的時間間隔 }) // 模擬服務調用函數 callService := func() (string, error) { fmt.Println(1) num++ fmt.Println(num) if num < 20 { // 在此處執行實際的服務調用邏輯，這里簡單返回一個成功響應 return "Service response", os.ErrNotExist } else { // 在此處執行實際的服務調用邏輯，這里簡單返回一個成功響應 return "Service response", nil } } for i := 0; i < 20000; i++ { result, err := breaker.Execute(func() (interface{}, error) { // 在 Execute 函數內執行服務調用 return callService() }) if err != nil { fmt.Printf("Request failed: %v\n", err) } else { response, ok := result.(string) if ok { fmt.Println("Request succeeded:", response) } } time.Sleep(time.Microsecond * 10000) } } ~~~