Nodejs 使用formidable模块实现stream方式图片上传，报错

Node.js 使用 Formidable 模块实现 Stream 方式图片上传时遇到错误

背景

我在尝试使用 Node.js 的 formidable 模块来处理通过 HTTP POST 请求上传的图片文件。尽管我在网上找到了一些示例代码，但在实际操作中遇到了一些问题。

错误信息

在执行过程中，我遇到了以下错误：

Error: MultipartParser.end(): stream ended unexpectedly: state = START

示例代码及问题分析

首先，我们来看一下基本的代码框架：

const http = require('http');
const formidable = require('formidable');

http.createServer((request, response) => {
    if (request.url === '/upload' && request.method.toLowerCase() === 'post') {
        const form = new formidable.IncomingForm();

        form.parse(request, (error, fields, files) => {
            if (error) {
                response.writeHead(500, { "Content-Type": "text/plain" });
                response.end("CRAP! " + error + "\n");
                return;
            }

            console.log("Completed Parsing");

            // 这里可以添加处理文件的逻辑
            response.writeHead(200, { "Content-Type": "text/plain" });
            response.end("File uploaded successfully!");
        });

        return;
    }

    response.writeHead(200, { "Content-Type": "text/html" });
    response.end(`
        <form action="/upload" enctype="multipart/form-data" method="post">
            <input type="file" name="image" />
            <input type="submit" value="Upload Image" />
        </form>
    `);
}).listen(3000, () => {
    console.log('Server running at http://127.0.0.1:3000/');
});

解决方案

上述代码中，关键点在于如何正确解析请求中的文件流。错误 Error: MultipartParser.end(): stream ended unexpectedly: state = START 通常发生在解析器尚未准备好接收数据时就已经结束了。为了解决这个问题，我们可以确保在解析之前正确地处理请求的整个内容。

以下是修正后的完整代码示例：

const http = require('http');
const formidable = require('formidable');

http.createServer((request, response) => {
    if (request.url === '/upload' && request.method.toLowerCase() === 'post') {
        const form = new formidable.IncomingForm();

        form.uploadDir = "./uploads"; // 设置文件保存目录
        form.keepExtensions = true;  // 保持文件扩展名

        form.on('error', (err) => {
            response.writeHead(500, { "Content-Type": "text/plain" });
            response.end(`Error: ${err.message}\n`);
        });

        form.on('end', () => {
            response.writeHead(200, { "Content-Type": "text/plain" });
            response.end("File uploaded successfully!");
        });

        form.parse(request);

        return;
    }

    response.writeHead(200, { "Content-Type": "text/html" });
    response.end(`
        <form action="/upload" enctype="multipart/form-data" method="post">
            <input type="file" name="image" />
            <input type="submit" value="Upload Image" />
        </form>
    `);
}).listen(3000, () => {
    console.log('Server running at http://127.0.0.1:3000/');
});

关键点解释

1. form.parse(request): 这个方法会自动处理上传的数据，并调用相应的事件处理器。
2. form.on('error', callback): 处理任何可能发生的错误。
3. form.on('end', callback): 当文件上传完成后触发此回调函数。

通过这种方式，我们可以更可靠地处理文件上传请求，并且避免了由于解析器状态异常而导致的错误。

最新版本的 express3 已经用 https://github.com/superjoe30/node-multiparty 别误导人家了…