feixiaobo/go-xxl-job-client
Fork: 15 Star: 39 (更新于 2024-11-06 12:45:19)
license: 暂无
Language: Go .
xxl-job go client
最后发布版本: v2.1.1 ( 2020-11-26 15:24:42)
go-xxl-job-client
xxl-job go 客户端版
介绍
xxj-job 是一个 Java 实现的轻量级分布式任务调度平台,具体实现与使用请参考https://github.com/xuxueli/xxl-job,原版执行器亦要求 Java 平台,但公司部分项目是 golang 开发,所以自己实现了 go 版本的执行器。
写在前面
- 我所实现的 go 客户端执行器 rpc 通信采用 dubbo-go 所用的类型 Java netty 的自研通信框架 getty(请参考:https://github.com/dubbogo/getty).
- 整个设计实现是参考 xxl-job-core 的源码实现了 go 版本,核心在于 admin 与执行器的 rpc 通讯采用的序列化方式是 hessian2,所有借用了 apache 实现的 dubbo-go-hessian2(参考https://github.com/apache/dubbo-go-hessian2)。
- 支持了 shell, python, php, js, powershell,暂不支持动态编译的 groovy 模式。
- 脚本模式的分片参数会作为启动脚本时的最后两个参数,用户参数按顺序位于分片参数之前。
部署 xxl-job-admin
详细步骤请参考https://github.com/xuxueli/xxl-job, 此处不再描述 admin 的部署。
部署 xxl-job 执行器(go 版本)
(1) 引入 go 客户端依赖
go get github.com/feixiaobo/go-xxl-job-client/v2
(2) 在 main 方法中构建客户端 client,注册任务,启动端口
(1) 实现任务
func XxlJobTest(ctx context.Context) error {
logger.Info(ctx, "golang job run success >>>>>>>>>>>>>>")
logger.Info(ctx, "the input param:", xxl.GetParam(ctx, "name"))
return nil
}
(2) 注册执行,任务,启动项目(可参考 example 目录)
client := xxl.NewXxlClient(
option.WithAppName("go-example"),
option.WithEnableHttp(true), //xxl_job v2.2.0版本及以后
option.WithClientPort(8083),
) //构建客户端
client.RegisterJob("testJob", JobTest) //注册任务
client.Run() //启动客户端
- 构建客户端时的 appName 是 xxl-job-admin 后台添加执行器时的 name
- 注册任务时的名字是 xxl-job-admin 后台新增任务时的 JobHandler
(3) 在 xxl-job-admin 后台管理页面添加执行器
- appName 为客户注册执行器时的名字
- 注册方式选择自动注册
(4) 在 xxl-job-admin 后台管理页面添加任务
- JobHandler 为注册任务时的 name
- 执行器选择刚刚添加的执行器
- 运行模式默认 BEAN 模式,可选择其他脚本模式(不支持 GLUE(Java))
添加完成后启动在任务管理菜单中查看任务
日志输出及参数传递
- go-xxl-job-client 自己实现了日志输出,使用 github.com/feixiaobo/go-xxl-job-client/v2/logger 包输出日志,因为 golang 不支持像 Java 的 ThreadLocal 一样的线程变量,已无法获取到 golang 的协程 id,所以日志输出依赖的内容已存到 context 上下文遍历中,故 log 需要使用 context 变量。可参考任务配置中的日志输出,
logger.Info(ctx, "golang job run success >>>>>>>>>>>>>>")
- 任务参数传递,可使用 xxl.GetParam 获取到任务配置或执行时手动添加的参数,使用 xxl.GetSharding 获取到分片参数。
param, _ := xxl.GetParam(ctx, "name") //获取输入参数
logger.Info(ctx, "the input param:", param)
shardingIdx, shardingTotal := xxl.GetSharding(ctx) //获取分片参数
logger.Info(ctx, "the sharding param: idx:", shardingIdx, ", total:", shardingTotal)
在调度日志中点击执行日志查看任务执行日志。
F&Q
(1) 遇到错误:register executor failed, please check xxl admin address or accessToken
xxl_job_admin地址不通或者accessToken错误,请检查是否配置了AdminAddress
(2) 执行任务admin端报错:java.net.MalformedURLException: no protocol: 192.168.0.105:8083/run
xxl_job_admin v2.2.0之后和客户端通信采用http/https通信。需在client端开启http协议,在client option中构造 option.WithEnableHttp(true), 参考 example下client_test。 旧版本请不要添加这个option
最近版本更新:(数据更新于 2024-09-24 05:50:40)
2020-11-26 15:24:42 v2.1.1
2020-09-26 16:49:56 v2.1.0
2020-07-17 12:13:39 v2.0.3
2020-03-04 16:02:17 v1.0.5
2020-03-04 11:41:36 v1.0.4
2020-03-03 18:25:31 v1.0.3
2020-03-03 17:28:16 v1.0.2
主题(topics):
glue, go, golang, hessian2, job-scheduler, scheduler, task, xxl-job
feixiaobo/go-xxl-job-client同语言 Go最近更新仓库
2024-11-21 22:49:20 containerd/containerd
2024-11-21 13:50:50 XTLS/Xray-core
2024-11-21 07:36:18 kubernetes/kubernetes
2024-11-21 06:27:30 ollama/ollama
2024-11-21 05:17:55 Melkeydev/go-blueprint
2024-11-21 04:04:03 dolthub/dolt