如何在 Go 中使用 cron 持续执行定时任务
技术百科
心靈之曲
发布时间:2026-01-26
浏览: 次 本文详解如何正确使用 robfig/cron 在 go 程序中实现长期运行的定时方法调用,解决因主 goroutine 过早退出导致任务不执行的问题,并提供可立即运行的完整示例。
在 Go 中使用 robfig/cron(现维护版本为 github.com/robfig/cron/v3)实现定时任务时,一个常见误区是:调用 c.Start() 后未保持主 goroutine 活跃,导致程序立即退出,定时器根本来不及触发。你的原始代码正是如此——c.Sta

此外,原 cron 表达式 "1 * * * * *" 表示「秒字段为 1 时执行」(即每分钟第 1 秒),而非「每秒执行」;若需每秒触发,请使用 "* * * * * *"(6 字段格式,对应 秒 分 时 日 月 周)。
以下是修正后的完整、健壮的实现:
package main
import (
"fmt"
"os"
"os/signal"
"syscall"
"time"
"github.com/robfig/cron/v3"
)
func main() {
// 创建 cron 调度器(v3 版本推荐使用 cron.New() 或 cron.New(cron.WithSeconds()))
c := cron.New(cron.WithSeconds())
// 添加每秒执行的任务(6 字段:* * * * * *)
_, err := c.AddFunc("* * * * * *", RunEverySecond)
if err != nil {
panic(err)
}
// 启动调度器(非阻塞,需在后台运行)
c.Start()
defer c.Stop() // 确保优雅关闭
fmt.Println("Cron job started. Press Ctrl+C to exit.")
// 阻塞主 goroutine,等待系统中断信号(如 Ctrl+C)
sigChan := make(chan os.Signal, 1)
signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
<-sigChan // 阻塞直至收到信号
fmt.Println("Shutting down...")
}
func RunEverySecond() {
fmt.Printf("[%s] Task executed\n", time.Now().Format("15:04:05"))
}✅ 关键要点说明:
- ✅ 必须显式阻塞 main():使用 signal.Notify 监听 SIGINT(Ctrl+C)或 SIGTERM,避免进程闪退;
- ✅ 正确使用 cron v3 的秒级支持:通过 cron.WithSeconds() 启用 6 字段语法,"* * * * * *" 表示每秒执行;
- ✅ 调用 c.Start() 后无需 go 关键字:v3 的 Start() 本身已启动 goroutine,手动 go c.Start() 是冗余且易引发竞态;
- ✅ 务必调用 c.Stop():在退出前清理资源(如关闭内部 ticker),避免 goroutine 泄漏;
- ⚠️ 注意:旧版 github.com/robfig/cron(v2)默认不支持秒级,需升级至 v3 并启用 WithSeconds() 选项。
运行该程序后,你将看到每秒打印一条带时间戳的日志,直到手动中断(Ctrl+C)。此模式适用于后台服务、健康检查、定时同步等长期运行场景。
# ai
# 适用于
# 推荐使用
# 若需
# 而非
# 每分钟
# 你将
# 如何正确
# 不支持
# 旧版
# go
# git
# github
# signal
# 请使用
相关栏目:
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
AI推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
SEO优化<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
技术百科<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
谷歌推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
百度推广<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
网络营销<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
案例网站<?muma echo $count; ?>
】
<?muma
$count = M('archives')->where(['typeid'=>$field['id']])->count();
?>
【
精选文章<?muma echo $count; ?>
】
相关推荐
- Python网络日志追踪_请求定位解析【教程】
- 如何在Golang中实现微服务服务拆分_Golan
- php下载安装后memory_limit怎么设置_
- 如何使用Golang处理网络超时错误_Golang
- C++ STL算法库怎么用?C++常用算法函数(s
- Mac如何彻底清理浏览器缓存?(Safari与Ch
- 如何用正则表达式精确匹配最多含一个换行符的起止片段
- 如何快速验证Golang安装是否成功_运行go v
- Win11如何暂停系统更新 Win11暂停更新最长
- 如何在包含多值的列中精准搜索指定演员?
- Win11无法安装软件怎么办_Win11解除应用安
- Windows怎样关闭桌面弹窗广告_Windows
- c++中如何使用虚函数实现多态_c++多态性实现原
- Flask 表单数据通过 SMTP 发送邮件的完整
- Win11怎么开启远程桌面连接_Windows11
- php查询数据怎么分组_groupby分组查询配合
- 如何使用Golang模拟请求超时_Golang c
- Mac如何与安卓手机传文件_Mac和Android
- php怎么下载安装后测试是否成功_简单脚本验证方法
- Python大型项目拆分策略_模块化解析【教程】
- 如何在Golang中编写端到端测试_Golang
- Python变量绑定机制_引用模型解析【教程】
- LINUX怎么查看进程_LINUX ps命令查看运
- c++中的std::conjunction和std
- Python装饰器复用技巧_通用能力解析【教程】
- Python函数接口稳定性_版本演进解析【指导】
- 如何在Golang中处理云原生事件_使用Event
- php接口返回数据乱码怎么办_php接口调试编码问
- C++如何使用std::transform批量处理
- C++如何使用std::optional?(处理可
- Win11怎么制作U盘启动盘_Win11原版系统安
- Windows如何使用注册表查找和删除项?(reg
- Win10怎样设置闹钟贪睡时间 Win10闹钟贪睡
- Win10 BitLocker加密教程 Win10
- Win11怎么设置多显示器任务栏 Win11扩展任
- Go 中实现 Python urllib.quot
- Win11怎么关闭触摸屏_禁用Win11笔记本触摸
- Python解释执行模型_字节码流程说明【指导】
- 如何解决同一段404代码在不同主机上表现不一致的问
- Windows系统被恶意软件破坏后的恢复策略_错误
- Win11如何更改用户账户文件夹名称 Win11修
- VSC怎么创建PHP项目_从零开始搭建项目的步骤【
- 如何使用Golang实现跨域请求支持_Golang
- 如何在Golang中实现WebSocket广播_使
- PHP主流架构怎么处理表单验证_规则与自定义【技巧
- Mac的“调度中心”与“空间”怎么用_Mac多桌面
- 本地php环境出现502错误_nginx或apac
- 如何使用Golang管理跨项目依赖_Golang多
- Python文件和流处理指南_高效读写大体积数据文
- Windows怎样关闭开始菜单广告_Windows

QQ客服