0.1.0 • Published 2 years ago
wt-mission-queue v0.1.0
wt-mission-queue
use
queue
创建一个 mission 队列
提供方法
| 方法 | 作用 | 备注 |
|---|---|---|
| start | 开始队列消费 | |
| mission | 注册一个 mission 到队列中 | |
| createMsg | 创建一个队列消息，需要提供参数为：指定消费的 mission，消息体、是否为最高优先级 | 此方法只能进行消息创建，不支持自动发送消息到对队列中 |
| send | 向队列中发送消息 | |
| destroyMsg | 在队列中销毁消息，提供消息标识：identifier |
提供事件
| 事件 | 作用 | 备注 |
|---|---|---|
| consumed | 消息消费完成后触发（成功及失败） |
mission
创建一个 mission 消费者
提供方法
| 方法 | 作用 | 备注 |
|---|---|---|
| constructor | 创建一个mission，需要提供名称以及组成单元 | |
| before | 钩子：消息正式消费前 | |
| after | 钩子：消息消费后 |
unit
消费者组成单元，由一个个 task 组成
提供方法
| 方法 | 作用 | 备注 |
|---|---|---|
| task | 细粒度拆分消费者 |
message
由所属 mission、消息体、消息标识组成
store
消息消费过程中数据传输载体
组成部分
| 属性 | 作用 |
|---|---|
| state | 存放运行过程中产生的数据 |
| content | 存放结果 |
samples
npm run samples