为什么这个对Node服务器的请求挂起了？

Question

我对express和node非常陌生。我试着用多方和code given here上传图片。我已经检查了文件大小。当我上传的文件大小超过限制时，它会出现在"problem section“中。问题是服务器挂起，只有在请求超时后才会响应。我已经尝试了许多堆栈溢出的解决方案，但似乎都不起作用。如果文件大小低于限制，则会起作用。我非常确定代码到达了问题部分，并且上传逻辑没有问题。但似乎我必须在“问题部分”做一些事情。请告诉我我漏掉了什么。

我已经用next()，res.send()，res.end()，next(err)，return替换了问题部分中的代码；但它不起作用。无论发生什么，它都会挂起。

代码如下：

router.post("/image", function(req, res, next) {
  if(req.user) {
    upload.uploadToS3(req, S3_BUCKET, S3_PROFILE_IMAGE_FOLDER, function(result) {
      if(result.error != null && result.error === false) {
        models.Customer.update({
          orignalImage : result.fileLocation
        },{
          where : { mobileNumber : req.user.mobileNumber}
        }).then(function(customer) {
          if(customer) {
            res.send({
              url: result.fileLocation,
              error : false
            });
          } else {
            res.status(400);
            res.send({error : true,
              error_message : 'Image upload failed'});
          }
        });
      } else {
        //PROBLEM SECTION
        res.status(404);
        res.json({error : true, error_message : result.error_message});
      }
    });
  } else {
    res.status(403);
    res.send({message: "access denied"});
  }
});

response after timeout

请告诉我，如果你需要更多的细节，我会上传它。var uploadToS3 = function(req，S3_BUCKET，folder，callback) { var s3Client = knox.createClient({ secure: false，key: awsConfig.accessKeyId，secret: awsConfig.secretAccessKey，bucket: S3_BUCKET，})；

  var headers = {
    'x-amz-acl': 'public-read',
  };

  var form = new multiparty.Form();
  var batch = new Batch();

  batch.push(function(cb) {
    form.on('part', function(part) {
      var validity = validateFile({type : part.headers['content-type'], name : part.filename, length : part.byteCount});
      console.log(validity);
      if(validity.isValid) {
        cb(null, { filename : folder+"/"+generateFileName({name : part.filename}), part : part});  
      } else {
        cb({error : true, error_message : validity.reason, part:part }, "advra kedavra");
      }
    });
  });

  batch.end(function(err, results) {

    if (err) {
      console.log(err);
      err.statusCode = 200;
      callback(err);
    } else {
      form.removeListener('close', onEnd);
      var result = results[0];
      var part = result.part;
      var destPath = result.filename;
      var counter = new ByteCounter();
      part.pipe(counter); // need this until knox upgrades to streams2
      headers['Content-Length'] = part.byteCount;
      s3Client.putStream(part, destPath, headers, function(err, s3Response) {
        result = {};
        if(err) {
          console.log(err);
          result.error = true;
          result.error_message = "Problem in uploading!";
        } else {
          console.log(s3Response.req.url);
          result = {error: false, statusCode : s3Response.statusCode, message : "file upload successful.", fileLocation : s3Response.req.url};
        }   
        callback(result);
      });
      part.on('end', function() {
        console.log("File upload complete", counter.bytes);
      });
    }
  });
  function onEnd() {
    console.log("no uploaded file");
    callback({error:false, error_message:"no uploaded file."});
  }
  form.on('error', function(err) {
    console.log('Error parsing form: ' + err.stack);
  });
  form.on('close', onEnd);
  form.parse(req);
}

Answer 1

经过3天的寻找，我找到了一个答案。Express.js close response

问题部分应如下所示：

res.status(400);
res.set("Connection", "close");
res.json({error:true, error_message : "<some - error message>"});

Answer 2

您只需在将状态设置为：res.status(400).end();之后添加一个.end()

See official docs

res.end(data)

结束响应过程。这个方法实际上来自节点核心，特别是http.ServerResponse的response.end()方法。

用于快速结束没有任何数据的响应。如果需要使用数据进行响应，请改用res.send()和res.json()等方法。

res.end();

res.status(404).end();

Answer 3

    res.status(400);
    res.set("Connection", "close");
    res.json({error:true, error_message : "<some - error message>"});

我不确定这解决了你的问题。“问题部分”在您的回调中，只有在upLoadToS3函数运行之后才会运行。“问题”可能出在这个函数上。你可能需要重构它来处理大文件上传。