组件分享之后端组件——基于Golang实现的Hystrix使用中间件hystrix-go
背景
近期正在探索前端、后端、系统端各类常用组件与工具,对其一些常见的组件进行再次整理一下,形成标准化组件专题,后续该专题将包含各类语言中的一些常用组件。欢迎大家进行持续关注。
组件基本信息
- 组件:hystrix-go
- 开源协议:MIT license
内容
之前分享了组件分享之后端组件——基于Java的分布式系统的延迟和容错组件(熔断组件)Hystrix,其是在Java开发过程中使用的熔断组件,本节我们就进行分享一个基于Golang的中间件hystrix-go,来进行使用Hystrix。
hystrix-go 旨在让 Go 程序员轻松构建具有与基于 Java 的 Hystrix 库类似的执行语义的应用程序。有关 Hystrix 工作原理的更多信息,请参阅Java Hystrix wiki。有关 API 文档,请参阅GoDoc
具体使用如下:
1、引入包
import "github.com/afex/hystrix-go/hystrix"
2、定义回退行为
hystrix.Go("my_command", func() error {
// talk to other services
return nil
}, func(err error) error {
// do this when services are down
return nil
})
3、等待输出
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
}
更多内容可以参考官方提供的README
本文声明:
知识共享许可协议
本作品由 cn華少 采用 知识共享署名-非商业性使用 4.0 国际许可协议 进行许可。