在createWriteStream上处理错误
我正在使用Node.js实现file upload，我的代码正常工作正常。
但是，当我写入文件失败（例如写入不存在的目录）时，它会调用error handling程序fstream.on('error', ...) ，但是它会卡住，永远不会继续。
我假定通过剪切inputstream，busboy移动到下一个处理部分，但似乎并非如此。
我想运行相同的busboy.on('end')来响应浏览器（有一些错误信息），但我怎么能得到这个叫？
var express = require("express"); var Busboy = require('busboy'); var fs = require('fs'); var upload = require('./upload'); var Path = require('path'); var app = express(); app.get("/", function(request, response) { response.writeHead(200, { Connection: 'close'}); response.end('<html><body>' + '<form action="/upload" method="post" enctype="multipart/form-data">' + ' <input type="file" name="filefield">' + ' <input type="submit">' + '</body></html>'); }); app.post("/upload", function(request, response) { // request.files will contain the uploaded file(s), // keyed by the input name (in this case, "file") console.log(request.body); var fileId = upload.generateId(); var busboy = new Busboy({headers: request.headers}); busboy.on('file', function(fieldname, file, filename, encoding, mimetype) { var path = Path.join('images', fileId); console.log('hello'); var fstream = fs.createWriteStream(path); fstream.on('end', function() { console.log("EOF"); }); fstream.on('close', function() { console.log("CLOSE"); }); fstream.on('error', function(err) { console.log("ERROR:" + err); file.unpipe(); fstream.end(); }); fstream.on('finish', function() { console.log('onFinish'); }) file.on('end', function() { console.log('file end'); }); file.pipe(fstream); }); busboy.on('end', function() { console.log('busboy end'); response.json({id:fileId}); }); request.pipe(busboy); }); app.listen(3000);
我通过在'error'事件处理程序中放置file.read()来解决这个问题。
fstream.on('error', function(err) { console.log("ERROR:" + err); file.read(); });
当createWriteStream出现错误时，调用error处理程序，并且pipe道连接被分解（ unpiped ），但是传入stream（ file ）在stream中有未读数据并且没有被使用。
通过调用.read() ，它被读取（但是由于没有人正在监听，所以没有传递给Writablestream）， end事件发送给读者。 这触发了busboy.on('end') 。
- 如何使用azure-storage-node按修改date查询Azure Blob
- 这与ObjectWrap :: Unwrap的Holder相比
- 如何用2d geo索引正确定义Mongoose模式中的数组对象
- mongoose：find，修改，保存
- 正确的机制降级反应本地
- 获取从angular2到nodejs预检请求的路由错误不会通过访问控制检查：否“Access-Control-Allow-Origin”
- 如何将一个对象传递给客户端Javascript – NodeJS＆express
- 如何在node.js中跨API调用cachingoAuth标记
- mongoosepaginate由参考文件sorting