xxl-job-executor的gin中间件
xxl-job-executor的gin中间件
背景
xxl-job-executor-go是xxl-job的golang执行器，可以独立运行，有时候我们要与项目或者框架（如:gin框架）集成起来合并为一个服务，本项目因此而生。
本项目地址
https://github.com/gin-middleware/xxl-job-executor
执行器项目地址
【xxl-job-executor的gin中间件】https://github.com/xxl-job/xxl-job-executor-go
与gin集成示例
package mainimport (
"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"
)const Port = "9999"func main() {
//初始化执行器
exec := xxl.NewExecutor(
xxl.ServerAddr("http://127.0.0.1/xxl-job-admin"),
xxl.AccessToken(""),//请求令牌(默认为空)
xxl.ExecutorIp("127.0.0.1"),//可自动获取
xxl.ExecutorPort(Port),//默认9999（此处要与gin服务启动port必需一至）
xxl.RegistryKey("golang-jobs"), //执行器名称
)
exec.Init()
//添加到gin路由
r := gin.Default()
xxl_job_executor_gin.XxlJobMux(r, exec)//注册gin的handler
r.GET("ping", func(cxt *gin.Context) {
cxt.JSON(200, "pong")
})//注册任务handler
exec.RegTask("task.test", task.Test)
exec.RegTask("task.test2", task.Test2)
exec.RegTask("task.panic", task.Panic)log.Fatal(r.Run(":" + Port))
}
推荐阅读
- 热闹中的孤独
- JAVA（抽象类与接口的区别&重载与重写&内存泄漏）
- 放屁有这三个特征的，请注意啦！这说明你的身体毒素太多
- 一个人的旅行，三亚
- 布丽吉特，人生绝对的赢家
- 慢慢的美丽
- 尽力
- 一个小故事，我的思考。
- 家乡的那条小河
- 《真与假的困惑》???|《真与假的困惑》??? ——致良知是一种伟大的力量