使用Firebase Functions时表单文件上传失败问题求助

核心原因 #

Firebase Functions的HTTP请求处理机制会提前解析请求体，当你的Express应用接收到请求时，req的可读流已经被消费过一部分（甚至全部），导致Busboy无法完整读取multipart/form-data格式的内容，最终触发"Unexpected end of form"错误。本地开发时没有这个问题，是因为本地Express服务器不会自动解析请求体，Busboy可以直接处理原始流。

解决步骤 #

1. 禁用Express的默认form解析中间件 #

确保你的Express应用没有提前解析multipart/form-data类型的请求体，只保留JSON解析即可，form-data交给Busboy处理：

// 仅保留JSON格式请求的解析
app.use(express.json());
// 若无需处理urlencoded表单可删除此行；若需要，extended: false不影响multipart类型请求
app.use(express.urlencoded({ extended: false }));

2. 用Promise包裹Busboy流程，完善错误监听 #

原代码的回调嵌套容易丢失错误信息，且未监听Busboy自身的错误事件。改用Promise封装，统一处理所有流相关错误：

router.post('/:username/upload_profile_picture', async function(req, res, next) {
  try {
    // 用Promise封装Busboy的文件处理逻辑
    const fileData = await new Promise((resolve, reject) => {
      const bb = Busboy({ headers: req.headers });
      let uploadData = null;

      // 处理上传的文件字段
      bb.on('file', (fieldname, file, filename, encoding, mimetype) => {
        const tempFilePath = path.join(os.tmpdir(), filename.filename);
        uploadData = { filePath: tempFilePath, type: mimetype };

        // 监听文件流和写入流的错误
        file.on('error', reject);
        const writeStream = fs.createWriteStream(tempFilePath);
        writeStream.on('error', reject);
        file.pipe(writeStream);
      });

      // 表单解析完成后返回数据
      bb.on('finish', () => {
        if (!uploadData) {
          reject(new Error('未检测到上传文件'));
        } else {
          resolve(uploadData);
        }
      });

      // 监听Busboy的解析错误
      bb.on('error', reject);

      // 将请求流导入Busboy
      req.pipe(bb);
    });

    // 调用仓库方法上传至Firebase Storage
    const profilePictureUrl = await UserRepository.uploadProfilePicture(fileData.filePath, req.params.username);
    
    if (!profilePictureUrl) {
      return res.status(400).json({ message: "图片上传失败" });
    }

    res.status(200).json({ 
      message: "图片上传成功", 
      profilePicture: profilePictureUrl 
    });

    // 异步删除临时文件，避免阻塞事件循环
    fs.unlink(fileData.filePath, (err) => {
      if (err) console.error('删除临时文件失败:', err);
    });
  } catch (error) {
    console.error('上传流程错误:', error);
    next(error);
  }
});

3. 优化Storage上传逻辑，改用异步IO #

原代码用fs.readFileSync会阻塞事件循环，换成异步版本更符合Node.js非阻塞特性：

const { promisify } = require('util');
const readFile = promisify(fs.readFile);

exports.uploadProfilePicture = async (filePath, username) => {
  try {
    const fileBuffer = await readFile(filePath);
    const imageRef = storage_ref(storage, `profilePictures/${username}`);
    
    await uploadBytes(imageRef, fileBuffer);
    console.log('文件已上传至Firebase Storage');
    
    return await getDownloadURL(imageRef);
  } catch (error) {
    console.error('Storage上传错误:', error);
    return null;
  }
}

额外注意事项 #

• 确保Firebase Functions的Runtime设置为Node.js 16或更高版本（在firebase.json的functions.runtime中配置），旧版本流处理存在兼容性问题。
• 测试时确认请求的Content-Type头是multipart/form-data; boundary=xxx（xxx为实际边界值，一般由请求工具自动生成）。
• 建议使用busboy@1.x版本，与Node.js 16+完全兼容。

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