新增分布式任务调度示例

src/app/modules/demo/queue/demo.ts

@@ -0,0 +1,19 @@
+import { App, Provide } from '@midwayjs/decorator';
+import { IMidwayWebApplication } from '@midwayjs/web';
+import { ICoolQueue, Queue } from 'midwayjs-cool-queue';
+
+/**
+ * 任务
+ */
+@Queue()
+@Provide()
+export abstract class DemoQueue implements ICoolQueue {
+  @App()
+  app: IMidwayWebApplication;
+
+  async data(job: any, done: any): Promise<void> {
+    // 这边可以执行定时任务具体的业务或队列的业务
+    console.log('数据', job);
+    done();
+  }
+}

src/app/modules/demo/service/task.ts

@@ -0,0 +1,15 @@
+import { Provide } from '@midwayjs/decorator';
+import { BaseService } from 'midwayjs-cool-core';
+/**
+ * 描述
+ */
+@Provide()
+export class DemoTaskService extends BaseService {
+  /**
+   * 测试任务执行
+   */
+  async test() {
+    // 需要登录后台任务管理配置任务
+    console.log('任务执行了');
+  }
+}