hystrix原理_go-hystrix熔断机制

什么是熔断

可以联想到我们家里的电表的保险丝，当电压负载过高后，保险丝熔断，确保家里的电器等其他安全。

熔断器是当依赖的服务已经出现故障时，为了保证自身服务的正常运行不在访问依赖的服务，防止雪崩效应

在熔断器中有三种状态：

• 关闭：让请求通过的默认状态。如果请求成功/失败但低于阈值，则状态保持不变。可能出现的错误是超过最大并发数和超时错误。
• 打开：当熔断器打开的时候，所有的请求都会被标记为失败；这是故障快速失败机制，而不需要等待超时时间完成。
• 半开：定期的尝试发起请求来确认系统是否恢复。如果恢复了，熔断器将转为关闭状态或者保持打开

熔断器的原理

使用示例

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:  1,    // 最大并发量
        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")
    }
}