xxl-job-executor的gin中间件 中间件 xxl-job-executor的gin中间件

rushui • 6447 次点击    
这是一个分享于 的项目,其中的信息可能已经有所发展或是发生改变。
# 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)) } ```
授权协议:
Apache
开发语言:
go 查看源码»
6447 次点击  
加入收藏 微博
0 回复
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传