Sailsjs 中的公牛任务不起作用？

Question

好吧，我（天真地）试图让公牛在一个sails应用程序中工作：最终我希望有一个队列，我可以根据传入的路线添加/删除/检查任务。

现在，据我了解，要创建一个在全球范围内工作的排队系统，我必须在 bootstrap.js 中添加此设置。

/**
 * Bootstrap
 * (sails.config.bootstrap)
 *
 * An asynchronous bootstrap function that runs before your Sails app gets lifted.
 * This gives you an opportunity to set up your data model, run jobs, or perform some special logic.
 *
 * For more information on bootstrapping your app, check out:
 * https://sailsjs.com/config/bootstrap
 */
module.exports.bootstrap = function(done) {

  // It's very important to trigger this callback method when you are finished
  // with the bootstrap!  (otherwise your server will never lift, since it's waiting on the bootstrap)
  let Queue = require('bull');
  let q = new Queue('test queue');
  q.process(function(job, done){
    console.log("starting job");
    for(let i = 0; i<job.value; i+=1) {
      console.log(i);
    }
    done();
  });
  q.add({'value':10});
  global.DirectUpdateQueue = q;
  return done();

};

根据上面的代码，sails 可以正常启动，并且在路线中我可以看到 global.DirectUpdateQueue 存在。

但不起作用的是排队的任务被执行。 - 我在控制台中看不到任何日志（至少应为“开始工作”）。当我在处理函数中设置断点时，代码也不会中断。

那么这里发生了什么？

编辑：这可能是因为我没有设置（本地）redis 服务器吗？ - 我没有找到有关此主题的任何信息，但我希望/希望 Bull.js 能够在内部实际处理此服务器，并且（更重要的是）不限于特定（OS）环境。

Answer 1

因此，首先，您必须确保在您的服务器上安装了 Redis。 创建队列时，您可以在下面的示例中传递 Redis 配置，这是默认设置。

然后在 bootsrap.js 中：

  var Queue = require('bull');
  var testQueue = new Queue('Website Queue', 'redis://127.0.0.1:6379');
  testQueue.process(function(job, done){

    console.log('job started');

    setTimeout(function () {

        console.log('10 seconds later');
        console.log(job.data);

    }, 10000)

    done(); 
    });    

  global.testQueue = testQueue; 

然后从动作/控制器你可以这样做：

testQueue.add({'value':10}); 

Answer 2

首先你必须连接到一个 Redis 服务器

var testQueue = new Queue('test', {
  redis: {
    port: 6379,
    host: '127.0.0.1',
    password: 'secret'
  }
});

根据the doc：

如果队列为空，则直接执行作业，否则将被放入队列并尽快执行。

要访问作业中的数据，请使用 job.data 对象：

testQueue.process((job) => {
  console.log("job with data 'foo' :", job.data.foo);

  // example with Promise
  return asynchTreatment()
  .then(() => { console.log('treatment ok'); })
  .catch((err) => { console.log('treatment ko :', err); }
}).on('completed', (job, result) => {
  // Job completed with output result!
  console.log('result :', result);
});

testQueue.add({ foo : 'bar' });

编辑 1：

医生说：

它创建了一个持久化在 Redis 中的新队列。每次实例化同一个队列时，它都会尝试处理之前未完成会话中可能存在的所有旧作业。

因此，如果服务器重新启动，您不会失去工作。

Answer 3

只需在 for 循环中使用 job.data.value

for(let i = 0; i<job.data.value; i+=1) {
  console.log(i);
}