d

taskexecutor/app/base/db/task.base.js

@@ -17,7 +17,9 @@ class TaskBase{
      await  this.redisClient.subscribe(this.TASK_CHANNEL);
      //频道事件处理函数
      this.redisClient.subclient.on("message", async function (channel, message) {
+         if(channel==self.TASK_CHANNEL){
           await self.taskHandle(channel, message);
+         }
      });
     await this.subBeforeTask(params);
   }