import (
    "errors"
    "github.com/afex/hystrix-go/hystrix"
    "sync"
)

var config = hystrix.CommandConfig{
    Timeout:                5000, //执行command的超时时间(毫秒)
    MaxConcurrentRequests:  8,    //command的最大并发量
    SleepWindow:            1000, //过多长时间，熔断器再次检测是否开启。单位毫秒
    ErrorPercentThreshold:  30,   //错误率 请求数量大于等于RequestVolumeThreshold并且错误率到达这个百分比后就会启动
    RequestVolumeThreshold: 5,    //请求阈值(一个统计窗口10秒内请求数量)  熔断器是否打开首先要满足这个条件；这里的设置表示至少有5个请求才进行ErrorPercentThreshold错误百分比计算
}

type runFunc func() error

type Hystrix struct {
    loadMap  *sync.Map //储存每个调用函数对应的 Hystrix
    fallback string   //降级信息
}

func NewHystrix(msg string) *Hystrix {
    return &Hystrix{
        loadMap:  new(sync.Map),
        fallback: msg,
    }
}

func (s *Hystrix) Run(name string, run runFunc) error {
    if _, ok := s.loadMap.Load(name); !ok {
        hystrix.ConfigureCommand(name, config)
        s.loadMap.Store(name, name)
    }
    //name 为执行的命令名称
    //run  我们要执行的函数
    //fallback：run运行过程中发生错误时的回调方法
    err := hystrix.Do(name, func() error {
        return run()
    }, func(err error) error {
        //fmt.Println("运行 run 方法错误", err)
        return errors.New(s.fallback)
    })
    if err != nil {
        return err
    }
    return nil
}

hy := utils.NewHystrix("调用错误服务降级")
cbs, _, _ := hystrix.GetCircuit("login")
for i := 0; i < 100; i++ {
    time.Sleep(time.Millisecond * 100)
    userAgent, err := client.UserAgentClient()
    if err != nil {
        t.Error(err)
        return
    }
err = hy.Run("login", func() error {
    _, err := userAgent.Login(context.Background(), &pb.Login{
        Account:  "hwholiday",
        Password: "123456",
    })
    if err != nil {
        return err
    }
        //fmt.Println(ack.Token)
        return nil
    })
fmt.Println("熔断器开启状态:", cbs.IsOpen(), "请求是否允许：", cbs.AllowRequest())
    if err != nil {
        t.Log(err)
    }
}

func NewEndPointServer(svc Service, limit *rate.Limiter) EndPointServer {
    var loginEndPoint endpoint.Endpoint
    {
        loginEndPoint = MakeLoginEndPoint(svc)
        //loginEndPoint = NewGolangRateAllowMiddleware(limit)(loginEndPoint)
    }
    return EndPointServer{LoginEndPoint: loginEndPoint}
}

if in.Account != "hwholiday" || in.Password != "123456" {
    err = errors.New("用户信息错误")
    return
}
//模拟耗时
//rand.Seed(time.Now().UnixNano())
//sl := rand.Int31n(10-1) + 1
//time.Sleep(time.Duration(sl) * time.Millisecond * 100)
//模拟错误
if rand.Intn(10) > 3 {
    err = errors.New("服务器运行错误")
    return
}
ack = &pb.LoginAck{}

## 结语
+ 我们可以看到Hystrix的状态从 打开 ->关闭 -> 打开
+ Hystrix的用法还有很多，这里只展示简单的使用，更加高级的功能欢迎大家一起讨论
+ 欢迎添加QQ一起讨论


### [完整代码地址](https://github.com/hwholiday/learning_tools/tree/master/go-kit/v8)