服务端¶
初始化¶
使用
NewServer()初始化服务，其参数是server的配置，所有配置在下面
import "github.com/gojuukaze/YTask/v2"
ser := ytask.Server.NewServer(
ytask.Config.Broker(&broker),
ytask.Config.Backend(&backend),
...
)
服务端配置¶
配置 |
是否必须 |
默认值 |
code |
说明 |
|---|---|---|---|---|
Broker |
* |
ytask.Co nfig.Broker |
||
Backend |
nil |
ytask.Con fig.Backend |
||
Logger |
log. YTaskLogger |
ytask.Co nfig.Logger |
logger, v2.5+支持 |
|
Debug |
FALSE |
ytask.C onfig.Debug |
是 否开启debug |
|
St atusExpires |
1day |
ytas k.Config.St atusExpires |
单位 ：秒，任务 状态的过期 时间,-1:永 久保存（有 的backend可 能不支持） |
|
Re sultExpires |
1day |
ytas k.Config.Re sultExpires |
单位 ：秒，任务 结果的过期 时间,-1:永 久保存（有 的backend可 能不支持） |
任务状态、结果有什么不同？
状态： 任务的开始、运行、成功、失败状态
结果： 函数的返回值
对于
mongo backend过期时间 0代表不存储，>0代表永久存储
注册任务¶
使用Add注册任务
func addFunc(a,b int) (int, bool){
return a+b, true
}
// group1 : 任务所属组，也是队列的名字
// add : 任务名
// addFunc : 任务函数
ser.Add("group1","add",addFunc)
任务函数的 参数、返回值 支持所有能被系列化为json的类型。
如果需要在函数中控制任务的重试等东西，则函数的第一个参数为TaskCtl
(带TaskCtl函数和其他函数使用上没区别)
如：
func addFunc(ctl *controller.TaskCtl, a int, b int) (int, int) {
if ... {
// retry
ctl.Retry(errors.New("ctl.Retry"))
return 0, 0
}
return a + b, a - b
}
ser.Add("group1","add",addFunc)
日志接口¶
v2.5+支持
只要实现 log.LoggerInterface 接口即可，默认已经实现一个基于 logrus 的 logger
logger := ytask.Logger.NewYTaskLogger()
Server := ytask.Server.NewServer(
...
ytask.Config.Logger(logger), // 可以不设置 logger
...
)
任务回调¶
v2.4+支持
注册任务时可以为任务添加回调函数，回调函数在 任务结束 后调用，前几个参数为任务的参数，最后一个参数为返回结果。
回调函数报错并不会影响任务的结果，另外由于回调函数和任务函数是在同一个goroutine中执行，回调函数不结束会导致当前worker一直被占用， 因此你需要根据实际需求评估回调函数需要执行的任务。
func addFunc(a,b int) (int, bool){
return a+b, true
}
func callbackFunc(a,b int, result *message.Result) {
if result.IsSuccess(){
// do ...
}else {
// do ...
}
}
ser.Add("group1", "add", addFunc, callbackFunc)
运行与停止¶
// group1 : 运行的组名
// 3 : 并发任务数
// false : 是否开启延时任务
ser.Run("group1", 3, false)
quit := make(chan os.Signal, 1)
signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
<-quit
ser.Shutdown(context.Background())