go使用Cron定时实现recover机制

 更新时间:2026年01月25日 10:48:46   作者:mao毛  
本文主要介绍了go使用Cron定时实现recover机制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

robfig/cron v3 未实现recover

定时任务painc会导致程序内存数据丢失,发生重启,本教程是实现cron的recover机制。同样也适用于长连接场景,比如tcp链接后,用户发生行为调用rpc服务,但是在调用前的某些操作,被抽象出来了,编程不合理等场景,发生painc,会导致当前用户断开链接,数据丢失。

维护handler,defer 处理recover

type CornDesc struct {
    Name    string
    Spec    string
    NewFunc func()
}

func (c *CornDesc) Handle() {
    defer c.final()
    c.NewFunc()
}

func (c *CornDesc) final() {
    if err := recover(); err != nil {
       fmt.Printf("%s 捕获运行异常! err :%v stack %s\n", c.Name, err, debug.Stack())
    }
}

cmd 导入原则,此部分可以修改

var _Machine *Machine

type Machine struct {
    *cron.Cron
    exist map[string]int
}

func InitMachine(c *cron.Cron) *Machine {
    if _Machine == nil {
       _Machine = &Machine{
          Cron:  c,
          exist: make(map[string]int),
       }
    }
    return _Machine
}
func BaseMachine() *Machine {
    return _Machine
}
func (m *Machine) Run() {
    m.Cron.Run()
}
func (m *Machine) verify(cronDesc *CornDesc) error {
    if id, ok := m.exist[cronDesc.Name]; ok {
       return fmt.Errorf("任务已存在,name %s id %d", cronDesc.Name, id)
    }
    return nil
}
func (m *Machine) Register(cornDesc *CornDesc) error {
    if err := m.verify(cornDesc); err != nil {
       return err
    }
    id, err := m.Cron.AddFunc(cornDesc.Spec, cornDesc.Handle)
    if err != nil {
       return err
    }
    m.exist[cornDesc.Name] = int(id)
    return nil
}

到此这篇关于go使用Cron定时实现recover机制的文章就介绍到这了,更多相关go recover机制内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • golang中context使用小结

    golang中context使用小结

    本文主要介绍了golang中context使用小结,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-11-11
  • golang动态创建类的示例代码

    golang动态创建类的示例代码

    这篇文章主要介绍了golang动态创建类的实例代码,本文通过实例代码给大家讲解的非常详细,需要的朋友可以参考下
    2023-06-06
  • 详解golang channel有无缓冲区的区别

    详解golang channel有无缓冲区的区别

    这篇文章主要给大家介绍了golang channel有无缓冲区的区别,无缓冲是同步的,有缓冲是异步的,文中通过代码示例给大家讲解的非常详细,需要的朋友可以参考下
    2024-01-01
  • GO语言中=和:=的区别说明

    GO语言中=和:=的区别说明

    这篇文章主要介绍了GO语言中=和:=的区别说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • golang interface{}类型转换的实现示例

    golang interface{}类型转换的实现示例

    在Go语言中,类型转换可以通过断言、显式、隐式和强制四种方式实现,针对interface{}类型转换为float32或float64,需要使用type断言或reflect包处理,感兴趣的可以了解一下
    2024-10-10
  • golang 如何获取pem格式RSA公私钥长度

    golang 如何获取pem格式RSA公私钥长度

    这篇文章主要介绍了golang 如何获取pem格式RSA公私钥长度操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • 基于HLS创建Golang视频流服务器的优缺点

    基于HLS创建Golang视频流服务器的优缺点

    HLS 是 HTTP Live Streaming 的缩写,是苹果开发的一种基于 HTTP 的自适应比特率流媒体传输协议。这篇文章主要介绍了基于 HLS 创建 Golang 视频流服务器,需要的朋友可以参考下
    2021-08-08
  • Golang中互斥锁和读写互斥锁原理及示例代码

    Golang中互斥锁和读写互斥锁原理及示例代码

    在Golang中,互斥锁是一种基本的同步原语,用于实现对共享资源的互斥访问,读写互斥锁是一种特殊类型的互斥锁,它允许多个协程同时读取某个共享资源,本文将通过过示例代码详细介绍Golang中互斥锁和读写互斥锁,需要的朋友可以参考下
    2023-05-05
  • go singleflight缓存雪崩源码分析与应用

    go singleflight缓存雪崩源码分析与应用

    这篇文章主要为大家介绍了go singleflight缓存雪崩源码分析与应用示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-09-09
  • prometheus client_go为应用程序自定义监控指标

    prometheus client_go为应用程序自定义监控指标

    这篇文章主要为大家介绍了prometheus client_go为应用程序自定义监控指标详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-02-02

最新评论