javascript - Node.js 超时未触发

Question

我正在使用x-ray用于抓取特定网站的某些内容并将其保存在 JSON 文件中的库。

我想每小时获取一次状态，但 Node 不执行我的 setTimeout。

这是我的代码:

var db, record, x;
x = require('x-ray')();
db = require('lowdb')('rec.json', {
  storage: require('lowdb/file-async')
});

record = function() {
  console.log('will contact server');
  setTimeout(record, 60 * 60 * 1000);
  x('http://example.com', 'h1')(function(err, content) {
    console.log('server contacted');
    if (err) {
      console.log('error occurred');
      db('status').push({
        time: (new Date).toString(),
        status: err
      });
    } else {
      console.log('status recorded successfully');
      db('status').push({
        time: (new Date).toString(),
        status: content
      });
    }
  });
};
console.log('ready');

record();

第一次记录时没有任何问题，但之后就什么也不做。看来 record 函数只执行一次。

我使用 pm2 来管理进程，pm2 list 显示它的运行时间远远超过 60 分钟。即使 Node 无法在给定时间内准确执行回调，该进程仍处于事件状态(最长，在我重新启动之前)大约 80 分钟。

日志中没有错误，并且在我的测试过程中没有意外重启。

也许这与我使用的库有关？我不知道是什么原因造成的。

Answer 1

来自LowDB Docs :

Important

When you modify the database, a Promise is returned.

When you read from the database, the result is immediately returned.

在 then 回调中安排函数执行应该可以:

var db, record, x;
x = require('x-ray')();
db = require('lowdb')('rec.json', {
  storage: require('lowdb/file-async')
});

record = function() {
  console.log('will contact server');
  x('http://example.com', 'h1')(function(err, content) {
    console.log('server contacted');
    if (err) {
      console.log('error occurred');
      db('status').push({
        time: (new Date).toString(),
        status: err
      }).then(function(status) {
        setTimeout(record, 60 * 60 * 1000);
      });
    } else {
      console.log('status recorded successfully');
      db('status').push({
        time: (new Date).toString(),
        status: content
      }).then(function(status) {
        setTimeout(record, 60 * 60 * 1000);
      });
    }
  });
};
console.log('ready');

record();