BullMq
2021-07-27 09:56:25 4 举报AI智能生成
BullMq的状态流转
作者其他创作
大纲/内容
在增加Job之前必须要先有Queue实例，queue = new Queue()
queue.add()
普通任务
Script.addJob
延迟任务
在addJob会多做几件事
重复任务
其于上面两个任务的添加任务方式不一样，是直接在客户端调用`client.add`
停滞任务
是active出事故之后会被移入进来的
BullMq的事件在redis中的存储结构
Job
Hash
completed
failed
delayed
repeat
ative
wait
delay
events
worker上线
scripe.moveToActive
任务开设执行，pocessFn()
执行过程且执行完不报错
handleCompleted
如果执行handleCompleted的Job是个repeat任务
Script.moveToCompleted
执行过程出现抛错
handleFailed
Script.moveToFail
如果这个任务是设置了`attempts`参数
moveToFinshed
QueueSchduer上线
Script.updateDelaySet
Script.moveStalledJobsToWait
0 条评论
下一页
为你推荐
查看更多
抱歉，暂无相关内容 
