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

Question

我对表达和节点很陌生。我试图使用多方和此处给出的代码上传图像。我已经检查了文件大小。当我上传大小超过限制的文件时，它会出现在“问题部分”中。问题是服务器挂起并仅在请求超时后响应。我已经尝试了许多关于堆栈溢出的解决方案，但似乎没有任何效果。如果文件大小低于限制，它会起作用。我很确定代码到达问题部分，上传逻辑没有问题。不过看来我得在“问题部分”做点什么了。请告诉我我错过了什么。

我已经将问题部分的代码替换为 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"});
  }
});

超时后响应

如果您需要更多详细信息，请告诉我，我会上传它。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 关闭响应

问题部分应该如下：

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