如何在binary.js(BinaryStream.write)节点服务器上解析不可写入的流？

Question

我正在文件上传节点服务器上工作，上传后的一个大文件会出现以下错误。

错误:流不能在(/node_modules/binaryjs/lib/stream.js:84:11)at /src/k/Cli/ BinaryStream.write /lib/media.js:120:36 at ChildProcess.exithandler (child_process.js:742:7)at ChildProcess.emit (events.js:110:17)at maybeClose (child_process.js:1015:16)at Process.ChildProcess._handle.onexit (child_process.js:1087:5)使用节点version v0.10.48 从https://github.com/rajkissu/binaryjs-upload-stream中选择引用代码

我无法找到解决这一问题的方法。

问题是，对于下面1%的情况，代码转到了console.log('Debug 4)情况，并且在执行stream.write({end: true});时停止了节点服务器，也就是说，我得到了坏的网关，因为抛出的错误没有得到处理。

在前端，我使用来自节点服务器的数据读取内容id并设置完成，但由于节点服务器停止并且无法从节点服务器获取内容id。

bs = new BinaryServer({ port: 9004 });

bs.on('connection', function (client) {
    client.on('stream', function (stream, meta) {
        upload(stream, meta);
    });
});

function upload(stream, meta) {
    var file = fs.createWriteStream(uploadPath + '/' + meta.name);
    stream.pipe(file);
    stream.on('end', function () {

       // console.log(__dirname);
        var cli_base=__dirname+'/../../';

        var cmd = '<upload systme cmd>';
        console.log('Uploading End and running command ' + cmd);         
        try {
            stream.write({uploaded: true});
        }catch (e) {
            console.log('Debug 3, Streem On End Event : '+e.message,meta);
            //  stream.write({end: true});
        }
        if(!meta.hasOwnProperty('executed')){
            meta.executed=true;
            child = exec(cmd, function (error, stdout, stderr) {
                try{
                    console.log(error, JSON.parse(stdout), stderr);
                    var command_output = JSON.parse(stdout);

                    if(command_output.hasOwnProperty('content_id')){
                        stream.write({end: true, content_id: command_output.content_id,files:command_output.file});
                        console.log(command_output.content_id);
                    }
                }catch (e) {                        
                   console.log('Debug 4, Streem On End Event : '+e.message,meta,child);
                   stream.write({end: true});
                }
            });
        }

    });
}

Answer 1

我为您的问题找到了解决方案，请在创建文件对象时使用选项，如下所示

var options = {flags: 'w', encoding: 'utf8',fd: null,mode: '0666'};
var file = fs.createWriteStream(uploadPath + '/' + meta.name,options);

节点参考options createWriteStream callback的编码选项