0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看技术视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

简述Golang熔断器的实现及使用

马哥Linux运维 来源:Segmentfault 作者:搬砖程序员带你飞 2021-11-26 10:08 次阅读

Go 项目中使用熔断技术提高系统容错性。本文介绍了 go 熔断器和其使用。

熔断器像是一个保险丝。当我们依赖的服务出现问题时,可以及时容错。一方面可以减少依赖服务对自身访问的依赖,防止出现雪崩效应;另一方面降低请求频率以方便上游尽快恢复服务。

熔断器的应用也非常广泛。除了在我们应用中,为了请求服务时使用熔断器外,在 web 网关、微服务中,也有非常广泛的应用。本文将从源码角度学习 sony 开源的一个熔断器实现 github/sony/gobreaker。(代码注释可以从github/lpflpf/gobreaker 查看)

熔断器的模式

gobreaker 是基于《微软云设计模式》一书中的熔断器模式的 Golang 实现。有 sony 公司开源,目前 star 数有 1.2K。使用人数较多。

下面是模式定义的一个状态机:

538bb7b4-4e2d-11ec-9eda-dac502259ad0.png

熔断器有三种状态,四种状态转移的情况:

三种状态

  • 熔断器关闭状态,服务正常访问

  • 熔断器开启状态,服务异常

  • 熔断器半开状态,部分请求限流访问

四种状态转移

  • 在熔断器关闭状态下,当失败后并满足一定条件后,将直接转移为熔断器开启状态。

  • 在熔断器开启状态下,如果过了规定的时间,将进入半开启状态,验证目前服务是否可用。

  • 在熔断器半开启状态下,如果出现失败,则再次进入关闭状态。

  • 在熔断器半开启后,所有请求(有限额)都是成功的,则熔断器关闭。所有请求将正常访问。

gobreaker 的实现

gobreaker 是在上述状态机的基础上,实现的一个熔断器。

熔断器的定义

typeCircuitBreakerstruct{
namestring
maxRequestsuint32//最大请求数(半开启状态会限流)
intervaltime.Duration//统计周期
timeouttime.Duration//进入熔断后的超时时间
readyToTripfunc(countsCounts)bool//通过Counts判断是否开启熔断。需要自定义
onStateChangefunc(namestring,fromState,toState)//状态修改时的钩子函数

mutexsync.Mutex//互斥锁,下面数据的更新都需要加锁
stateState//记录了当前的状态
generationuint64//标记属于哪个周期
countsCounts//计数器,统计了成功、失败、连续成功、连续失败等,用于决策是否进入熔断
expirytime.Time//进入下个周期的时间
}

其中,如下参数是我们可以自定义的:

  • MaxRequests:最大请求数。当在最大请求数下,均请求正常的情况下,会关闭熔断器

  • interval:一个正常的统计周期。如果为 0,那每次都会将计数清零

  • timeout: 进入熔断后,可以再次请求的时间

  • readyToTrip:判断熔断生效的钩子函数

  • onStateChagne:状态变更的钩子函数

请求的执行

熔断器的执行操作,主要包括三个阶段;①请求之前的判定;②服务的请求执行;③请求后的状态和计数的更新

//熔断器的调用
func(cb*CircuitBreaker)Execute(reqfunc()(interface{},error))(interface{},error){

//①请求之前的判断
generation,err:=cb.beforeRequest()
iferr!=nil{
returnnil,err
}

deferfunc(){
e:=recover()
ife!=nil{
//③panic的捕获
cb.afterRequest(generation,false)
panic(e)
}
}()

//②请求和执行
result,err:=req()

//③更新计数
cb.afterRequest(generation,err==nil)
returnresult,err
}

请求之前的判定操作

请求之前,会判断当前熔断器的状态。如果熔断器以开启,则不会继续请求。如果熔断器半开,并且已达到最大请求阈值,也不会继续请求。

func(cb*CircuitBreaker)beforeRequest()(uint64,error){
cb.mutex.Lock()
defercb.mutex.Unlock()

now:=time.Now()
state,generation:=cb.currentState(now)

ifstate==StateOpen{//熔断器开启,直接返回
returngeneration,ErrOpenState
}elseifstate==StateHalfOpen&&cb.counts.Requests>=cb.maxRequests{//如果是半打开的状态,并且请求次数过多了,则直接返回
returngeneration,ErrTooManyRequests
}

cb.counts.onRequest()
returngeneration,nil
}

