Sails.js中Bull队列任务无法执行问题求助

嘿，你遇到的队列任务不执行的核心原因，正是Bull.js完全依赖Redis作为消息存储中间件——它本身并没有内置Redis服务！

为什么任务没执行？ #

Bull的工作机制是把任务数据存在Redis里，再从Redis中取出任务分发给处理器。如果本地没有运行Redis服务，Bull会默认尝试连接localhost:6379，但连接失败后它不会直接崩溃，而是会静默重试，导致你添加的任务一直处于"等待"状态，永远到不了process回调的执行环节，自然看不到starting job日志。

快速验证方法 #

你可以在bootstrap的队列初始化代码里加上错误监听，确认是不是Redis连接问题：

let Queue = require('bull');
let q = new Queue('test queue');

// 添加错误监听
q.on('error', function(err) {
  console.error('Bull队列连接Redis失败:', err);
});

q.process(function(job, done){
  console.log("starting job");
  // 注意：这里要改成job.data.value，不是job.value！
  for(let i = 0; i < job.data.value; i+=1) {
    console.log(i);
  }
  done();
});
q.add({'value':10});
global.DirectUpdateQueue = q;

启动应用后如果控制台输出Redis连接错误，就完全确认是Redis未部署的问题了。

解决步骤 #

1. 部署本地Redis服务
   根据你的操作系统安装并启动Redis：

   • macOS：用Homebrew安装brew install redis，然后brew services start redis启动服务
   • Linux：通过包管理器（如apt/yum）安装redis-server并启动服务
   • Windows：下载官方Windows版Redis，或用WSL运行Linux版Redis
     启动Redis后重启你的Sails应用，队列任务应该就能正常执行了。

2. （可选）使用远程Redis服务
   如果不想在本地装Redis，也可以用云服务商提供的Redis服务，初始化队列时指定连接参数即可：

   let q = new Queue('test queue', {
     redis: {
       host: '你的Redis服务地址',
       port: 6379,
       password: '你的Redis密码' // 若有设置密码的话
     }
   });
   

额外代码修正 #

另外注意你的process回调里有个小错误：你通过q.add({'value':10})添加的任务数据，会被存在job.data对象里，所以要把job.value改成job.data.value，否则循环会因为job.value为undefined而直接跳过，即使Redis正常也看不到循环日志。

内容的提问来源于stack exchange，提问作者paul23