使用Go语言实现高效定时任务功能

news/2025/9/23 12:13:19/文章来源:https://www.cnblogs.com/taoshihan/p/19106954

gofly.v1kf.com

vx: llike620

在现代软件开发中，定时任务是许多系统不可或缺的一部分。无论是数据同步、定期通知还是资源清理，定时任务都能帮助我们自动化这些重复性工作。本文将介绍如何使用Go语言中的cron库实现一个功能丰富的定时任务系统。

定时任务系统的核心优势

自动化执行：解放人力，让系统在预定时间自动完成任务
精准调度：可以精确到分钟、小时、天等不同粒度
可靠性高：一旦配置完成，任务会按时执行，减少人为遗漏
灵活扩展：可以随时添加新的定时任务而不影响现有功能

实现代码解析

location, _ := time.LoadLocation("Asia/Shanghai")
cr := cron.New(cron.WithLocation(location))

首先，我们设置时区为"Asia/Shanghai"（北京时间），确保所有定时任务都基于我们所在的时区执行。

每分钟执行一次的Ping任务

cr.AddFunc("*/1 * * * *", func() {log.Println("定时任务执行:", time.Now().Format("2006-01-02 15:04:05"), "给客服websocket链接发送ping")ws.SendPingToKefuClient()
})

这个任务每分钟执行一次，主要目的是保持WebSocket连接活跃，防止因长时间无通信而断开。这在客服系统中尤为重要，确保客服与客户的实时通信通道始终畅通。

每日定时通知任务

cr.AddFunc("38 11 * * *", func() {log.Println("定时任务执行上午11点38分:", time.Now().Format("2006-01-02 15:04:05"), "通知客服账号过期提醒")service.KefuExpireEmailNotice()
})

每天上午11:38执行账号过期提醒，这是一个典型的业务通知类任务。通过定时发送邮件提醒，可以有效避免客服因账号过期而无法登录系统的情况。

每小时更新抖音凭证

douyinClientKey := models.FindConfig("DouyinClientKey")
douyinClientSecret := models.FindConfig("DouyinClientSecret")
if douyinClientKey != "" && douyinClientSecret != "" {cr.AddFunc("0 */1 * * *", func() {log.Println("定时任务执行:", time.Now().Format("2006-01-02 15:04:05"), "更新抖音access_token,refresh_token")service.UpdateDouyinAccessToken()})
}

每小时整点检查并更新抖音的access_token和refresh_token。这里还加入了配置检查，只有配置了抖音客户端密钥和密钥才会启用这个任务，体现了良好的防御性编程思想。