问题描述
我在 PM2(版本 5.1.0)pm2.delete(process,errback)
函数中遇到了一个非常烦人的问题。经过两天的调试,试图找到问题的根源,它开始看起来像一个与PM2库本身有关的问题。
这是我正在做的事情的简化代码片段。稍后我会解释这个问题。
const debug = require("debug")("...");
const pm2 = require("pm2");
const Database = require("./Database");
...
class Backend {
static cleanup() {
return new Promise((resolve,reject) => {
pm2.connect((error) => {
if (error) {
debug("...");
reject();
return;
}
// MongoDB query and async forEach iteration
Database.getCollection("...").find({
...
})
.forEach((document) => {
pm2.delete("service_...",(error,process) => {
if (!error && process[0].pm2_env.status === "stopped") {
debug("...");
} else {
debug("...");
}
});
})
.catch(...)
.then(...);
}
});
}
...
}
现在问题来了:我的进程没有被终止,errback
的 pm2.delete(process,errback)
根本没有被执行。
- 我打印了连接回调的错误参数,它总是
null
,因此与 PM2 的连接已成功建立 - 我直接在删除回调的开头放置了调试文本并且没有打印
- 我将删除函数包装在一个 while 循环中,只有在删除回调至少执行一次并且循环永远运行时才会停止
- 我启动了一个调试会话并注意到
node_modules/pm2/lib/API.js
(第 533 行)中 PM2 的删除函数被调用,但由于某种原因,该进程没有终止,并且我提供的回调函数根本没有执行(我去了在调试模式下通过命令一步一步,但仍然无法判断它在哪里执行回调失败(虽然它似乎发生在 PM2 的 API.js 中)) - 我还注意到,在带有断点的调试模式下逐步运行代码时,如果我在中间的某个点取消执行,有时我的进程会因 API 调用而终止(但是,回调仍未执行)
- 我也在我的软件的另一个地方使用了 PM2 的删除功能,它在那里工作得很有魅力
因此,由于某种原因,pm2.delete(process,errback)
没有正确执行,此时我不知道该怎么做。有人对 PM2 的源代码有经验或在某个时候遇到过类似的问题吗?任何建议都会有所帮助。
解决方法
看来我找到了问题的根源:
在 forEach 调用之后的 Promise 链中的稍后点,我使用 pm2.disconnect();
。经过进一步调查,我注意到它不是完全同步的,这意味着在我的情况下,PM2 在删除功能完全完成之前断开连接。这给出了描述的结果和奇怪的调试行为。
总而言之,API 工作得非常好,但必须非常注意异步代码,因为它会导致非常复杂的行为,而且也很难调试。
必须确保在调用 pm2.disconnect();
之前删除函数真的完成了。