Skip to main content

定时任务

注册定时任务#

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