Node.js程序提前退出，函数未执行完毕（已用回调仍无效）

我来帮你搞定这个头疼的问题——Node.js进程会在事件循环中没有待处理的异步任务时自动退出，你的IMAP邮件获取、解析都是异步操作，要是没让进程等到这些操作全部完成，它就会直接“跑路”，根本等不到回调执行。

从你给出的代码片段来看，核心问题是没有把异步操作的流程正确串联起来，也没有维持事件循环的活跃状态直到任务结束。下面给你一套具体的解决方案：

关键修复思路 #

1. 把回调式的异步操作封装成Promise，用async/await来控制流程，这样能更清晰地等待每个异步步骤完成
2. 监听所有异步操作的错误事件，避免未捕获的异常直接杀死进程
3. 显式控制进程退出时机，确保所有任务完成后再允许进程结束

修改后的完整示例代码 #

const Imap = require('imap');
const { MailParser } = require("mailparser");

// 预先定义邮箱的IMAP配置模板
const outlookConfig = {
  host: 'outlook.office365.com',
  port: 993,
  tls: true,
};
const gmailConfig = {
  host: 'imap.gmail.com',
  port: 993,
  tls: true,
};

let otp;
const fullPattern = new RegExp('<span.*>[0-9]{6}</span>');
const otpPattern = new RegExp('[0-9]{6}');

// 封装IMAP连接为Promise，方便用await等待连接成功
function connectImap(imapConfig) {
  return new Promise((resolve, reject) => {
    const imap = new Imap(imapConfig);
    
    // 监听连接成功事件
    imap.once('ready', () => {
      console.log('IMAP邮箱连接成功');
      resolve(imap);
    });
    
    // 监听连接错误事件
    imap.once('error', (err) => {
      console.error('IMAP连接失败:', err);
      reject(err);
    });
    
    imap.connect();
  });
}

// 封装邮件获取与OTP解析为Promise
async function fetchOtpFromMail(imap) {
  return new Promise((resolve, reject) => {
    // 打开收件箱
    imap.openBox('INBOX', false, (err, box) => {
      if (err) {
        console.error('打开收件箱失败:', err);
        return reject(err);
      }
      
      // 搜索最近1小时内的邮件（可根据需求调整搜索条件）
      const searchCriteria = ['ALL', ['SINCE', new Date(Date.now() - 3600000).toISOString().split('T')[0]]];
      // 只获取邮件文本内容，并标记为已读
      const fetchOptions = { bodies: ['TEXT'], markSeen: true };
      
      // 获取最新的邮件（这里取最后一封，你也可以根据需要调整范围）
      const fetch = imap.seq.fetch(box.messages.total + ':*', fetchOptions);
      
      fetch.on('message', (msg) => {
        const mailParser = new MailParser();
        
        // 把邮件流导入解析器
        msg.on('body', (stream) => stream.pipe(mailParser));
        
        // 解析完成后提取OTP
        mailParser.on('end', (parsedMail) => {
          const content = parsedMail.html || parsedMail.text;
          const fullMatch = fullPattern.exec(content);
          if (fullMatch) {
            otp = otpPattern.exec(fullMatch[0])[0];
            console.log('成功提取OTP:', otp);
            resolve(otp);
            // 完成后关闭IMAP连接，释放资源
            imap.end();
          }
        });
      });
      
      // 监听邮件获取错误
      fetch.once('error', (err) => {
        console.error('获取邮件失败:', err);
        reject(err);
        imap.end();
      });
      
      // 监听邮件获取结束事件，如果没找到OTP就抛出错误
      fetch.once('end', () => {
        if (!otp) {
          reject(new Error('未找到包含6位OTP的邮件'));
        }
      });
    });
  });
}

// 主流程函数，用async/await串联所有异步操作
async function getOtp(email, password, mailType) {
  try {
    // 选择对应的邮箱配置
    const baseConfig = mailType === 'outlook' ? outlookConfig : gmailConfig;
    const imapConfig = { ...baseConfig, user: email, password: password };
    
    // 等待IMAP连接成功
    const imap = await connectImap(imapConfig);
    
    // 等待邮件解析并提取OTP
    const resultOtp = await fetchOtpFromMail(imap);
    
    console.log('所有操作完成');
    return resultOtp;
  } catch (err) {
    console.error('流程执行出错:', err);
    throw err;
  }
}

// 调用主函数，确保进程等待所有操作完成
getOtp('你的邮箱地址', '你的邮箱密码', 'outlook')
  .then(() => {
    // 任务完成，正常退出进程
    process.exit(0);
  })
  .catch(() => {
    // 出错时异常退出进程
    process.exit(1);
  });

重要注意事项 #

• 确保你的邮箱已经开启了IMAP服务：比如Gmail需要在账户设置中开启IMAP，并且如果开启了两步验证，需要使用应用专用密码登录；Outlook需要确保IMAP服务处于启用状态
• 所有异步操作都要处理错误：未捕获的异常会直接导致进程崩溃退出，所以每个Promise都要加catch，IMAP的error事件也要监听
• 如果需要长期运行（比如持续监听邮件），可以不用手动调用process.exit()，保持IMAP连接活跃即可；如果是一次性获取OTP，用完关闭连接更节省资源

内容的提问来源于stack exchange，提问作者Mohammad Asif