[TOC] ## 示例 ### client ``` package main import ( "fmt" "github.com/afex/hystrix-go/hystrix" "log" "net" "net/http" "os" "os/signal" "syscall" "time" ) func main() { hystrix.ConfigureCommand("default", hystrix.CommandConfig{ Timeout: 1000, // 單次請求 超時時間 MaxConcurrentRequests: 10, // 最大并發量 SleepWindow: 5000, // 熔斷后多久去嘗試服務是否可用 RequestVolumeThreshold: 1, // 驗證熔斷的 請求數量, 10秒內采樣 ErrorPercentThreshold: 1, // 驗證熔斷的 錯誤百分比 }) //開啟一個http監控服務 //可以使用hystrix-dashboard面板查看具體情況 //https://github.com/mlabouardy/hystrix-dashboard-docker hystrixStreamHandler := hystrix.NewStreamHandler() hystrixStreamHandler.Start() go func() { err := http.ListenAndServe(net.JoinHostPort("", "8888"), hystrixStreamHandler) log.Fatal(err) }() for i := 0; i < 100000; i++ { Do(i) } quit := make(chan os.Signal) signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM) <-quit } func Do(params int) { err := hystrix.Do("defalut", func() error { fmt.Println(params) return nil }, nil) if err != nil { //加入自動降級處理，如獲取緩存數據等 switch err { case hystrix.ErrCircuitOpen: fmt.Println("circuit error:" + err.Error()) case hystrix.ErrMaxConcurrency: fmt.Println("circuit error:" + err.Error()) default: fmt.Println("circuit error:" + err.Error()) } time.Sleep(1 * time.Second) log.Println("sleep 1 second") } } ```