如何使 node.js 脚本每小时重新启动一次?

How make a node.js script to be restarted every hour?

我有一个 node.js 脚本,可以创建到加密交易网站 (bitmex) 的 websocket 连接。它传输价格数据。

出于某种原因,一两个小时后流变坏并且价格(如果有流)不准确。

现在我每小时手动重启一次,但我需要它自动完成。我该怎么做?

脚本代码如下:

var WebSocket = require('ws');
var ws = new WebSocket("wss://www.bitmex.com/realtime");

var couchbase = require('couchbase')
var cluster = new couchbase.Cluster('couchbase://localhost/');
cluster.authenticate('xxxxxx', 'xxxxxxx');
var bucket = cluster.openBucket('test');
var N1qlQuery = couchbase.N1qlQuery;

let num_msg = 0;        
ws.onopen = function(){
    ws.send(JSON.stringify({"op": "subscribe", "args": [    
    "trade:XBTUSD",
    "trade:LTCZ18"]
    }))
};
ws.onmessage = function(msg){
    var response = JSON.parse(msg.data);
    num_msg++
    if(num_msg > 50) {
        var coin = response['data'][0]['symbol'];
        var price = response['data'][0]['price'];
        //console.log(coin + ":" + price + "\n");
        bucket.manager().createPrimaryIndex(
            function(){
                bucket.upsert(  coin, 
                                {
                                'price': price
                                },
                                function (err, result){
            });
        });

    }

};

编辑:我没有提到我目前使用 Windows 7 系统(尽管我确实需要移动到 Ubuntu 或类似系统)。

编辑 2:我的代码的最终版本:)

const cron = require("node-cron");
var WebSocket = require('ws');
var couchbase = require('couchbase');
var dateTime = require('node-datetime');

let now = new Date();
minutes = now.getMinutes() + 1;
if(minutes + 30 > 59) {
    minutes1 = minutes - 30;
} else {
    minutes1 = minutes - 30;
}
if(minutes > minutes1) {
    s_cron = minutes1 + "," + minutes +  " * * * *";
} else {
    s_cron = minutes + "," + minutes1 +  " * * * *";
}
cron.schedule(s_cron, () => {
    console.log("---------------------");
    console.log("Running Cron Job");
    var dt = dateTime.create();
    var formatted = dt.format('Y-m-d H:M:S');
    console.log(formatted);    
    // create bitmex ws
        var ws = new WebSocket("wss://www.bitmex.com/realtime");
        // connect to couchbase
        var cluster = new couchbase.Cluster('couchbase://localhost/');
        cluster.authenticate('xxxxxxxx', 'xxxxxxxxxx');
        var bucket = cluster.openBucket('test');
        var N1qlQuery = couchbase.N1qlQuery;

        let num_msg = 0;        
        ws.onopen = function(){
            ws.send(JSON.stringify({"op": "subscribe", "args": [    
                "trade:XBTUSD",
                "trade:LTCZ18"]
            }))
        };
        ws.onmessage = function(msg){
            var response = JSON.parse(msg.data);
            num_msg++
            if(num_msg > 50) {
                var coin = response['data'][0]['symbol'];
                var price = response['data'][0]['price'];
                //console.log(coin + ":" + price + "\n");
                bucket.manager().createPrimaryIndex(
                    function(){
                        bucket.upsert(  coin, 
                                        {
                                        'price': price
                                        },
                                        function (err, result){
                                            //bucket.disconnect()
                    });
                });

            }

        };
  });

考虑使用 cron 每小时重新启动一次。您的 crontab 条目将如下所示:

0 * * * * <command to restart your app>

如果您不能或不想使用您的系统 crontab 或等效系统(不确定它在 Windows 上会是什么),您可以使用 pm2

pm2: https://www.npmjs.com/package/pm2

关于如何使 pm2 每小时重新启动一次,请参阅 https://github.com/Unitech/pm2/issues/1076 or 。

另一种选择是 node-cronhttps://www.npmjs.com/package/node-cron

试试 'node-cron':更多内容在 https://www.npmjs.com/package/node-cron 希望有用。