分享
这是一个创建于 的主题,其中的信息可能已经有所发展或是发生改变。
# xxl-job-executor的gin中间件
## 背景
xxl-job-executor-go是xxl-job的golang执行器,可以独立运行,有时候我们要与项目或者框架(如:gin框架)集成起来合并为一个服务,本项目因此而生。
## 执行器项目地址
https://github.com/xxl-job/xxl-job-executor-go
## 与gin集成示例
```go
package main
import (
"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))
}
```
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信1251 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传