使用Puppeteer.js批量截图URL/SVG遇EventEmitter内存泄漏问题求助

嗨，我来帮你搞定这个问题！

你遇到的MaxListenersExceededWarning，本质是因为代码一次性启动了太多无头Chrome实例，导致Node.js的事件监听器数量超出了默认上限。要实现逐个处理截图任务，核心是把并行的异步操作改成串行执行，或者控制并发数量，下面给你具体的解决方案：

方案1：完全串行处理（逐个执行任务） #

最直接的方式是用for...of循环配合await，确保前一个截图任务完全结束（包括关闭Chrome实例）后，再启动下一个任务。假设你用的是Puppeteer，代码示例如下：

const puppeteer = require('puppeteer');

// 单个截图任务的封装函数
async function takeSingleScreenshot(targetUrl, saveFilePath) {
  const browser = await puppeteer.launch({ headless: 'new' });
  const page = await browser.newPage();
  
  try {
    await page.goto(targetUrl, { waitUntil: 'networkidle2' }); // 等待页面加载完成
    await page.screenshot({ path: saveFilePath });
    console.log(`✅ 完成截图：${targetUrl}`);
  } catch (err) {
    console.error(`❌ 截图失败：${targetUrl}`, err);
  } finally {
    await browser.close(); // 关键：用完必须关闭浏览器，避免进程残留
  }
}

// 串行处理所有任务的函数
async function processScreenshotsSequentially(urlList) {
  for (const { url, savePath } of urlList) {
    await takeSingleScreenshot(url, savePath);
  }
}

// 调用示例
const targetUrls = [
  { url: 'https://example.com', savePath: './screenshots/example.png' },
  { url: 'https://google.com', savePath: './screenshots/google.png' },
  // 更多URL/SVG路径...
];

processScreenshotsSequentially(targetUrls);

这段代码里，for...of循环会等待每个takeSingleScreenshot执行完毕再进入下一次迭代，同一时间只会有一个Chrome实例在运行，从根源上避免了实例过多的问题。

方案2：控制并发数（兼顾效率与稳定性） #

如果你不想完全串行，想同时运行少量任务提高效率，可以用并发控制工具（比如p-limit库）来限制同时运行的Chrome实例数量，示例如下：

const puppeteer = require('puppeteer');
const pLimit = require('p-limit');

// 限制同时最多3个任务并行
const concurrencyLimit = pLimit(3);

async function takeSingleScreenshot(targetUrl, saveFilePath) {
  const browser = await puppeteer.launch({ headless: 'new' });
  const page = await browser.newPage();
  
  try {
    await page.goto(targetUrl, { waitUntil: 'networkidle2' });
    await page.screenshot({ path: saveFilePath });
    console.log(`✅ 完成截图：${targetUrl}`);
  } catch (err) {
    console.error(`❌ 截图失败：${targetUrl}`, err);
  } finally {
    await browser.close();
  }
}

async function processScreenshotsWithConcurrency(urlList) {
  // 把所有任务包装成受限制的异步函数
  const tasks = urlList.map(item => 
    concurrencyLimit(() => takeSingleScreenshot(item.url, item.savePath))
  );
  await Promise.all(tasks);
}

// 调用示例
const targetUrls = [
  { url: 'https://example.com', savePath: './screenshots/example.png' },
  { url: 'https://google.com', savePath: './screenshots/google.png' },
  // 更多URL/SVG路径...
];

processScreenshotsWithConcurrency(targetUrls);

这种方式既不会一次性启动太多实例，又能比串行处理更快完成任务，适合URL数量较多的场景。

额外注意事项 #

• 务必关闭浏览器实例：每次截图完成后一定要调用await browser.close()，否则Chrome进程会残留，导致内存占用飙升，甚至引发更多错误。
• 应急临时方案（不推荐）：如果暂时无法修改代码结构，可以临时提高Node.js的事件监听器上限，在代码开头添加：require('events').EventEmitter.defaultMaxListeners = 20;，但这只是治标不治本，还是推荐从任务执行方式上解决问题。

内容的提问来源于stack exchange，提问作者ssp singh