node busboy + express 4 + ng-file-upload 不会触发事件答案

【问题标题】：node busboy + express 4 + ng-file-upload doesn't trigger eventsnode busboy + express 4 + ng-file-upload 不会触发事件
【发布时间】：2014-06-05 21:31:26
【问题描述】：

我正在使用 mean.io 堆栈 + ng-file-upload

有谁知道为什么没有触发事件？

客户

controller('ArticleParentCtrl', ['$scope', '$timeout', '$upload', function ($scope, $timeout, $upload) {

        $scope.article = {};

        function setPreview(fileReader, index) {
            fileReader.onload = function(e) {
                $timeout(function() {
                    $scope.dataUrls[index] = e.target.result;
                });
            };
        }

        $scope.fileReaderSupported = window.FileReader !== null;
        $scope.uploadRightAway = true;

        $scope.hasUploader = function(index) {
            return (typeof $scope.upload[index] !== 'undefined');
        };
        $scope.abort = function(index) {
            $scope.upload[index].abort();
            $scope.upload[index] = null;
        };

        $scope.onFileSelect = function($files) {
            $scope.selectedFiles = [];
            $scope.progress = [];
            if ($scope.upload && $scope.upload.length > 0) {
                for (var i = 0; i < $scope.upload.length; i++) {
                    if ($scope.upload[i] !== null) {
                        $scope.upload[i].abort();
                    }
                }
            }
            $scope.upload = [];
            $scope.uploadResult = [];
            $scope.selectedFiles = $files;
            $scope.dataUrls = [];
            for (var y = 0; y < $files.length; y++) {
                var $file = $files[y];
                var isImage = /\.(jpeg|jpg|gif|png)$/i.test($file.name);
                if(!isImage){
                    alert('Only images are allowed');
                    return;
                }
                if (window.FileReader && $file.type.indexOf('image') > -1) {
                    var fileReader = new FileReader();
                    fileReader.readAsDataURL($files[y]);
                    setPreview(fileReader, y);
                }
                $scope.progress[y] = -1;
                if ($scope.uploadRightAway) {
                    $scope.start(y);
                }
            }
        };

        $scope.start = function(index) {
            $scope.progress[index] = 0;
            $scope.upload[index] = $upload.upload({
                url :'/articles/api/upload',
                method: 'POST',
                headers: {
                    'x-ng-file-upload': 'lalista'
                },
                data :  $scope.media,
                file: $scope.selectedFiles[index],
                fileFormDataName: 'avatar'
            })
            .then(
                function(response) {
                    $scope.uploadResult.push(response.data);
                    $timeout(function() {
                        $scope.article.avatar =  response.data.avatar;
                    });
                },
                null,
                function(evt) {
                    $scope.progress[index] = parseInt(100.0 * evt.loaded / evt.total);
                })
            .xhr(function(xhr){
                xhr.upload.addEventListener('abort', function(){
                        console.log('aborted complete');
                    }, 
                    false);
            });
        };

    }])

服务器

exports.upload = function(req, res) {
    var busboy = new Busboy({ headers: req.headers });
    busboy.on('error', function(err){
        console.log(err);
    });
    busboy.on('file', function(fieldname, file, filename, encoding, mimetype) {
      console.log('fieldname');
      console.log(fieldname);
      console.log('file');
      console.log(file);
      console.log('filename');
      console.log(filename);
      console.log('encoding');
      console.log(encoding);
      console.log('mimetype');
      console.log(mimetype);
      //var saveTo = path.join(os.tmpDir(), path.basename(fieldname));
      //file.pipe(fs.createWriteStream(saveTo));
    });
    busboy.on('finish', function() {
      console.log('finish');
    });

};

如果我使用强大的类似：

var form = new formidable.IncomingForm;
form.parse(req, function(err, fields, files){
    console.log(files);
});

代码运行良好但我想知道到底为什么用 busboy 不起作用:(

【问题讨论】：

标签： javascript node.js angularjs express

【解决方案1】：

您没有将您的请求传递给 busboy。你需要做req.pipe(busboy);。

【讨论】：

我已经尝试过了，但如果我没记错的话，我会得到一个未定义的 busboy.on req.pipe(busboy) 它是为 connect-busboy 设置的
您问题中的 busboy 示例是直接使用 busboy。如果您实际上并没有使用该代码而是使用 connect-busboy，那么您需要在 req.busboy 上附加事件处理程序，如果您没有在 connect-busboy 中间件设置中设置 immediate: true，则使用 req.pipe(req.busboy);。跨度>
我都试过了，但第一个坏了 bodyParser() 我把它写成gist.github.com/whisher/84f2ac83894d3e6fb7df btw 你可以在应用程序配置中同时使用 bodyParser() 和 busboy 吗？第二个在帖子中给我问题
该要点中的配置与 connect-busboy 应该可以正常工作。在您的路线处理程序中，您只需执行req.busboy.on('file', ...); 和req.busboy.on('field', ...); 以及之后：req.pipe(req.busboy);。如果这不起作用，请提供一个对您来说失败的简单示例，我将尝试重现它。此外，如果您使用的是 busboy，则不需要 body-parser。
它这样做的要点示例的问题 bodyparser() 被破坏了。感谢您的支持，如果您想复制它，请使用我的邮政编码顺便说一句我正在使用mean.io。再次感谢:)

【解决方案2】：

这对我有用

busboy not firing finish event

var Busboy = require('busboy');

exports.upload = function(req, res) {
    var busboy = new Busboy({
        headers: req.headers
    });

    busboy.on('error', function(err) {
        console.log(err);
    });

    busboy.on('file', function(fieldname, file, filename, encoding, mimetype) {
        console.log(fieldname);
        console.log(file);
        console.log(filename);
        console.log(encoding);
        console.log(mimetype);

        // see other question
        file.resume();

    });

    busboy.on('finish', function() {
        console.log('finish');
    });

    return req.pipe(busboy);

};

【讨论】：