hystrix-go

GoSnail · · 1506 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

内部组织了一次关于hystrix-go的分享,没想到引起了内部的困惑,对于没有做过分布式系统的开发同学可能根本没有接触过hystrix,学习一个新东西,我个人的一贯思路是按照黄金圈理论。


这里关于hystrix是什么就不描述了,百度一下足够你翻几屏的了。

因为目前Team以golang为主要开发语言,所以使用了开源的hystrix-go(https://github.com/afex/hystrix-go).

大家先看下面一个例子:

var Number int

var  Result string

func main() {

    config := hystrix.CommandConfig{

            Timeout:2000,                        //超时时间设置  单位毫秒

            MaxConcurrentRequests:8,            //最大请求数

            SleepWindow:1,                      //过多长时间,熔断器再次检测是否开启。单位毫秒

            ErrorPercentThreshold:30,            //错误率

            RequestVolumeThreshold:5,            //请求阈值  熔断器是否打开首先要满足这个条件;这里的设置表示至少有5个请求才进行ErrorPercentThreshold错误百分比计算

    }

    hystrix.ConfigureCommand("test",config)

    cbs,_,_:= hystrix.GetCircuit("test")

    defer hystrix.Flush()

    for i:= 0;i < 50 ;i++ {

        start1 := time.Now()

        Number = i 

        hystrix.Go("test",run ,getFallBack)

        fmt.Println("请求次数:",i +1,";用时:",time.Now().Sub(start1),";请求状态 :",Result,";熔断器开启状态:",cbs.IsOpen(),"请求是否允许:",cbs.AllowRequest())

        time.Sleep(1000 * time.Millisecond)

    }

    time.Sleep(20 * time.Second)

}

func run()error {

    Result ="RUNNING1"

    if Number >10 {

        return nil

    }

    if Number %2 ==0  {

        return nil

    } else {

    return errors.New("请求失败")

    }

}

func getFallBack(errerror) error {

    Result ="FALLBACK"

       return nil

}

这是一个同事分享时讲的一个列子(不知这个例子的具体出路),也就是这个例子,把大家搞晕了~~。

大家可能会预期输出第一次i == 0,对2取余为0,然后输出

请求次数: 1 ;用时: 12.002µs ;请求状态 : ;熔断器开启状态: false 请求是否允许: true

请求次数: 2 ;用时: 131.926µs ;请求状态 : RUNNING1 ;熔断器开启状态: false 请求是否允许: true

然后依次循环,当到第11次时,对2取余不为9的次数为5,到达RequestVolumeThreshold设定的5,所以熔断器开启,此后的处理不会进入到run函数,直到SleepWindow时间到,会开启重试。

然后大家可以运行下上面的程序试试,实际并非如此。这里存在对大家两个知识点的掌握程度考验,1:go协程。2、hystrix-go的配置参数含义理解。

对于知识点1,这里不再做解释了,请查看上一篇文章,https://www.jianshu.com/writer#/notebooks/27310466/notes/30733785。

讲上面的例子稍微修改下,增加runtime.GOMAXPROCS(1),就能够达到上面的预期了吗?然而并没有,如果这里还没有理解,说明大家没有仔细看我上面提到的那个文章,或者说看了没有看透。

那么究竟怎么做才能达到我们心里预期那?

大家细看下hystrix-go源码或readme,实际上hystrix提供了hystrix.Go、hystrix.GoC、hystrix.Do、hystrix.DoC这四种方法。顾名思义,GoX代表异步调用处理,DoX代表同步处理,因此将上面的例子中的hystrix.Go改成hystrix.Do,基本可以输出之前的预期结果,但是细心的人仔细查看输出结果其实并不对。接下来主要讨论下hystrix.CommandConfig{

            Timeout:2000,                        //超时时间设置  单位毫秒

            MaxConcurrentRequests:8,            //最大请求数

            SleepWindow:1,                      //过多长时间,熔断器再次检测是否开启。单位毫秒

            ErrorPercentThreshold:30,            //错误率

            RequestVolumeThreshold:5,            //请求阈值  熔断器是否打开首先要满足这个条件;这里的设置表示至少有5个请求才进行ErrorPercentThreshold错误百分比计算

    }这里的几个参数。

Timeout,顾名思义就是指运行run函数的超时时间,如果超时,熔断器失败次数+1,这里可以将run函数里面增加个大于timeout的延时看看效果?然后在getFallBack函数里面打印下err,会hystrix: timeout这个错误输出。

再说下SleepWindow这个参数。按照上面的例子,会有如下的打印

请求次数: 11 ;用时: 164.183µs ;请求状态 : RUNNING1 ;熔断器开启状态: false 请求是否允许: true

请求次数: 12 ;用时: 117.482µs ;请求状态 : FALLBACK ;熔断器开启状态: true 请求是否允许: false

请求次数: 13 ;用时: 184.445µs ;请求状态 : RUNNING1 ;熔断器开启状态: false 请求是否允许: true

熔断器状态在12个请求开启了一次,立刻关闭了,这就是因为sleepWindow时间很短(1ms),熔断器再次检测ok后,立马改变了熔断器状态。


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:GoSnail

查看原文:hystrix-go

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

1506 次点击  ∙  1 赞  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传