强化：分析多部分/form-data请求然后上传文件

Question

自昨天以来，我的Node Express应用程序有问题。

我想做的是下一个：

中间件1，步骤1（解析请求）： 用强大的req.body中的多部分/form-data来解析我想对数据（此类验证）做的事情，然后如果一切都很好，请转到步骤2。

中间件2，步骤2（上传文件）： 上传文件具有强大的问题（已经被解析）

问题：

• multer：已经用Multer进行了测试，但不可能，我必须将中间件2放在中间件1之前，否则Req.body是空的（也已测试了Multer.none（））。
• 但是当我在中间件1中解析请求时，强大的中间件2（因为我的req。

强大：用强大的可实现测试， 一个过滤器功能，但我真的想拥有两个分开的中间。

Express Middlewares

const formidable = require('formidable');

// parse request
module.exports.middleware1 = async (req, res, next) => {
  const form = formidable({ multiples: true });

  form.parse(req, (err, fields, files) => {
    if (err) {
      next(err);
      return;
    }
    
    // request parsed
    // do what I want to do with the fields (such validation)
    console.log(fields)
    
    next()
  });
}

// upload file
module.exports.middleware2 = async (req, res, next) => {
  const options = {
    uploadDir: 'test',
    keepExtensions: true,
    maxFiles: 1,
    filename: function (name, ext, part, form) {
      return name
    },
    filter: function ({name, originalFilename, mimetype}) {
      return true
    }
  }
  const form = formidable(options);
  form.parse(req, (err, fields, files) => {
    if (err) {
      next(err);
      return;
    }
    
    // file uploaded, go to controller
    
    next()
  });
}

front App

publishPost: function () {
  let formData = new FormData()

  const post = {
    filters: {
      ...this.postFilters
    },
    details: {
      ...this.postDetails
    }
  }

  formData.append('post', JSON.stringify(post))
  formData.append('file', this.postMedia.file)

  postService.createOne(formData).then((res) => {
    if (res) {
      postServiceStatus.createOneDone()
    }
  });
}

如果有人有了想法，我会很感激！

Answer 1

我终于找到了解决问题的解决方案！

我创建了一个全局错误处理程序，该处理程序可以处理API上的所有错误，并且当一个错误与创建文件的路由相关时（在第一个中间件中）时，我将删除文件，并在req.file中传递的信息。

const fs = require('fs')
const { DEFAULT_API_PATH } = process.env

/**
 * Handle middlewares errors
 * @param {Object} err error object
 * @param {String} err.type type of error (service affected by the error)
 * @param {String} err.error original error
 * @param {String} err.message returned error
 * @param {Number} err.status error status
 * @returns 
 */
module.exports = async (err, req, res, next) => {
  if (err.error) console.log(err.error) 
  
  // Delete file
  if (req.path === `${DEFAULT_API_PATH}/posts/create` && req.file) {
    if (fs.existsSync(req.file.path)) {
      fs.unlinkSync(req.file.path, function (err) {
        console.log(err)
      }); 
    }
  } 
  
  if (err.type && err.type === 'database') return res.status(err.status || 400).send({ error: err.message || 'Une erreur innatendue s\'est produite avec la base de données. Veuillez réessayer dans un instant.' }) 
  else if (err.type && err.type === 'server') return res.status(err.status || 400).send({ error: err.message || 'Une erreur innatendue s\'est produite avec le serveur. Veuillez réessayer dans un instant.' }) 
  
  return res.status(err.status || 400).send({ error: err.message || 'Une erreur innatendue s\'est produite. Veuillez réessayer dans un instant.' }) 
}

Answer 2

服务器只能消耗一次传入的请求，因为客户端是流的，并且HTTP协议不允许服务器从客户端请求“倒带”。

multer和强大的想法是将文件写入uploadDir ，因为该请求正在消耗。如果您不想在第一个中间件中执行此操作，则需要将文件存储在JavaScript变量中（例如，res.locals.uploadedfile）并将其写入uploadDir << /代码>您自己在第二个中间件中。但是，这是什么优势？主内存比磁盘空间昂贵。

您为什么要坚持两个单独的中间人？