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