捕获与释放模式：在 Node.js 中处理高容量 Webhook

免费领取国家顶级域名（.cn/.中国）

欢迎加入国家域名信源站点导航

站点智能：AI搭建 AI辅助运营独立站，把生意做到全世界

如果你正在构建一个与第三方供应商集成的应用程序接口（API），你最终将面临网络钩子（Webhook）洪流的挑战。

当外部服务发送大量的网络钩子事件峰值时，同步处理数据并将其插入数据库的标准方法会阻塞 Node.js 的事件循环。你的应用程序接口（API）将会超时，供应商会认为交付失败，而你将丢失关键数据。

为了应对不可预测的流量峰值，你需要将超文本传输协议（HTTP）响应与数据处理解耦。以下是如何使用 Node.js、Express 和 BullMQ 实现“捕获并释放”模式的方法。

先决条件

• 已安装 Node.js 和 Express。
• 正在运行的 Redis 实例（BullMQ 必需）。
• 对异步 JavaScript 有基本了解。

同步陷阱（切勿这样做）

大多数开发人员编写他们的第一个网络钩子接收器时是这样的：

app.post('/webhook/inventory', async (req, res) => {
  const payload = req.body;

  try {
    // ❌ 反模式：在响应之前进行繁重的处理
    const normalizedData = heavyDataTransformation(payload);
    await database.insert(normalizedData);

    // 供应商等待数据库完成...
    res.status(200).send('成功');
  } catch (error) {
    res.status(500).send('失败');
  }
});

问题所在：如果供应商每秒发送 500 个网络钩子，而你的数据库插入一条记录需要 200 毫秒，数据库连接池将达到上限。请求将排队堆积，内存使用量激增，连接将关闭。数据将永久丢失。

第一步：实现“捕获并释放”

网络钩子摄入的黄金法则是立即确认接收。在进行任何繁重操作之前，我们希望向供应商返回 200 OK 或 202 Accepted 状态。

为了安全地做到这一点，防止在服务器崩溃时丢失内存中的数据，我们将