定时任务Cron

1 Example

项目地址定时任务Cron - 图1 (opens new window) ego版本：ego@v0.3.11

2 定时任务配置

  1. type Config struct {
  2.     WaitLockTime          time.Duration // 抢锁等待时间，默认60s
  3.     LockTTL               time.Duration // 租期，默认60s
  4.     LockDir               string        // 定时任务锁目录
  5.     RefreshTTL            time.Duration // 刷新ttl，默认60s
  6.     WaitUnlockTime        time.Duration // 抢锁等待时间，默认1s
  7.     DelayExecType         string        // skip，queue，concurrent，如果上一个任务执行较慢，到达了新的任务执行时间，那么新的任务选择跳过，排队，并发执行的策略
  8.     EnableDistributedTask bool          // 是否分布式任务，默认否，如果存在分布式任务，会只执行该定时人物
  9.     EnableImmediatelyRun  bool          // 是否立刻执行，默认否
  10.     EnableWithSeconds     bool          // 是否使用秒作解析器，默认否
  11. }

3 常规定时任务

3.1 用户配置

  1. [cron.test]
  2. enableDistributedTask = false          # 是否分布式任务，默认否，如果存在分布式任务，会只执行该定时人物
  3. enableImmediatelyRun = false        # 是否立刻执行，默认否
  4. enableWithSeconds = false      # 是否使用秒作解析器，默认否
  5. delayExecType = "skip"  # skip，queue，concurrent，如果上一个任务执行较慢，到达了新任务执行时间，那么新任务选择跳过，排队，并发执行的策略，新任务默认选择skip策略

3.2 用户代码

配置创建一个 的配置项，其中内容按照上文HTTP的配置进行填写。以上这个示例里这个配置key是cron.test

代码中创建一个 cron 服务， ecron.Load(“”).Build() ，代码中的 key 和配置中的 key 。创建完 cron 后， 将他添加到 ego new 出来应用的 Schedule 方法中。

  1. package main
  3. import (
  4.     "errors"
  5.     "fmt"
  6.     "github.com/gotomicro/ego"
  7.     "github.com/gotomicro/ego/core/elog"
  8.     "github.com/gotomicro/ego/task/ecron"
  9.     "time"
  10. )
  12. //  export EGO_DEBUG=true && go run main.go --config=config.toml
  13. func main() {
  14.     err := ego.New().Cron(cron1()).Run()
  15.     if err != nil {
  16.         elog.Panic("startup engine", elog.Any("err", err))
  17.     }
  18. }
  20. func cron1() ecron.Ecron {
  21.     cron := ecron.Load("cron.test").Build()
  22.     cron.Schedule(ecron.Every(time.Second*10), ecron.FuncJob(execJob))
  23.     cron.Schedule(ecron.Every(time.Second*10), ecron.FuncJob(execJob2))
  24.     return cron
  25. }
  27. // 异常任务
  28. func execJob() error {
  29.     elog.Info("info job")
  30.     elog.Warn("warn job")
  31.     fmt.Println("run job")
  32.     return errors.New("exec job1 error")
  33. }
  35. // 正常任务
  36. func execJob2() error {
  37.     elog.Info("info job2")
  38.     elog.Warn("warn job2")
  39.     fmt.Println("run job2")
  40.     return nil
  41. }

4 分布式定时任务

4.1 用户配置

  1. [cron.test]
  2. enableDistributedTask = true          # 是否分布式任务，默认否，如果存在分布式任务，会只执行该定时人物
  3. enableImmediatelyRun = false        # 是否立刻执行，默认否
  4. enableWithSeconds = false      # 是否使用秒作解析器，默认否
  5. delayExecType = "skip"  # skip，queue，concurrent，如果上一个任务执行较慢，到达了新任务执行时间，那么新任务选择跳过，排队，并发执行的策略，新任务默认选择skip策略

4.2 用户代码

配置创建一个 的配置项，其中内容按照上文HTTP的配置进行填写。以上这个示例里这个配置key是cron.test

代码中创建一个 cron 服务， ecron.Load(“”).Build() ，代码中的 key 和配置中的 key 。创建完 cron 后， 将他添加到 ego new 出来应用的 Schedule 方法中。

  1. package main
  3. import (
  4.     "errors"
  5.     "fmt"
  6.     "github.com/gotomicro/ego"
  7.     "github.com/gotomicro/ego/core/elog"
  8.     "github.com/gotomicro/ego/task/ecron"
  9.     "time"
  10. )
  12. //  export EGO_DEBUG=true && go run main.go --config=config.toml
  13. func main() {
  14.     err := ego.New().Cron(cron1()).Run()
  15.     if err != nil {
  16.         elog.Panic("startup engine", elog.Any("err", err))
  17.     }
  18. }
  20. func cron1() ecron.Ecron {
  21.     lock := ecronlock.Load("").Build(ecronlock.WithClientRedis(invoker.Redis))
  22.     cron := ecron.Load("cron.test").Build(ecron.WithLocker(lock))
  23.     cron.Schedule(ecron.Every(time.Second*10), ecron.FuncJob(execJob))
  24.     return cron
  25. }
  27. func execJob() error {
  28.     elog.Info("info job")
  29.     elog.Warn("warn job")
  30.     fmt.Println("run job")
  31.     return errors.New("exec job1 error")
  32. }