使用sails.js框架在node.js中编写轮询服务

Question

我在sails.js 中有项目，我想编写一个轮询服务，在某个时间间隔检查一些记录，然后发送电子邮件。我的示例代码是：

 module.exports.bootstrap = function(cb) {
    cb();
    var refresh = function() {
        setTimeout(doWork, //someInterval);
    };

    var doWork = function() {
        if (//check some condition) {
            sendEmail();
        }
        refresh();
    };

    doWork();
 }

我使用 pm2 库并以集群模式启动我的项目。示例代码是：

pm2 start app.js -i 4

此命令以集群模式运行 app.js，有 4 个进程。 问题是我的轮询服务在所有进程中运行，因为我在 config/bootstrap.js 文件中运行我的轮询服务，这非常糟糕。
我的问题是如何在所有过程中运行一次我的服务？

Answer 1

您可以检查进程是否为主进程，然后仅在该情况下运行脚本。

var cluster = require('cluster');
if(cluster.isMaster) // rest of your service...

但对我来说...这是一个奇怪的逻辑...您应该将您的任务排队到共享数据库，当任务被池化时，将其从中删除等等。