您好,登录后才能下订单哦!
这篇文章主要讲解了“如何使用Go重试机制”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“如何使用Go重试机制”吧!
服务依赖第三方服务或者其他服务,但有时第三方服务偶发性出现问题并且会快速的恢复,而我们的系统可能因为这些偶发性出现问题。
所以无法保证以来服务的可靠性,但是我们可以通过其他的方式来保证我们的服务是稳定的,可靠的。
重试机制可以协助我们构建健壮的服务。比如调用第三方服务或执行某操作时,出现执行失败,我们可以让其再重试几次再抛出错误。
重试机制:某方法或者函数执行失败了重新执行,尝试重新执行后,尝试几次失败后结束。期间成功一次则表示成功。
重试次数
需要被重新执行方法
func add() (string, error) { var i = 1 var j = 2 result := i + j return strconv.Itoa(result), nil } func RetryFunc(count int, cback func() (string, error)) { for i := 0; i < count; i++ { result, err := cback() if err == nil { return result } } } // 应用 package main func main(){ Retry(3, add) }
重试函数接收2个参数,一个是重试次数,一个是需要重新执行的函数。但函数都是固定的。可以进一步优化。
type Effector func(context.Context) (string, error) func Retry(count int ,delay time.Duration, effector){ return func(ctx. context.Context)(string, error){ for r:=0; ;r++{ response, err := effector() if err == nil || r>= count { return response, err } fmt.Printf("Function call failed, retrying in %v", delay) select { case <- time.After(delay) case <- ctx.Done(): return "", ctx.Err() } } } }
增加延时参数 delay 控制重试延时 ,使用匿名函数定义一个函数接收器,返回值为匿名函数的。所以重试函数接受三个参数:一个效应器,一个整数,描述函数重试传递的效应器的次数以及重试之间的延迟。
函数接收器的参数是 context ,context 主要用来在 goroutine 之间传递上下文信息。这里使用context主要是用于超时取消,然后快速返回。 context
包主要提供了两种方式创建context
:
context.Background
是上下文的默认值,所有其他的上下文都应该从它衍生(Derived)出来。
context.TODO
应该只在不确定应该使用哪种上下文时使用。
感谢各位的阅读,以上就是“如何使用Go重试机制”的内容了,经过本文的学习后,相信大家对如何使用Go重试机制这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。