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机制内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Go语言实现可靠的UDP 协议的示例详解

    Go语言实现可靠的UDP 协议的示例详解

    UDP(用户数据报协议)是一种无连接、轻量级的传输层协议,这篇文章主要为大家详细介绍了如何使用Go语言实现可靠的UDP 协议,需要的小伙伴可以了解下
    2025-07-07
  • Golang中crypto/cipher加密标准库全面指南

    Golang中crypto/cipher加密标准库全面指南

    本文主要介绍了Golang中crypto/cipher加密标准库,包括对称加密、非对称加密以及使用流加密和块加密算法,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧
    2024-02-02
  • Go语言的变量定义详情

    Go语言的变量定义详情

    这篇文章主要介绍了Go语言的变量定义详情,go定义变量的方式和c,c++,java语法不一样,var 变量名类型,var在前,变量名在中间,类型在后面,下文更多详细内容需要的小伙伴可以参考一下
    2022-03-03
  • Golang环境变量设置和查看工具go env详解

    Golang环境变量设置和查看工具go env详解

    go env 是 Go 工具链中的一个命令,用于设置和查看当前 Golang 环境的相关信息,对于理解、编译和运行 Golang 程序非常有用,本文就给大家简单的介绍一下Golang环境变量设置和查看工具go env,需要的朋友可以参考下
    2023-07-07
  • 基于Golang 高并发问题的解决方案

    基于Golang 高并发问题的解决方案

    这篇文章主要介绍了Golang 高并发问题的解决方案,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2021-05-05
  • golang中获取变量类型的方法总结

    golang中获取变量类型的方法总结

    golang中是没有提供内置函数来获取变量的类型的,但是通过一定的方式也可以获取,下面主要给大家介绍了几个golang获取变量类型的几种方式,需要的朋友可以参考下
    2025-03-03
  • Golang并发编程之调度器初始化详解

    Golang并发编程之调度器初始化详解

    这篇文章主要为大家详细介绍了Golang并发编程中关于调度器初始化的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以了解一下
    2023-03-03
  • Go调度器学习之协作与抢占详解

    Go调度器学习之协作与抢占详解

    如果某个G执行时间过长,其他的G如何才能被正常调度,这就引出了接下来的话题:协作与抢占。本文将通过一些示例为大家详细讲讲调度器中协作与抢占的相关知识,需要的可以参考一下
    2023-04-04
  • 使用Go语言实现HTTP客户端请求并解析响应的完整流程

    使用Go语言实现HTTP客户端请求并解析响应的完整流程

    在日常开发中,无论是调用 RESTful API、采集网页数据,还是进行微服务之间的通信,HTTP 客户端几乎无处不在,本文聚焦于如何使用 Go 实现一个 HTTP 客户端,完成请求发送、响应解析、错误处理、Header与Body提取等完整流程,需要的朋友可以参考下
    2025-08-08
  • Golang实现检测SSL证书有效期

    Golang实现检测SSL证书有效期

    本文主要为大家详细介绍如何使用Go语言中的crypto/tls模块来获取网站的SSL/TLS证书信息并检查其有效期,文中的示例代码讲解详细,感兴趣的小伙伴可以了解下
    2026-04-04

最新评论