Java

Golang

1. 環(huán)境配置：執(zhí)行以下命令，使用最新的tag拉取Go版本的XXL-JOB的SDK。

   go get github.com/xxl-job/xxl-job-executor-go@{最新的tag}

2. 編寫(xiě)任務(wù)執(zhí)行代碼。

   package main
   
   import (
       "context"
       "fmt"
       xxl "github.com/xxl-job/xxl-job-executor-go"
       "github.com/xxl-job/xxl-job-executor-go/example/task"
       "log"
   )
   
   func main() {
       exec := xxl.NewExecutor(
           xxl.ServerAddr("xxxxxx"),       //請(qǐng)求地址，控制臺(tái)應(yīng)用管理接入配置獲取
           xxl.AccessToken("xxxxxxx"),     //請(qǐng)求令牌，控制臺(tái)應(yīng)用管理接入配置獲取
           xxl.ExecutorPort("9999"),       //默認(rèn)9999（非必填）
           xxl.RegistryKey("golang-jobs"), //執(zhí)行器名稱
           xxl.SetLogger(&logger{}),       //自定義日志
       )
       exec.Init()
       exec.Use(customMiddleware)
       //設(shè)置日志查看handler
       exec.LogHandler(customLogHandle)
       //注冊(cè)任務(wù)handler
       exec.RegTask("task.test", task.Test)
       exec.RegTask("task.test2", task.Test2)
       exec.RegTask("task.panic", task.Panic)
       log.Fatal(exec.Run())
   }
   
   // 自定義日志處理器
   func customLogHandle(req *xxl.LogReq) *xxl.LogRes {
       return &xxl.LogRes{Code: xxl.SuccessCode, Msg: "", Content: xxl.LogResContent{
           FromLineNum: req.FromLineNum,
           ToLineNum:   2,
           LogContent:  "這個(gè)是自定義日志handler",
           IsEnd:       true,
       }}
   }
   
   // xxl.Logger接口實(shí)現(xiàn)
   type logger struct{}
   
   func (l *logger) Info(format string, a ...interface{}) {
       fmt.Println(fmt.Sprintf("自定義日志 - "+format, a...))
   }
   
   func (l *logger) Error(format string, a ...interface{}) {
       log.Println(fmt.Sprintf("自定義日志 - "+format, a...))
   }
   
   // 自定義中間件
   func customMiddleware(tf xxl.TaskFunc) xxl.TaskFunc {
       return func(cxt context.Context, param *xxl.RunReq) string {
           log.Println("I am a middleware start")
           res := tf(cxt, param)
           log.Println("I am a middleware end")
           return res
       }
   }