memcache 插件
我们使用xxl-job
作为xxl-job-admin
连接的SDK
, 并且将其封装在xxxljob
包中。我们也为其适配了自动注册的rxxljob
包的实现。
如何使用
自动注册
在使用的过程中,我们只需要将rmemcache
导入到主程序中,比如
import (
_ "path/to/r/rxxljob"
)
func main() {
.....
}
主程序运行过程中会根据配置
中的数据,创建对应的实例,并且放到内存中。我们在使用的过程中,可以调用
cli := rxxljob.GetXJobManager("ngo.client.xxxljob")
直接拿到客户端,就可以使用了。
配置参数
参数 | 类型 | 含义 | 默认值 |
---|---|---|---|
Addr | string | xxl-job-admin 地址 | |
Token | string | 验证token | |
ExecutorIP | string | 客户端IP | |
ExecutorPort | string | 客户端port | |
ExecutorName | string | xxl-job-admin 中调度器的key |
配置举例
Addr = "http://xxljob:8080/xxl-job-admin"
ExecutorIP = "127.0.0.1"
ExecutorPort = "9999"
ExecutorName = "xxl-job-executor-sample"
目前我们只支持了同一个应用的一个客户端
。