1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768 |
- package main
- import (
- "fmt"
- "github.com/gin-gonic/gin"
- "github.com/gin-middleware/xxl-job-executor"
- "github.com/xxl-job/xxl-job-executor-go"
- "github.com/xxl-job/xxl-job-executor-go/example/task"
- "log"
- )
- func main() {
- fmt.Println("hello world")
-
- exec := xxl.NewExecutor(
- xxl.ServerAddr("http://49.234.19.130:20061/xxl-job-admin/"),
-
- xxl.AccessToken(""),
- xxl.ExecutorIp("49.234.19.130"),
- xxl.ExecutorPort("9999"),
- xxl.RegistryKey("golang-jobs"),
- xxl.SetLogger(&logger{}),
- )
- exec.Init()
- r := gin.Default()
- xxl_job_executor_gin.XxlJobMux(r, exec)
-
- r.GET("ping", func(cxt *gin.Context) {
- cxt.JSON(200, "pong")
- })
-
- exec.RegTask("task.test", task.Test)
- exec.RegTask("task.test2", task.Test2)
- exec.RegTask("task.panic", task.Panic)
- log.Fatal(r.Run(":" + "9999"))
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- }
- 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...))
- }
|