定时任务
注册定时任务
定时任务和其他消息不太一样,直接在 main.go
里注册即可
scheduler := asynq.NewScheduler(
asynq.RedisClientOpt{Addr: cfg.Addr},
&asynq.SchedulerOpts{Location: time.Local},
)
// 这里进行任务的注册
// start
t, _ := task.NewEmailWelcomeTask(6)
if _, err := scheduler.Register("@every 5s", t); err != nil {
log.Fatal(err)
}
// end
// Run blocks and waits for os signal to terminate the program.
if err := scheduler.Run(); err != nil {
log.Fatal(err)
}