定时任务

注册定时任务

定时任务和其他消息不太一样，直接在 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)
 }