- 组件分享之后端组件——基于Golang实现的Hystrix使用中
- 组件分享之后端组件——基于Golang实现的容器指标的类似顶部的
- 组件分享之后端组件——基于Golang实现的基于LDAP V3协
- 组件分享之后端组件——基于Golang实现的database/s
- 组件分享之后端组件——基于Golang实现的高级消息队列协议 (
- 组件分享之后端组件——基于Golang实现的数据库迁移工具dbm
- 组件分享之后端组件——基于Golang实现的高性能和弹性的流处理
- 组件分享之后端组件——基于Golang实现的漏桶式速率限制算法(
- 组件分享之后端组件——基于Golang实现的用于收集、处理、聚合
- 组件分享之后端组件——基于Golang实现的以并行线程计算或分发
组件分享之后端组件——基于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
本文声明:
88x31.png知识共享许可协议
本作品由 cn華少 采用 知识共享署名-非商业性使用 4.0 国际许可协议 进行许可。
网友评论