如何防止 Node.js 在等待回调时退出？

Question

我有这样的代码：

var client = new mysql.Client(options);
console.log('Icanhasclient');

client.connect(function (err) {
  console.log('jannn');
  active_db = client;
  console.log(err);
  console.log('hest');

  if (callback) {
    if (err) {
      callback(err, null);
    }

    callback(null, active_db);
  }
});

我的问题是 Node 在我运行时立即终止。它打印“Icanhasclient”，但回调中的任何 console.log 都没有被调用。

（本例中的mysql是node-mysql。

有什么办法可以让 node.js 在退出之前等待回调完成？

Answer 1

这就是我的做法。我让我的主入口点返回一个承诺，然后我使用这个小包装器来确保只要该承诺没有解决，节点就不会退出：

function wrapPromiseMain(entryPoint) {
    const pollTime = 1000000;
    let interval = setInterval(() => {}, pollTime);
    
    return entryPoint().finally(() => {clearInterval(interval)});
}

要使用它，只需承诺化您的主入口点并将其作为参数传递给包装器：

function main() {

    // ... main stuff ...

    return doSomethingAsync();
}

wrapPromiseMain(main);

我发现它比基本的轮询循环更简洁，因为它会在 promise 完成时自动取消计时器，因此不会增加任何额外的延迟。因此，如果您愿意，轮询时间基本上可以是永久的。

Answer 2

请试试这个。检查这是否有帮助。

var client = new mysql.Client(options);
console.log('Icanhasclient');
var verbose;

if (!verbose) {
    return new Promise(function (resolve, reject) {
        client.connect(function (err) {
            if (err) {
                console.log(Error in connecting
                SQL ${err}
            )
                ;
                return reject(err);
            }
            verbose = client;
            return resolve(verbose);
        })
    })
} else {
    return new Promise(function (resolve) {
        resolve(verbose);
    })
}

Answer 3

这是我的两分钱：

async function main()
{
    await new Promise(function () {});
    console.log('This text will never be printed');
}

function panic(error)
{
    console.error(error);
    process.exit(1);
}

// https://stackoverflow.com/a/46916601/1478566
main().catch(panic).finally(clearInterval.bind(null, setInterval(a=>a, 1E9)));

Answer 4

根据@Todd 的回答，我创建了一个单行。将其包含在脚本的开头，完成后设置done = true：

var done = (function wait () { if (!done) setTimeout(wait, 1000) })();

例子：

var done = (function wait () { if (!done) setTimeout(wait, 1000) })();

someAsyncOperation().then(() => {
  console.log('Good to go!');
  done = true;
});

它是如何工作的？如果我们稍微扩展一下：

// Initialize the variable `done` to `undefined`
// Create the function wait, which is available inside itself
// Note: `var` is hoisted but `let` is not so we need to use `var`
var done = (function wait () {

  // As long as it's nor marked as done, create a new event+queue
  if (!done) setTimeout(wait, 1000);

  // No return value; done will resolve to false (undefined)
})();

Answer 5

我的解决方案是实例化一个 EventEmitter，并监听我的自定义事件。

var eventEmitter = new process.EventEmitter();

然后我从异步回调中调用了eventEmitter.emit：

client.connect(function (err) {
    eventEmitter.emit('myevent', {something: "Bla"})
});

我脚本中的最后一件事是eventEmitter.on：

eventEmitter.on('myevent', function(myResult){
  // I needed the result to be written to stdout so that the calling process could get it
  process.stdout.write(JSON.stringify(myResult));
});

然后节点将等待事件处理程序完成运行。

Answer 6

您可以使用 setInterval 发出 setTimeout 或重复超时。

如果你想检查退出条件，你也可以做一个条件超时：

(function wait () {
   if (!SOME_EXIT_CONDITION) setTimeout(wait, 1000);
})();

把它放在你代码的最后，控制台会一直等待……然后等待……直到你想要它关闭。

Answer 7

我确实查看了felixge/node-mysql 库，但没有在 API 中看到对命令 client.connect 的引用。这是您要拨打的实际电话（不是在这里挑剔）吗？无论如何，恕我直言，您需要更多地考虑 Javascript 的设计方式，因为它使用的编程范式不同于大多数其他流行语言。

我在您的代码中看到的第一个问题是您尚未定义回调，因此它实际上并不存在。我假设 console.log(callback) 是未定义的。从您的代码中，匿名函数是 client.connect 函数的“回调”。您必须在更高的范围内定义您所谓的“回调”。例如，我将定义一个函数 myCallback 存在于高于 client.connect 的匿名函数的范围内。查找 Javascript variable scope 可能很有用。

    var myCallback(err, response) {
      if (err) {
        console.log('err:%s',err);
      } else {
        console.log('response:%s',response);
      }
    }

    client.connect(err, function(response) {
      // this anonymous function is the callback to client.connect, the var
      // 'callback' would be undefined.
      if (err) {
        myCallback(err);
        return; // Explicit call to return, else the lines below would run.
      } 
      myCallback(null, response);
    });

其次，如果你没有在Javascript中显式调用return，函数会继续处理。我被这个myself 咬了。最后，Javascript 运行一个event-driven 循环，这意味着它永远不会等待函数返回一个值，这就是我们首先拥有所有这些回调的原因。您可以强制 Javascript 表现不同，例如通过使用 while 循环直到条件为真。请参阅caolan 的“异步”库，了解操作事件循环的各种策略。过度使用这些方法的主要缺点是您实际上浪费了 CPU 周期/阻塞，而您可能应该使用更多回调并简单地重新考虑您的程序是如何工作的。

Answer 8

回调未排队

节点运行直到所有事件队列为空。当调用诸如

时，将回调添加到事件 queue

  emmiter1.on('this_event',callback).

已执行。此调用是模块开发人员编写的代码的一部分。

如果一个模块是同步/阻塞版本的快速端口，这可能不会发生，直到操作的某些部分完成并且所有队列可能在此之前清空，从而允许节点静默退出。

这是一个鬼鬼祟祟的错误，模块开发人员在开发过程中可能不会遇到，因为它在具有许多 队列 的繁忙系统中发生的频率较低，因为对于所有它们在关键时刻为空。

用户可能的修复/错误检测器是在可疑函数调用之前插入一个特殊的计时器事件。