我会很快解释一下我的应用程序的功能:
1. 客户上传文档 2. 文档被处理 3. 服务器创建pdf的快照图像 4. 服务器返回快照图像的路径
现在的问题是,从步骤(1)到(4)的整个过程需要超过60秒。
起初,我使用了旧的express.bodyParser()代码,但是在60秒后我会收到以下错误消息:
测试用例2 - 使用mulster中间件:
1. 客户上传文档 2. 文档被处理 3. 服务器创建pdf的快照图像 4. 服务器返回快照图像的路径
现在的问题是,从步骤(1)到(4)的整个过程需要超过60秒。
起初,我使用了旧的express.bodyParser()代码,但是在60秒后我会收到以下错误消息:
Error: Request aborted
at IncomingMessage.onReqAborted (/DIR_TO_NODE/node/file-upload-error/node_modules/express/node_modules/connect/node_modules/multiparty/index.js:131:17)
at IncomingMessage.EventEmitter.emit (events.js:92:17)
at abortIncoming (http.js:1911:11)
at Socket.serverSocketCloseListener (http.js:1923:5)
at Socket.EventEmitter.emit (events.js:117:20)
at TCP.close (net.js:466:12)
并且操作系统的tmp
目录中的文件被删除了。
所以我决定使用mulster
中间件模块来替代express.multipart()
。
这个改变解决了问题的一半,因为它消除了之前我遇到的Express.js多部分错误。
这意味着现在我的程序在60秒后仍然继续运行,这是好事,但是在同样的60秒后,客户端仍然会出现HTTP超时。
现在我知道像Chrome这样的浏览器有一个固定的60秒超时修复,但是我的问题是:
有没有办法防止在60秒后发生HTTP超时?
如果没有办法,其他应用程序是如何解决这个问题的?我特别关注同时有多个用户争夺文件系统访问权限的情况。
下面是一些测试案例,我通过从不使用res.send()
回答请求并每10秒轮询tmp
目录中的文件名来模拟长时间处理,只是为了检查我的文件何时会消失(有时是60秒超时,有时是120秒超时)。
测试用例编号1 - 使用传统的express.bodyParser()
中间件:
var express = require('express');
var path = require('path');
var app = express();
var fs = require('fs');
var os = require('os');
var pid = process.pid.toString();
var interval;
app.use(express.bodyParser());
app.get('/', function (req, res) {
res.send([
'<form method="post" enctype="multipart/form-data">' +
'<p>Image: <input type="file" name="pdf" /></p>' +
'<p><input type="submit" value="Upload" /></p>' +
'</form>'
].join(''));
});
app.post('/', function (req, res, next) {
var file_path;
if(req.files.pdf) {
file_path = req.files.pdf.path;
}
else {
file_path = os.tmpDir() + 'test';
}
var filename = path.basename(file_path);
var dir = path.dirname(file_path);
console.log('\n> PID: ' + pid);
console.log('> Filepath: ' + dir);
console.log('> Filename: ' + filename);
var count = 0;
clearInterval(interval);
interval = setInterval(function () {
count++;
console.log('\n> Interval: ' + (count * 10) + ' seconds');
var files = fs.readdirSync(dir);
for(var i = 0; i < files.length; i++) {
if(files[i].substr(0, pid.length) === pid) {
console.log('\t-> File present: ' + files[i]);
}
}
}, 10000);
});
app.listen(3000);
console.log('Express started on port 3000');
测试用例2 - 使用mulster中间件:
var express = require('express');
var multer = require('multer');
var path = require('path');
var app = express();
var fs = require('fs');
var os = require('os');
var pid = process.pid.toString();
var interval;
app.use(express.json());
app.use(express.urlencoded());
app.use(multer({
dest: os.tmpDir()
}));
app.get('/', function (req, res) {
res.send([
'<form method="post" enctype="multipart/form-data">' +
'<p>Image: <input type="file" name="pdf" /></p>' +
'<p><input type="submit" value="Upload" /></p>' +
'</form>'
].join(''));
});
app.post('/', function (req, res, next) {
var file_path;
if(req.files.pdf) {
file_path = req.files.pdf.path;
}
else {
file_path = os.tmpDir() + 'test';
}
//var file_path = req.files.pdf.path;
var filename = path.basename(file_path);
var dir = path.dirname(file_path);
console.log('\n> PID: ' + pid);
console.log('> Filepath: ' + dir);
console.log('> Filename: ' + filename);
var count = 0;
clearInterval(interval);
interval = setInterval(function () {
count++;
console.log('\n> Interval: ' + (count * 10) + ' seconds');
var files = fs.readdirSync(dir);
for(var i = 0; i < files.length; i++) {
if(files[i].split('.')[0].length === 32 || files[i].substr(0, pid.length) === pid) {
console.log('\t-> File present: ' + files[i]);
}
}
}, 10000);
});
app.listen(3000);
console.log('Express started on port 3000');