如何解决已关闭Node.js应用后MySQL表仍被cron定时任务自动更新的问题

问题根源 #

1. 定时任务表达式配置错误：你代码中使用的* * * * *代表每分钟执行一次，并非你预期的每日午夜执行，正确的午夜执行cron表达式为0 0 * * *。
2. 存在未被终止的任务实例：Node应用停止后表仍在更新，说明服务器上还有其他运行中的相关进程，大概率是后台残留的Node进程、进程管理器托管的未关闭实例、系统级crontab配置或者多部署实例导致。

排查步骤 #

• 清理残留Node进程：执行命令ps aux | grep node查看所有运行中的Node进程，找到对应你项目的进程ID，执行kill -9 进程ID彻底终止。
• 检查系统crontab配置：执行crontab -l查看是否存在额外的定时任务，比如直接操作MySQL的脚本或者拉起你项目代码的配置，如有则删除对应规则。
• 检查进程管理器托管任务：如果你使用PM2、forever等进程管理工具，执行pm2 list查看托管列表，找到对应项目进程后执行pm2 delete 进程ID/名称彻底删除。
• 排查多部署实例：如果你的项目部署在Docker容器、集群或者多台服务器上，需要确认所有关联实例都已经停止运行。

代码优化建议 #

你提供的定时任务代码存在多处逻辑缺陷，建议同步修改：

const CronJob = require('cron').CronJob;
const logger = require("../helpers/logger");
const { updateUser } = require("../helpers/user");
const db = require("../models/db");

// 修改cron表达式为每天午夜执行
const job = new CronJob('0 0 * * *', async function() {
    try {
        // 原UPDATE操作后马上执行DELETE，无实际意义直接删除该步骤
        await db.query("DELETE FROM sponsored_posts", (err, data) => {
            if (err) logger.debug(err)
        });

        //EXPIRING USER
        const [expiringUsers] = await db.query("SELECT * FROM all_users WHERE membership_expired > 0");
        if (expiringUsers.length > 0) {
            // 用Promise.all包裹map的异步操作，保证所有更新完成再进入下一步
            await Promise.all(expiringUsers.map(async user => {
                await updateUser({
                    uid: parseInt(user.uid),
                    membership_expired: user.membership_expired - 1
                })
            }))
        }

        const [expiredUsers] = await db.query("SELECT * FROM all_users WHERE membership_expired = 0");
        if (expiredUsers.length > 0) {
            await Promise.all(expiredUsers.map(async user => {
                await updateUser({
                    uid: parseInt(user.uid),
                    can_purchase: 1
                })
            }))
        }
    } catch (e) {
        logger.error('定时任务执行异常', e)
    }
    
}, null, false, "Africa/Lagos");

job.start();

优化点说明：

• 修正了cron表达式为每日午夜执行
• 新增全局try/catch捕获执行异常，避免进程崩溃
• 回调式数据库查询改为Promise写法，统一控制异步流程
• 用Promise.all包裹批量异步更新操作，避免并行执行的时序问题和资源泄漏
• 删掉了无意义的UPDATE sponsored_posts操作，后续直接执行DELETE，前置更新状态没有实际作用

内容的提问来源于stack exchange，提问作者The Owner