bull plugin for Egg.js.
$ npm install -S @hackycy/egg-bull bull
$ npm install --save-dev @types/bull插件内并无直接依赖bull，需要自己安装
// {app_root}/config/plugin.ts
const plugin: EggPlugin = {
bull: {
enable: true,
package: '@hackycy/egg-bull',
},
}在app目录新建queue目录，所有的Queue都要在该文件夹下定义，注意返回的类型一定要为bull实例，否则使用该插件无意义。这里只是约定。
// app/queue/task.ts
import * as Queue from 'bull';
import { Application } from 'egg';
export default (app: Application) => {
app.logger.info('queue');
const q = new Queue('testqueue', {
redis: {
port: 6379,
host: '127.0.0.1',
password: '123456',
db: 0,
},
});
q.process(function(job, done) {
app.logger.info('[queue]', job.data);
done();
});
return q;
};可以以文件夹分隔。
建议export导出为一个funtion，这样会注入一个Egg的Application实例。
如无需使用Application实例的可以直接导出定义的bull实例。
该插件辅助定义了
egg-ts-helper，可以在TS项目中方便使用。
已经将所有定义的Queue挂载到了Application上，例如获取上述定义的
this.app.queue.task.add({ b: 'a' }); //具体使用与bull无差异请提出issues
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent