xxl-job hosting

  1. import (
  2.     "github.com/yoyofx/yoyogo/abstractions/configuration"
  3.     "github.com/yoyofx/yoyogo/pkg/scheduler"
  4.     "github.com/yoyofxteam/dependencyinjection"
  5. )
  7. func main() {
  8.     // -f ./conf/test_conf.yml 指定配置文件 , 默认读取 config_{profile}.yml , -profile [dev,test,prod]
  9.     config := configuration.YAML("config")
  11.     scheduler.NewXxlJobBuilder(config).
  12.         ConfigureServices(func(collection *dependencyinjection.ServiceCollection){
  13.             scheduler.AddJobs(collection, NewDemoJob)
  14.         }).
  15.         Build().Run()
  16. }

Job

  1. type DemoJob struct {
  2. }
  4. func NewDemoJob() *DemoJob {
  5.     return &DemoJob{}
  6. }
  8. func (*DemoJob) Execute(cxt *scheduler.JobContext) (msg string) {
  9.     cxt.Report("Job %d is beginning...", cxt.LogID)
  11.     for i := 1; i <= 100; i++ {
  12.         cxt.Report("Job Progress: %d Percent.", i)
  13.         time.Sleep(time.Second)
  14.     }
  16.     return cxt.Done("666")
  17. }
  19. //GetJobName 自定义任务的名字
  20. func (*DemoJob) GetJobName() string {
  21.     return "job1"
  22. }

config.yml

  1. yoyogo:
  2.   application:
  3.     name: console-xxl-job
  4.     metadata: "dev"
  5.     server:
  6.       type: "console"    # 宿主类型是 console
  7.     xxl:
  8.       serverAddr: http://127.0.0.1:8080/xxl-job-admin/
  9.       port: 9999