从0搭建Java/Golang应用并接入

Java

Golang

1. 环境配置：执行以下命令，使用最新的tag拉取Go版本的XXL-JOB的SDK。

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

2. 编写任务执行代码。

   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"),       //请求地址，控制台应用管理接入配置获取
           xxl.AccessToken("xxxxxxx"),     //请求令牌，控制台应用管理接入配置获取
           xxl.ExecutorPort("9999"),       //默认9999（非必填）
           xxl.RegistryKey("golang-jobs"), //执行器名称
           xxl.SetLogger(&logger{}),       //自定义日志
       )
       exec.Init()
       exec.Use(customMiddleware)
       //设置日志查看handler
       exec.LogHandler(customLogHandle)
       //注册任务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:  "这个是自定义日志handler",
           IsEnd:       true,
       }}
   }
   
   // xxl.Logger接口实现
   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
       }
   }