[TOC] > [github](https://github.com/afex/hystrix-go) ## 概述 1. 集`流量控制`、`熔斷`、`容錯`等 2. 每一個 Command都會有一個默認統計控制器 3. 默認的統計控制器 DefaultMetricCollector 4. 保存熔斷器的所有狀態,調用次數,失敗次數,被拒絕次數等信息 ### 熔斷狀態 1. CLOSED關閉狀態:允許流量通過 2. OPEN打開狀態:不允許流量通過,即處于降級狀態,走降級邏輯。 3. HALF OPEN半開狀態:允許某些流量通過,如果出現超時、異常等情況,將進入OPEN狀態,如果成功,那么將進入 CLOSED狀態。 ## 參數 ``` Timeout 執行command的超時時間。`默認時間是1000毫秒` MaxConcurrentRequests command的最大并發量`默認值是10` SleepWindow 當熔斷器被打開后，SleepWindow的時間就是控制過多久后去嘗試服務是否可用了。`默認值是5000毫秒` RequestVolumeThreshold 一個統計窗口10秒內請求數量。達到這個請求數量后才去判斷是否要開啟熔斷。`默認值是20` ErrorPercentThreshold 錯誤百分比，請求數量大于等于RequestVolumeThreshold 并且錯誤率到達這個百分比后就會啟動`熔斷默認值是50` ``` ### 函數 ``` // 同步執行 err := hystrix.Do("my_command", func() error { // talk to other services return nil }, func(err error) error { // do this when services are down return nil }) //異步執行 output := make(chan bool, 1) errors := hystrix.Go("my_command", func() error { // talk to other services output <- true return nil }, nil) select { case out := <-output: // success case err := <-errors: // failure ```