node.js - Node.js 定期任务与集群

Question

我在生产模式下运行 StrongLoop 的 Loopback API 服务器。这意味着主进程创建尽可能多的工作人员，您的 CPU 有多少内核。所以主进程只控制工人，从不执行你的代码。

我的目的是一次只执行一次周期性任务，因为现在它在所有 4 个工作人员上运行。

除了 cron 或类似 Redis 的存储中的“键锁”之外，有什么建议吗？

Answer 1

在 iojs 和 node v0.12 中，可以进行独占套接字绑定。这可以用作类似于基于文件系统的方法的锁定形式。两者的方法相同：

attempt exclusive access to resource
if success:
   perform task
else:
   do not perform task

使用套接字，您可以执行以下操作：

net.createServer().on('error', function(err) {
  console.log('did not get lock', err);
}).listen({ port: 4321, exclusive: true }, function() {
  singleProcessTask();
  this.close();
});

请注意，这exclusive: true仅在集群模式下是必需的，因为它默认为共享套接字。

与fs.open类似：

fs.open('lock.file', 'wx', function(err, fd) {
  if (err) {
    console.log('did not get lock', err);
  } else{
    singleProcessTask();
    fs.close(fd, function(err) {
      // insert error handling here
      fs.unlink('lock.file', function(err) {
        // insert error handling here
      });
    });
});

在这两种情况下，如果您的任务非常快并且您的进程处于稍微不同的计时器计划上，则可能会出现竞争条件。在这些情况下，任务仍然一次只能由一个进程执行，但它可能会在每个计划期间处理多次，具体取决于您实施计划的方式。

编辑：更说明性的例子

var net = require('net');

var HOUR = 60*60*1000;

setInterval(myTask, HOUR);

function myTask() {
  locked(function() {
    // task code here
  });
}

function locked(fn) {
  net.createServer().on('error', function(err) {
    console.log('did not get lock', err);
  }).listen({ host: '127.0.0.1', port: 4321, exclusive: true }, function() {
    fn();
    this.close();
  });
}