使用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重试机制的资料请关注我们其它相关文章！

赞 (0)

相关推荐

  • 浅谈Golang 切片（slice）扩容机制的原理

    我们知道 Golang 切片(slice) 在容量不足的情况下会进行扩容,扩容的原理是怎样的呢?是不是每次扩一倍?下面我们结合源码来告诉你答案. 一.源码 Version : go1.15.6  src/runtime/slice.go //go1.15.6 源码 src/runtime/slice.go func growslice(et *_type, old slice, cap int) slice { //省略部分判断代码 //计算扩容部分 //其中,cap : 所需容量,newcap

  • Golang的锁机制与使用技巧小结

    Golang的锁机制与使用技巧小结

    目录 1. sync.Mutex详解 2. RWMutex详解 3. sync.Map详解 4. 原子操作 atomic.Value 5. 使用小技巧 1. sync.Mutex详解 sync.Mutex是Go中的互斥锁,通过.lock()方法上锁,.unlock()方法解锁.需要注意的是,因为Go函数值传递的特点,sync.Mutex通过函数传递时,会进行一次拷贝,所以传递过去的锁是一把全新的锁,大家在使用时要注意这一点,另外sync.Mutex是非重入锁,这一点要与Java中的锁区分. ty

  • golang panic及处理机制

    golang panic及处理机制

    目录 一 panic机制 二 实例 2.1 main用recover 2.2 func用recover 2.3 func用recover且开创goroutine 2.4 goroutine中panic 2.5 func1内嵌func2中panic且func2做处理 2.6 func1内嵌func中panic且func1做处理 一 panic机制 panic会将这个异常不断向上抛出,直到有地方处理它,如果有处理,则不会再向上抛出.倘若没有处理,那么最终会导致main挂掉. golang虽然没有tr

  • golang select 机制和超时问题

    golang 中的协程使用非常方便,但是协程什么时候结束是一个控制问题,可以用 select 配合使用. 首先声明,golang 使用并不熟悉,本文仅仅是记录使用过程中遇到的一些坑. 子协程和父协程的通信通常用 context 或者 chan.我遇到一个通常的使用场景,在子协程中尝试多次处理,父协程等待一段时间超时,我选择用 chan 实现.我以为 select 和 C++ 中 switch 类似,所以最开始代码类似如下: for { select { case <-ctx.Done(): //

  • django-利用session机制实现唯一登录的例子

    配置连接数据库 DATABASES = { 'default': { 'ENGINE': 'django.db.backends.mysql', 'NAME': '数据库名称', 'USER': 'root', 'PASSWORD': '123456', 'HOST': '10.18.62.2', 'PORT': '3306', } } 生成session表 python manage.py makemigrations python manage.py migrate 登录时记住保存用户登录信

  • 使用Go重试机制代码更可靠

    目录 场景 设计原理 场景 服务依赖第三方服务或者其他服务,但有时第三方服务偶发性出现问题并且会快速的恢复,而我们的系统可能因为这些偶发性出现问题. 所以无法保证以来服务的可靠性,但是我们可以通过其他的方式来保证我们的服务是稳定的,可靠的. 重试机制可以协助我们构建健壮的服务.比如调用第三方服务或执行某操作时,出现执行失败,我们可以让其再重试几次再抛出错误. 设计原理 重试机制:某方法或者函数执行失败了重新执行,尝试重新执行后,尝试几次失败后结束.期间成功一次则表示成功. 重试次数 需要被重新执

  • Spring Cloud 请求重试机制核心代码分析

    场景 发布微服务的操作一般都是打完新代码的包,kill掉在跑的应用,替换新的包,启动. spring cloud 中使用eureka为注册中心,它是允许服务列表数据的延迟性的,就是说即使应用已经不在服务列表了,客户端在一段时间内依然会请求这个地址.那么就会出现请求正在发布的地址,而导致失败. 我们会优化服务列表的刷新时间,以提高服务列表信息的时效性.但是无论怎样,都无法避免有那么一段时间是数据不一致的. 所以我们想到一个办法就是重试机制,当a机子在重启时,同个集群的b是可以正常提供服务的,如果有

  • RocketMQ重试机制及消息幂代码实例解析

    这篇文章主要介绍了RocketMQ重试机制及消息幂代码实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.重试机制 1.由于MQ经常处于复杂的分布式系统中,考虑网络波动,服务宕机,程序异常因素,很有可能出现消息发送或者消费失败的问题.因此,消息的重试就是所有MQ中间件必须考虑到的一个关键点.如果没有消息重试,就可能产生消息丢失的问题,可能对系统产生很大的影响.所以,秉承宁可多发消息,也不可丢失消息的原则,大部分MQ都对消息重试提供了很好

  • Spring Cloud Gateway重试机制的实现

    前言 重试,我相信大家并不陌生.在我们调用Http接口的时候,总会因为某种原因调用失败,这个时候我们可以通过重试的方式,来重新请求接口. 生活中这样的事例很多,比如打电话,对方正在通话中啊,信号不好啊等等原因,你总会打不通,当你第一次没打通之后,你会打第二次,第三次...第四次就通了. 重试也要注意应用场景,读数据的接口比较适合重试的场景,写数据的接口就需要注意接口的幂等性了.还有就是重试次数如果太多的话会导致请求量加倍,给后端造成更大的压力,设置合理的重试机制才是最关键的. 今天我们来简单的了

  • Java编程Retry重试机制实例详解

    本文研究的主要是Java编程Retry重试机制实例详解,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下 1.业务场景 应用中需要实现一个功能: 需要将数据上传到远程存储服务,同时在返回处理成功情况下做其他操作.这个功能不复杂,分为两个步骤:第一步调用远程的Rest服务逻辑包装给处理方法返回处理结果:第二步拿到第一步结果或者捕捉异常,如果出现错误或异常实现重试上传逻辑,否则继续逻辑操作. 2.常规解决方案演化 1)try-catch-redo简单重试模式: 包装正

  • Spring Cloud Gateway重试机制原理解析

    重试,我相信大家并不陌生.在我们调用Http接口的时候,总会因为某种原因调用失败,这个时候我们可以通过重试的方式,来重新请求接口. 生活中这样的事例很多,比如打电话,对方正在通话中啊,信号不好啊等等原因,你总会打不通,当你第一次没打通之后,你会打第二次,第三次-第四次就通了. 重试也要注意应用场景,读数据的接口比较适合重试的场景,写数据的接口就需要注意接口的幂等性了.还有就是重试次数如果太多的话会导致请求量加倍,给后端造成更大的压力,设置合理的重试机制才是最关键的. 今天我们来简单的了解下Spr

  • Python retrying 重试机制的使用方法

    Python retrying 重试机制的使用方法

    目录 循环加判断 retrying 我们在程序开发中,经常会需要请求一些外部的接口资源,而且我们不能保证每次请求一定会成功,所以这些涉及到网络请求的代码片段就需要加上重试机制.下面来说一下Python中的重试方法. 循环加判断 最简单的重试方式就是在需要进行重试的代码片段上加一个循环,程序内捕获异常,如果执行成功就退出循环,执行失败就就重复执行相关代码,例如: import requests def req_with_retry(url): retry_max = 10 # 最大重试次数为10次

  • Python retrying 重试机制详解

    Python retrying 重试机制详解

    目录 循环加判断 retrying 总结 我们在程序开发中,经常会需要请求一些外部的接口资源,而且我们不能保证每次请求一定会成功,所以这些涉及到网络请求的代码片段就需要加上重试机制.下面来说一下Python中的重试方法. 循环加判断 最简单的重试方式就是在需要进行重试的代码片段上加一个循环,程序内捕获异常,如果执行成功就退出循环,执行失败就就重复执行相关代码,例如: import requests def req_with_retry(url): retry_max = 10 # 最大重试次数为

  • HttpClient连接池及重试机制解析

    HttpClient连接池及重试机制解析

    目录 一.HttpClient 简介 功能介绍 使用方法 二.HttpClientUtil 2.1HttpClient版本 2.2项目中用到的工具类如下 2.3笔者着重说一下http连接池 三.HttpClient的重试机制 3.1.那么问题来了HttpClient有没有重试策略? 3.2执行流程 3.3关闭重试 四.总结 4.1重试发生的条件 4.2不发生重试的异常 4.3实践中遇到的异常 一.HttpClient 简介 HttpClient 是Apache Jakarta Common 下的

  • 详解Spring Cloud Zuul重试机制探秘

    简介 本文章对应spring cloud的版本为(Dalston.SR4),具体内容如下: 开启Zuul功能 通过源码了解Zuul的一次转发 怎么开启zuul的重试机制 Edgware.RC1版本的优化 开启Zuul的功能 首先如何使用spring cloud zuul完成路由转发的功能,这个问题很简单,只需要进行如下准备工作即可: 注册中心(Eureka Server) zuul(同时也是Eureka Client) 应用服务(同时也是Eureka Client) 我们希望zuul和后端的应用

随机推荐