我有一个将文件上传到mongodb的过程,效果很好。但是我有一个大问题。如果由于某种原因连接丢失(客户端浏览器关闭,互联网连接不良,电源关闭等),我没有任何指示,并且busboy / req流不会触发任何事件,导致一段时间后未处理错误。当我通过立即上载并关闭浏览器进行测试时。我看到很少文件已上传到mongodb。大概是每100个文件中有10个文件。我没有指示最后一个是否已完全上传,也没有任何事件可以解决/拒绝。代码:
static upload (req) {
return new Promise((resolve, reject) => {
const docIds = [];
const busboy = new Busboy({ headers: req.headers });
const gridFSBucket = MongoDb.GridFSBucket({
chunkSizeBytes: 64 * 1024,
bucketName: 'bucketFiles',
writeConcern: {w: 1}
});
busboy.on('file', function (fieldName, file, fileName, encoding, mimeType) {
const bucketStream = gridFSBucket.openUploadStream(fileName, { metadata: { encoding, mimeType} });
file.on('error', function () {
// Never hitting that
reject(error);
});
file.pipe(bucketStream)
.on('error', function (error) {
// Never hitting that
reject(error);
})
.on('finish', function (doc) {
docIds.push(doc._id);
});
});
busboy.on('error', function (error) {
// Never hitting that
reject(error);
});
busboy.on('finish', function () {
//Everything uploaded BUT
//if connection lost never hitting that
resolve(docIds);
});
req.on('error', function (error) {
// Never hitting that
reject(error);
});
req.pipe(busboy);
});
}
我刚刚发现了。要知道是否发生了意外的流/请求结束,您需要监听req.connection('error'...)事件,例如:
req.connection.on('error', function (error) {
//do something like cancelling the mongodb session ...
reject(error)
});