golang持久化定时器

开发中经常会遇到需要定时执行任务的场景，Golang提供了一种持久化的定时器实现方式，可以在不重启程序的情况下保持定时任务的持续执行。本文将介绍如何使用Golang实现持久化定时器。

使用 time.Ticker 实现定时器

Golang的标准库中提供了 time 包，其中也包含了定时器的相关功能。最简单的定时器是使用 time.Ticker 实现的，它可以定时触发一个动作。下面是一个例子：

    t := time.NewTicker(time.Second * 10)
    for now := range t.C {
        fmt.Println(now)
    }

这段代码会每隔 10 秒输出当前的时间。但是一旦程序终止，定时器就会停止工作。

使用数据库记录定时器状态

为了实现持久化的定时器，我们可以使用数据库来记录定时器的状态，包括定时间隔、上次执行时间等。这样，当程序重启时，可以从数据库中读取状态并继续定时执行任务。

首先，我们需要选择一个适合的数据库来存储定时器的状态。常见的选择有MySQL、PostgreSQL和SQLite等，这里我们以MySQL为例。

使用 Golang 和 MySQL 实现持久化定时器

在Golang中，我们可以使用 gorm 库来操作MySQL数据库。下面是一个例子：

    type Timer struct {
        gorm.Model
        Interval time.Duration
        LastExec time.Time
        // ...
    }
    
    func main() {
        db, err := gorm.Open("mysql", "username:password@(localhost:3306)/database?charset=utf8&parseTime=True&loc=Local")
        if err != nil {
            log.Fatal(err)
        }
        
        db.AutoMigrate(&Timer{})
        
        go func() {
            for {
                var timer Timer
                db.First(&timer)
                
                if timer.ID != 0 && time.Now().Sub(timer.LastExec) > timer.Interval {
                    // 执行任务
                    go func() {
                        // ...
                        
                        // 更新定时器的上次执行时间
                        db.Model(&timer).Update("LastExec", time.Now())
                    }()
                }
                
                time.Sleep(time.Second)
            }
        }()
        
        select {}
    }

上述代码中，我们首先定义了一个 Timer 结构体来表示定时器的状态，包括间隔时间和上次执行时间等字段。然后，我们使用 gorm.Open 打开数据库连接，并调用 db.AutoMigrate 来自动同步 Timer 结构体到数据库。

接下来，在一个 goroutine 中循环读取数据库中的 Timer 记录，并根据定时器的状态来执行任务。如果定时器记录存在且满足触发条件，就执行任务，并更新定时器的上次执行时间。循环最后通过 time.Sleep 来控制定时器的检查频率。

最后，通过 select {} 来阻止程序退出。

至此，我们已经完成了一个简单的持久化定时器的实现。通过使用数据库来记录定时器状态，我们可以在程序重启后继续执行定时任务，大大提高了程序的可靠性。