其中当前状态的计算,是依据当前状态来的。如果当前状态为已开启,则判断是否已经超时,超时就可以变更状态到半开;如果当前状态为关闭状态,则通过周期判断是否进入下一个周期。

func(cb*CircuitBreaker)currentState(nowtime.Time)(State,uint64){
switchcb.state{
caseStateClosed:
if!cb.expiry.IsZero()&&cb.expiry.Before(now){//是否需要进入下一个计数周期
cb.toNewGeneration(now)
}
caseStateOpen:
ifcb.expiry.Before(now){
//熔断器由开启变更为半开
cb.setState(StateHalfOpen,now)
}
}
returncb.state,cb.generation
}

周期长度的设定,也是以据当前状态来的。如果当前正常(熔断器关闭),则设置为一个 interval 的周期;如果当前熔断器是开启状态,则设置为超时时间(超时后,才能变更为半开状态)。

请求之后的处理操作

每次请求之后,会通过请求结果是否成功,对熔断器做计数。

func(cb*CircuitBreaker)afterRequest(beforeuint64,successbool){
cb.mutex.Lock()
defercb.mutex.Unlock()

now:=time.Now()

//如果不在一个周期,就不再计数
state,generation:=cb.currentState(now)
ifgeneration!=before{
return
}

ifsuccess{
cb.onSuccess(state,now)
}else{
cb.onFailure(state,now)
}
}

如果在半开的状态下:

  • 如果请求成功,则会判断当前连续成功的请求数 大于等于 maxRequests, 则可以把状态由半开状态转移为关闭状态

  • 如果在半开状态下,请求失败,则会直接将半开状态转移为开启状态

如果在关闭状态下:

  • 如果请求成功,则计数更新

  • 如果请求失败,则调用 readyToTrip 判断是否需要将状态关闭状态转移为开启状态

总结

  • 对于频繁请求一些远程或者第三方的不可靠的服务,存在失败的概率还是非常大的。使用熔断器的好处就是可以是我们自身的服务不被这些不可靠的服务拖垮,造成雪崩。

  • 由于熔断器里面,不仅会维护不少的统计数据,还有互斥锁做资源隔离,成本也会不少。

  • 在半开状态下,可能出现请求过多的情况。这是由于半开状态下,连续请求成功的数量未达到最大请求值。所以,熔断器对于请求时间过长(但是比较频繁)的服务可能会造成大量的 too many requests 错误

转自:segmentfault.com/a/1190000023033343

编辑:jq
声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • 数据
    +关注

    关注

    8

    文章

    6790

    浏览量

    88723
  • 熔断器
    +关注

    关注

    6

    文章

    457

    浏览量

    31496
  • go语言
    +关注

    关注

    1

    文章

    157

    浏览量

    9014

原文标题:Golang 熔断器的实现

文章出处:【微信号:magedu-Linux,微信公众号:马哥Linux运维】欢迎添加关注!文章转载请注明出处。

