• 本来是想单独封装一个定时器任务 模块, 然后在main.go中调用一下启动定时器的方法,然鹅并不生效.如下:

/*
 * @Description:定时任务
 * @Author: Casso-Wong
 */

package timer

import (
    "fmt"

    "github.com/robfig/cron"
)

type storeMsg struct{}

// Run insert msg records to mysql form redis
func (s storeMsg) Run() {
    fmt.Println(123, "run")
}

// StartCron 开启定时任务程序
func StartCron() {
    c := cron.New()
    c.Start()
    defer c.Stop()
    // storeMsg := storeMsg{}
    c.AddJob("*/5 * * * * ?", storeMsg{})
}

在main.go中调用 StartCron并没什么用

• 需要在main.go中直接注册定时器:

    corns := cron.New()
    corns.Start()
    defer corns.Stop()
    corns.AddJob("*/5 * * * * ?", timer.StoreMsg{})  // 在timer包中定义的实现Run方法的结构体

• 最终确定使用的姿势：

package jobs
import(
...
)
// Conrs 定时器
var Conrs *cron.Cron

func init() {
    Conrs = cron.New() // 定时任务
    Conrs.Start()
    Conrs.AddJob(parsecfg.GlobalConfig.Timer.Store, StoreMsg{}) // 添加定时任务
    // Conrs.AddJob(parsecfg.GlobalConfig.Timer.Store, StoreGroup{})
}

然后在 main.go中：defer jobs.Conrs.Stop()