Node.js+Express如何在反向代理前为请求体添加字符串？

我来帮你分析下问题，然后给出几个可行的解决思路：

首先，req.body 是 undefined 的核心原因很简单：Express 默认不会自动解析任何格式的请求体，不管是 XML、JSON 还是表单数据。你需要手动配置解析中间件，或者直接获取原始请求体内容，才能对它进行修改。

结合你的需求（只是简单替换 XML 字符串），下面是几种实用的解决方案：

方案一：直接修改原始请求体字符串（最适合你的场景） #

这种方法不需要解析 XML 为对象，直接处理原始字符串，操作简单高效：

1. 先安装依赖包 raw-body，用来读取原始请求体：

npm install raw-body

2. 修改你的路由代码，读取原始请求体、替换内容后再转发：

const express = require('express');
const getRawBody = require('raw-body');
const { PassThrough } = require('stream');
const app = express();

app.post('/geoserver', async function (req, res) {
  try {
    // 读取原始请求体为字符串
    const rawBody = await getRawBody(req, {
      encoding: 'utf8',
      limit: '1MB' // 根据你的请求体大小调整，比如改成'10MB'
    });

    // 执行你需要的字符串替换
    const modifiedBody = rawBody.replace('</Query>', '<Filter> .... </Filter></Query>');

    // 这里要注意：原始请求流已经被消耗了，需要创建新的流来承载修改后的内容
    const newStream = new PassThrough();
    newStream.write(modifiedBody);
    newStream.end();

    // 替换 req 的流方法，让代理能读取到修改后的内容
    req.pipe = () => newStream;
    req.read = newStream.read.bind(newStream);

    // 更新 Content-Length 头部，避免目标服务器因为长度不匹配报错
    req.headers['content-length'] = Buffer.byteLength(modifiedBody, 'utf8');

    // 转发请求
    apiProxy.web(req, res, { target: serverOne });
  } catch (err) {
    res.status(500).send('处理请求体失败');
  }
});

方案二：利用 http-proxy 的 proxyReq 事件修改（更优雅） #

如果你用的是 http-proxy 库，可以通过它的 proxyReq 事件，在发送代理请求前直接修改请求体，不需要在路由里处理流的问题：

1. 同样先安装 raw-body：

npm install raw-body

2. 配置代理的事件监听：

const httpProxy = require('http-proxy');
const getRawBody = require('raw-body');

const apiProxy = httpProxy.createProxyServer({});

// 监听代理请求发送前的事件
apiProxy.on('proxyReq', (proxyReq, req, res, options) => {
  // 只针对 /geoserver 的 POST 请求处理
  if (req.path === '/geoserver' && req.method === 'POST') {
    getRawBody(req, { encoding: 'utf8', limit: '1MB' }, (err, rawBody) => {
      if (!err) {
        const modifiedBody = rawBody.replace('</Query>', '<Filter> .... </Filter></Query>');
        // 更新代理请求的 Content-Length
        proxyReq.setHeader('Content-Length', Buffer.byteLength(modifiedBody));
        // 写入修改后的内容并结束流
        proxyReq.write(modifiedBody);
        proxyReq.end();
      } else {
        res.status(500).send('读取请求体失败');
      }
    });
  }
});

// 你的路由保持简洁
app.post('/geoserver', (req, res) => {
  apiProxy.web(req, res, { target: serverOne });
});

方案三：解析 XML 为对象后修改（适合复杂操作场景） #

如果你之后需要对 XML 结构做更复杂的修改（比如添加多层节点），可以先把 XML 解析成 JS 对象，修改后再转回 XML：

1. 安装依赖：

npm install body-parser body-parser-xml xml2js

2. 配置 Express 解析 XML：

const express = require('express');
const bodyParser = require('body-parser');
const xml2js = require('xml2js');
const builder = new xml2js.Builder();

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

// 配置 XML 解析中间件
app.use(bodyParser.xml({
  limit: '1MB',
  xmlParseOptions: {
    explicitArray: false, // 避免单个节点被转为数组，按需调整
    trim: true
  }
}));

3. 修改请求体并转发：

app.post('/geoserver', function (req, res) {
  // 解析后的 req.body 是 JS 对象，比如 { Query: ... }
  if (req.body.Query) {
    // 添加 Filter 节点（如果 Filter 有子节点，可以写成对象形式）
    req.body.Query.Filter = '....';
  }

  // 把 JS 对象转回 XML 字符串
  const modifiedXml = builder.buildObject(req.body);
  // 更新请求体和 Content-Length
  req.body = modifiedXml;
  req.headers['content-length'] = Buffer.byteLength(modifiedXml, 'utf8');

  // 转发请求
  apiProxy.web(req, res, { target: serverOne });
});

几个注意事项 #

• 确保请求的 Content-Type 是正确的（比如 application/xml），否则中间件可能无法正确解析。
• 如果你的请求体很大，一定要调整 limit 参数，避免触发超出限制的错误。
• 修改 Content-Length 头部非常重要，否则目标服务器可能会因为请求体长度不匹配而拒绝处理。

内容的提问来源于stack exchange，提问作者Iñigo