在CRUD场景下如何将text/plain格式的HTTP POST请求转换为JSON？TCP服务器POST请求存入MongoDB遇空对象问题排查

核心问题在于Express默认不会解析text/plain类型的请求体，所以你的req.body才会是undefined，最终插入MongoDB的是空对象。下面一步步解决你的问题：

1. 让Express解析text/plain请求体 #

Express内置的express.json()和express.urlencoded()只处理application/json和表单编码的请求，要解析纯文本，需要添加express.text()中间件。在你的HTTP服务器入口文件（比如app.js或server.js）里加上：

const express = require('express');
const app = express();

// 先添加纯文本解析中间件
app.use(express.text());
// 再添加其他中间件（比如json解析、路由等）
app.use(express.json());
// ... 你的路由配置

这个中间件会把text/plain的请求体转换成字符串，存到req.body里。

2. 将纯文本转换为JSON并处理解析逻辑 #

现在req.body是TCP发送过来的纯文本字符串了，接下来要把它转成JSON——前提是这个字符串本身是合法的JSON格式（比如{"deviceId":"sensor01","temp":26.5}这种）。

转换和解析操作完全可以放在同一个位置（就是你的createIotData处理函数里），这样逻辑更集中。修改你的处理代码：

const IotData = require('../models/IotData');

exports.createIotData = (req, res, next) => {
  try {
    // 1. 把纯文本转成JSON对象
    const parsedData = JSON.parse(req.body);
    
    // 2. 这里可以做解析操作（比如验证字段、格式化数据）
    // 举个例子：如果需要提取deviceId和temp字段
    // const { deviceId, temp } = parsedData;
    // 可以在这里做数据校验，比如判断temp是否在合理范围
    
    // 3. 根据Mongoose模型创建文档
    // 如果你的模型是存整个JSON字符串（对应你简化后的all字段）：
    const newIotData = new IotData({ all: req.body });
    // 如果你后续要拆分字段，比如模型有deviceId、temp字段，就用：
    // const newIotData = new IotData(parsedData);
    
    newIotData.save()
      .then(() => {
        res.status(201).json({
          message: 'IOT Data registered!',
          content: parsedData // 返回解析后的JSON更友好
        });
      })
      .catch(error => res.status(400).json({ error }));
  } catch (parseError) {
    // 处理JSON解析失败的情况（比如TCP发送的文本不是合法JSON）
    res.status(400).json({ error: 'Invalid JSON format in request body', details: parseError.message });
  }
};

3. 关键注意事项 #

• 确保TCP发送的文本是合法JSON：如果你的TCP客户端发送的是类似temp:26,humidity:60这种非JSON格式的文本，JSON.parse会报错。这时候你需要先调整TCP端的发送格式，或者自己写字符串解析逻辑（比如用正则分割）。
• 错误处理不能少：一定要用try-catch包裹JSON.parse，避免非法格式导致服务器崩溃。
• 中间件的顺序：express.text()要放在路由之前，确保请求到达路由时已经被解析。

可选：自定义中间件处理转换 #

如果你想把转换逻辑抽离成单独的中间件（比如多个路由都需要处理text转JSON），可以写一个自定义中间件：

app.use((req, res, next) => {
  if (req.headers['content-type'] === 'text/plain') {
    let rawBody = '';
    req.on('data', chunk => rawBody += chunk.toString());
    req.on('end', () => {
      try {
        req.body = JSON.parse(rawBody);
        next();
      } catch (err) {
        // 解析失败可以选择保留原字符串，或者直接返回错误
        req.body = rawBody;
        next();
        // 或者直接返回错误：
        // res.status(400).json({ error: 'Invalid JSON' });
      }
    });
  } else {
    next();
  }
});

这样所有text/plain的请求都会自动尝试转成JSON，路由处理函数里直接用req.body即可。

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