这是一个很难描述的问题。 我有一个 koajs 应用程序，该应用程序每 2 分钟在多个实例(10-1000 范围)中创建一个函数。此计划作业在应用程序启动时创建。我使用 koajs 是因为我需要一些简单的 api 端点用于这个应用程序。前 3-5 小时运行良好，然后创建的实例数开始减少，部分日志输出消失。

这是基于实际代码的最小示例:

server.ts

const bootstrap = async () => {
    process.setMaxListeners(0); //(node:7310) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 uncaughtException listeners added to [process]. Use emitter.setMaxListeners() to increase limit
                                //appears on app startup (however seems like this setMaxListeners(0) doesnt affect anything since the warning persist)
    const app = new Koa();
    app.use(async ctx => {
        ctx.body = "Welcome to my Server!";
    });
    app.listen(port);
    new Main().run();
};

bootstrap(); 

ma​​in.ts(试过:cron npm 包，node-scheduler，setInterval，递归setTimeout) 来运行 scheduledJobWrapper。

    isStarting: boolean = false;

    async run() {
        logger.info(`running the app, every 2 minutes`);

        //let that = this;
        // new CronJob(`*/2 * * * *`, function () {
        //     that.scheduledJobWrapper();
        // }, null, true, 'America/Los_Angeles');

        const interval = 2 * 60 * 1000;
        setInterval(() => {
            this.scheduledJobWrapper();
        }, interval);
    }

    async scheduledJobWrapper() {
        logger.info("here scheduledJobWrapper");

        let args = {};
        //some irrelevant logic to set the arguments
        await this.scheduledJob(args);
    }

    async scheduledJob(args) {
        try {
            logger.info("starting");
            if (!this.isStarting) {
                this.isStarting = true;

                const runningCount = Executor.tasks.length; //Executor.tasks is a singleton containing some info about tasks. details are irrelevant. the point is it contains the active tasks.
                const tasksLimit = 100;

                if (runningCount < tasksLimit) {
                    for await (const i of Array(tasksLimit - runningCount).keys()) {
                        if (Executor.tasks.length > 20)
                            await global.sleep(5 * 1000);

                        this.startWrapper(args); //calling main task here
                    }
                }
                this.isStarting = false;

                logger.info(`Started: ${Executor.tasks.length - runningCount}`);
            }
        } catch (e) {
            logger.error("Error running scheduled job: " + e.toString());
        }
    }

在本例中，问题表现如下: 前 3-5 小时所有工作都按预期工作，之后每次调用计划的函数:

1. logger.info("here scheduledJobWrapper"); 现在会显示任何输出。
2. logger.info("starting"); 不在输出中
3. this.startWrapper 确实运行并且其中的代码正在执行。

尽管 this.startWrapper 内部的代码仍在运行，但新创建的作业数量正在缓慢减少。 硬件 (RAM/CPU) 没有得到任何显着负载(CPU 低于 10%，RAM 低于 20%)

关于可能原因的任何线索？

nodejs: 12.6.0

谢谢!

更新 似乎使用 setInterval 应用程序可以正常运行更长的时间(6-24 小时)，但之后问题仍然存在。

最佳答案

问题在于 setInterval 函数。它会随着时间变慢。它也有奇怪的行为。您可以使用 setTimeout 创建自定义 setInterval 或使用第三方模块并尝试。

示例 setInterval 实现。

const intervals = new Map();
function setInterval(fn, time, context, ...args) {
  const id = new Date().getTime() + "" + Math.floor(Math.random() * 10000);
  intervals.set(
    id,
    setTimeout(function next() {
      intervals.set(id, setTimeout(next, time));
      fn.apply(context, args);
    }, time)
  );
  return id;
}
function clearInterval(id) {
  clearTimeout(intervals.get(id));
}

setInterval(console.log, 100, console, "hi");

You can also enhance, by adding delta time loss in next setTimeout. Meaning if time loss, run next setTimeout earlier.

关于javascript - 每 2 分钟运行一次的 Nodejs 函数会随着时间的推移而丢失，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/56935112/