基于Node.js搭建webhook分发服务器的现有实现方案是否正确？

核心思路正确性 #

你这套Webhook分发的底层逻辑（用户注册回调地址、服务端触发事件后批量推送）的方向完全正确，和Facebook Messenger等主流平台的Webhook机制核心逻辑一致。但现有代码存在几个明显错误，无法直接正常运行：

• /set-webhook接口取值错误：你写的const clientWebhookUrl = req.url获取的是当前请求的路径/set-webhook，不是用户提交的回调地址，应该从请求体中取用户上传的地址参数
• 语法错误：/set-webhook路由的回调函数末尾缺少闭合的)，会直接导致服务启动报错
• /handle-webhooks里的回调地址是硬编码的，生产环境需要从数据库中查询所有已注册的用户地址循环推送

如果要上线正式使用，还需要补充以下必要的逻辑：

• Webhook地址有效性校验：用户提交回调地址后不要直接存储，要先发起一次校验请求（比如GET请求携带随机challenge参数，要求用户服务返回该challenge值），避免用户填写无效地址、或者恶意填写第三方地址导致垃圾推送，这是所有主流Webhook平台的标准流程
• 签名校验：推送数据时要在请求头中加入签名，用你和用户约定的密钥（用户注册时可以生成唯一的access token下发给用户）对推送内容加密生成签名，用户收到请求后可以用相同规则验签，确认数据是官方推送且没有被篡改
• 推送失败重试机制：用户服务可能出现临时宕机、接口超时的情况，不能推送一次就放弃，要做指数退避重试（比如第一次间隔1分钟重试，第二次间隔2分钟，第三次间隔4分钟，最多重试5次），多次重试失败可以标记该Webhook地址为无效，触发通知提醒用户
• 异步推送：现有代码是同步发送推送请求，如果有上千个用户注册，该接口会等待所有请求完成才返回，很容易超时卡死，必须接入消息队列（比如BullMQ、RabbitMQ）把推送任务丢到队列中异步处理，/handle-webhooks收到事件后直接返回200，后台异步执行推送任务
• 请求超时限制：给axios加上超时限制，比如timeout: 5000，避免某个用户服务长时间不响应，拖死你的推送进程
• 权限控制：/set-webhook接口不能无权限访问，要加用户身份校验，比如要求请求头携带用户的API Key，确认是合法用户才能注册回调地址
• 幂等支持：给每个推送的事件生成唯一的event_id，用户收到后可以根据event_id去重，避免重复推送导致的业务重复处理
• 推送日志留存：所有推送的请求参数、响应状态、错误信息都要留存日志，方便排查问题，用户反馈没收到数据时可以快速定位问题根源

const express = require("express");
const axios = require("axios");
const { v4: uuidv4 } = require('uuid');

const app = express();
const PORT = 3000;

// 模拟存储用户webhook配置，生产环境替换为真实数据库
const userWebhooks = new Map();

app.use(express.json());

// Webhook注册接口
app.post("/set-webhook", async (req, res) => {
  // 生产环境需先校验用户API Key，确认身份合法性
  const { webhook_url, user_id, verify_token } = req.body;
  if (!webhook_url || !user_id || !verify_token) {
    return res.sendStatus(400);
  }

  // 校验Webhook地址有效性
  try {
    const challenge = uuidv4();
    const verifyRes = await axios.get(webhook_url, {
      params: { 'hub.mode': 'subscribe', 'hub.challenge': challenge, 'hub.verify_token': verify_token },
      timeout: 3000
    });
    if (verifyRes.data !== challenge) {
      return res.status(400).send('Webhook地址校验失败');
    }
  } catch (e) {
    return res.status(400).send('Webhook地址无法访问');
  }

  // 存储到数据库
  userWebhooks.set(user_id, { url: webhook_url, secret: uuidv4() });
  return res.sendStatus(200);
});

// 事件触发接口，收到事件后推送给所有注册用户
app.post("/handle-webhooks", async (req, res) => {
  const eventData = req.body;
  const eventId = uuidv4();

  // 生产环境此处需将推送任务丢入消息队列异步处理，不要同步执行
  for (const [userId, config] of userWebhooks.entries()) {
    // 生成签名，生产环境建议用HMAC加密
    const signature = Buffer.from(JSON.stringify(eventData) + config.secret).toString('base64');
    try {
      await axios.post(config.url, eventData, {
        headers: {
          'Content-Type': 'application/json',
          'X-Event-Id': eventId,
          'X-Signature': signature
        },
        timeout: 5000
      });
      // 记录推送成功日志
    } catch (e) {
      // 记录推送失败日志，加入重试队列
      console.log(`推送给用户${userId}失败: ${e.message}`);
    }
  }

  return res.sendStatus(200);
});

app.listen(PORT, () => {
  console.log(`App is listening on port ${PORT}.`);
});

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