如何在ExpressJS单API端点处理多POST请求并生成AgileCRM用户数组？

先帮你梳理下之前两种尝试的小问题：

• 第一种用原生的request.on('data')其实没必要，Express的body-parser已经帮你封装了请求体解析逻辑，不用手动拼接Buffer；
• 第二种的全局users数组存在致命问题：服务器重启、进程重启或者多实例部署时，数组里的数据会直接丢失——毕竟每个POST请求是独立的，你需要把数据持久化存储，而不是存在内存里。

接下来咱们一步步搞定需求：

1. 正确配置Express的body-parser #

因为AgileCRM会发送text/plain或application/json格式的数据，所以要同时启用两种解析器：

const express = require('express');
const bodyParser = require('body-parser');
const app = express();

// 解析application/json格式的请求体
app.use(bodyParser.json());
// 解析text/plain格式的请求体
app.use(bodyParser.text({ type: 'text/plain' }));

2. 选择数据持久化方式 #

如果数据量不大，用本地JSON文件存储是最简单的方案；如果数据量大或需要更高性能，建议用MongoDB、SQLite这类数据库。这里先给JSON文件的实现示例：

先写两个工具函数，用来读取和写入用户数据：

const fs = require('fs').promises;
const path = require('path');

// 定义存储用户数据的JSON文件路径
const USER_DATA_FILE = path.join(__dirname, 'users.json');

// 读取现有用户数组
async function getUsers() {
  try {
    const data = await fs.readFile(USER_DATA_FILE, 'utf8');
    return JSON.parse(data);
  } catch (err) {
    // 如果文件不存在，返回空数组
    if (err.code === 'ENOENT') return [];
    throw err;
  }
}

// 将更新后的用户数组写入文件
async function saveUsers(users) {
  await fs.writeFile(USER_DATA_FILE, JSON.stringify(users, null, 2));
}

3. 编写API端点核心逻辑 #

现在写处理POST请求的端点，逻辑是：

• 根据请求的Content-Type解析出用户对象；
• 验证用户数据的完整性（可选但推荐）；
• 读取已有的用户数组，追加新用户；
• 保存更新后的数组；
• 返回响应或错误信息。

app.post('/agilecrm-users', async (req, res) => {
  try {
    let user;
    // 根据Content-Type处理不同格式的数据
    if (req.is('application/json')) {
      user = req.body;
    } else if (req.is('text/plain')) {
      // 将text格式的内容转为JSON对象
      user = JSON.parse(req.body);
    } else {
      return res.status(400).send('不支持的Content-Type，请使用application/json或text/plain');
    }

    // 验证用户数据是否包含必要字段
    const requiredFields = ['name', 'phone', 'email', 'car_brand', 'car_number'];
    const missingFields = requiredFields.filter(field => !(field in user));
    if (missingFields.length > 0) {
      return res.status(400).send(`缺少必填字段：${missingFields.join(', ')}`);
    }

    // 读取现有用户数组，追加新用户
    const users = await getUsers();
    users.push(user);

    // 保存到文件
    await saveUsers(users);

    // 返回成功响应，可附带当前完整用户数组
    res.status(201).json({ message: '用户数据添加成功', users });
  } catch (err) {
    console.error('处理请求时出错：', err);
    res.status(500).send('服务器内部错误');
  }
});

// 启动服务器
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`服务器运行在端口${PORT}`);
});

关键注意点 #

• 禁止用全局变量存储数组：Express是多请求并发的，全局变量在服务器重启、进程重启或多实例部署时会丢失数据，持久化存储才是可靠方案；
• 兼容两种数据格式：确保能正确解析AgileCRM发送的text/plain和application/json；
• 数据验证：添加必填字段校验，避免无效数据混入数组；
• 异步处理：文件操作是异步的，用async/await处理更简洁，避免回调地狱。

这样每次AgileCRM发送POST请求到/agilecrm-users端点，用户数据就会被追加到数组里，最终就能得到你想要的格式啦！

内容的提问来源于stack exchange，提问作者As Md Habibullah