收藏 人收藏

    评论

    相关推荐

    一般熔断器有过载和短路保护吗

    一般熔断器主要提供短路保护,但在一定程度上也能提供过载保护 。不过,需要注意的是,熔断器的过载保护能力相对有限,并且通常具有一定的时间延迟。 短路保护 当电路中出现短路故障时,电流会急剧增大,远远
    的头像 发表于 09-05 17:35 590次阅读

    熔断器一般串联在什么电路中

    熔断器一般串联在多种电路中,其主要目的是保护电路和设备免受过载、短路等异常情况的影响。以下是对熔断器串联电路的介绍: 1. 高低压配电系统 熔断器广泛应用于高低压配电系统中,作为短路和过电流的保护
    的头像 发表于 09-05 17:17 339次阅读

    熔断器在低压电路中起什么作用

    熔断器是一种电气保护装置,它在低压电路中扮演着至关重要的角色。 熔断器在低压电路中的作用 过载保护 熔断器能够检测电路中的过载情况,当电流超过其额定值时,熔断器
    的头像 发表于 09-05 17:11 397次阅读

    低压熔断器的基本构造与类型选择

    一、低压熔断器的基本构造 熔断器的核心组成部分包括熔体、熔管和熔座。熔体是熔断器的关键部分,通常由金属或合金制成,其熔点较低,能够在电流超过一定阈值时迅速熔化,从而切断电路。熔管则用于安装熔体,同时
    的头像 发表于 08-20 17:26 591次阅读

    熔断器在电路中起什么保护作用

    熔断器是一种电气保护装置,广泛应用于电力系统和各种电气设备中。它主要由熔丝或熔片组成,当电路中的电流超过熔断器的额定电流时,熔丝或熔片会迅速熔断,切断电路,从而起到保护电路和设备的作用。 一、
    的头像 发表于 07-13 15:00 2067次阅读

    熔断器在使用时应与被保护电路如何连接

    熔断器在电路中起到保护的作用,能够及时切断过载电流或短路电流,以防止电路和设备的损坏。在使用熔断器时,它必须正确地连接到被保护的电路中才能发挥作用。在本文中,我们将详细讨论熔断器与被保护电路的连接
    的头像 发表于 02-26 11:11 2427次阅读

    熔断器主要由什么组成? 熔断器的作用是什么保护

    熔断器是电力系统中常见的一种安全装置,用于保护电气设备和电力系统设施免受电流过载或故障电流引起的损坏。它主要由熔断器体、熔断器芯和触发机构等组成。 熔断器是一种电器设备,它主要用于保护
    的头像 发表于 02-26 09:39 4839次阅读

    熔断式隔离开关是什么?熔断器式隔离开关与隔离开关熔断器组的区别

    熔断式隔离开关是什么?熔断器式隔离开关与隔离开关熔断器组的区别  熔断式隔离开关是一种常见的电气设备,用于切断电路和隔离电器设备。它能够在紧急情况下迅速切断电流,保护设备和人身安全。在
    的头像 发表于 02-06 10:08 3914次阅读

    熔断器有几种形式 熔断器的灭弧方法有哪几种?

    熔断器有几种形式 熔断器的灭弧方法有哪几种? 熔断器是一种用来保护电路免受过电流和过负荷的损坏的电器设备。它们在电力系统和电子设备中广泛应用,也被称为电气保险丝。熔断器有多种形式,灭弧
    的头像 发表于 02-06 10:08 1969次阅读

    熔断器的灭弧方法有哪几种 使用高压熔断器应该注意哪些问题?

    强迫熄弧法:这种方法通过在熔断器中引入一个与工频电源频率相反的电流,从而在熔断器中产生一个与工频电源频率相反的磁场,使熔断器中的气体发生电离,形成电弧。
    的头像 发表于 02-05 15:24 2051次阅读
    <b class='flag-5'>熔断器</b>的灭弧方法有哪几种 使用高压<b class='flag-5'>熔断器</b>应该注意哪些问题?

    “限流”型熔断器和“非限流”型熔断器有何区别?

    “限流”型熔断器和“非限流”型熔断器有何区别? 熔断器是一种在分布式系统中用于处理容错的重要技术。它可以用于保护应用程序免受由于服务失效等原因引起的故障。在分布式系统中,熔断器作为一个
    的头像 发表于 02-05 15:23 1991次阅读

    熔断器与断路的区别 断路能否完全取代熔断器

    熔断器与断路的区别 断路能否完全取代熔断器熔断器与断路是电力系统中常见的保护设备,它们
    的头像 发表于 02-05 13:45 3889次阅读

    跌落式熔断器型号参数

    跌落式熔断器是一种常见的电气保护装置,用于在电路电流超过其额定值时,切断电路并保护电气设备。它主要由熔断器座、熔断器座座套、熔断片和导电线组成。熔断
    的头像 发表于 01-18 13:49 2171次阅读

    新能源熔断器测试方法

    新能源熔断器测试方法
    的头像 发表于 11-20 09:43 1347次阅读
    新能源<b class='flag-5'>熔断器</b>测试方法

    熔断器如何安装?熔断器的安装及选材方法

    选择熔断器规格时,先选择熔断器规格,再根据熔断器规格选择熔断器规格。
    的头像 发表于 11-17 10:45 3887次阅读