使用Axios转发POST请求时出现CanceledError问题排查

问题根源 #

POST请求转发时直接把express.Request对象丢给Axios的data参数是核心问题。Express的req不是单纯的请求体流，还带着框架内部的属性和方法，Axios没法正确处理这种非标准流，导致请求流被中止。而GET请求没有请求体，所以没这个问题。

修复方案 #

1. 正确传递请求体+过滤请求头 #

修改转发逻辑，只传原始请求体流，同时过滤掉会引发冲突的请求头（比如host、connection），保留必要的业务请求头：

import axios from 'axios';
import express from 'express';
import { parse } from 'url';

const DESTINATION_URL = '你的目标NextJS后端地址';

async function forwardRequest(req: express.Request, res: express.Response) {
    const { path } = parse(req.url, true);
    const forwardUrl = DESTINATION_URL + path;

    // 过滤掉与目标服务器不兼容的请求头
    const allowedHeaders = Object.fromEntries(
        Object.entries(req.headers).filter(([key]) => {
            const lowerKey = key.toLowerCase();
            return !['host', 'connection', 'content-length'].includes(lowerKey);
        })
    );

    try {
        const response = await axios({
            url: forwardUrl,
            method: req.method,
            data: req, // GET请求自动忽略data，POST请求会读取req的流
            headers: allowedHeaders,
            responseType: 'stream',
        });

        // 同步目标后端的响应头给客户端
        res.set(response.headers);
        // 管道传输响应数据，避免内存堆积
        response.data.pipe(res);
    } catch (err) {
        console.error('转发失败:', err);
        res.status(500).send('请求转发失败');
    }
}

const ForwardRouter = express.Router();
ForwardRouter.all('*', forwardRequest);

export default ForwardRouter;

2. 可选：添加重试机制处理临时中断 #

如果偶尔出现流中止的情况，可以用axios-retry自动重试：

先安装依赖：

npm install axios-retry

然后配置重试逻辑：

import axiosRetry from 'axios-retry';

// 仅针对流中止错误进行重试
axiosRetry(axios, {
    retries: 2,
    retryDelay: (count) => count * 1000, // 每次重试间隔1秒
    retryCondition: (error) => {
        return error instanceof axios.CanceledError && error.message.includes('Request stream has been aborted');
    },
});

3. 确保请求体未被提前消费 #

如果你的Express应用使用了body-parser中间件，它会提前读取请求体流，导致Axios转发时拿不到数据。要保证转发路由在body-parser之前执行，或者给转发路径单独禁用body-parser：

// 示例：给转发路径跳过body-parser解析
app.use('/your-forward-path', (req, res, next) => next(), ForwardRouter);

// 其他路径正常使用body-parser
app.use(express.json());
app.use(express.urlencoded({ extended: true }));

关键注意点 #

• 过滤请求头是因为Axios会自动设置host等基础头，手动转发会和目标服务器的预期冲突，导致请求失败。
• 直接传req作为data时，必须确保req的流没被提前消费（比如没被body-parser处理）。
• 用responseType: 'stream'后，一定要用管道传输响应数据，不然大文件会导致内存溢出。

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