初级会员
  • 第 51982 位会员
  • rushui
  • 如水
  • 2020-04-21 11:14:49
  • Offline
  • 34 12

最近的评论

  • ### 最近更新,可自定义日志了 # xxl-job-executor-go 很多公司java与go开发共存,java中有xxl-job做为任务调度引擎,为此也出现了go执行器(客户端),使用起来比较简单: # 支持 ``` 1.执行器注册 2.耗时任务取消 3.任务注册,像写http.Handler一样方便 4.任务panic处理 5.阻塞策略处理 6.任务完成支持返回执行备注 7.任务超时取消 (单位:秒,0为不限制) 8.失败重试次数(在参数param中,目前由任务自行处理) 9.可自定义日志输出 10.自定义日志查看handler ``` # Example ``` package main import ( 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("http://127.0.0.1/xxl-job-admin"), xxl.AccessToken(""), //请求令牌(默认为空) xxl.ExecutorIp("127.0.0.1"), //可自动获取 xxl.ExecutorPort("9999"), //默认9999(非必填) xxl.RegistryKey("golang-jobs"), ) exec.Init() //设置日志查看handler exec.LogHandler(func(req *xxl.LogReq) *xxl.LogRes { return &xxl.LogRes{Code: 200, Msg: "", Content: xxl.LogResContent{ FromLineNum: req.FromLineNum, ToLineNum: 2, LogContent: "这个是自定义日志handler", IsEnd: true, }} }) //注册任务handler exec.RegTask("task.test", task.Test) exec.RegTask("task.test2", task.Test2) exec.RegTask("task.panic", task.Panic) log.Fatal(exec.Run()) } ``` # see github.com/xxl-job/xxl-job-executor-go/example/ # xxl-job-admin配置 ### 添加执行器 执行器管理->新增执行器,执行器列表如下: ``` AppName 名称 注册方式 OnLine 机器地址 操作 golang-jobs golang执行器 自动注册 无 ``` ### 添加任务 任务管理->新增(注意,使用BEAN模式,JobHandler与RegTask名称一致) ``` 1 测试panic BEAN:task.panic * 0 * * * ? admin STOP 2 测试耗时任务 BEAN:task.test2 * * * * * ? admin STOP 3 测试golang BEAN:task.test * * * * * ? admin STOP ```
  • 评论了主题 xxl-job golang客户端
    目前已处理panic错误,并会上报到xxl-job服务端
  • 评论了项目 xxl-jobgolang客户端
    xxl-job是一个分步式定时任务系统
  • golang 基础库:https://github.com/go-basic