Node.js中的流（Stream）介绍(2)

1.Readable 流还没有 pipe 到任何流上，可调 .pause() 暂停
2.Readable 流已经 pipe 到了流上，需 remove 掉所有 data 事件订阅，并且调用 .unpipe()方法逐一解除与下游流的关系

妙用

结合流的异步特性，我可以写出这样的应用：直接将 用户A 的输出桥接到 用户B 的页面上输出：

复制代码 代码如下:

router.post('/post', function(req, res) {
    var destination = req.headers['destination']; //发给谁
    cache[destionation] = req;
    //是的，并不返回，所以最好是个ajax请求
});

用户B请求的时候：

复制代码 代码如下:

router.get('/inbox', function(req, res){
    var user = req.headers['user'];
    cache.find(user, function(err, previousReq){ //找到之前存的req
       var form = new multiparty.Form();
       form.parse(previousReq);  // 有文件给我
       form.on('part', function (part) {
            part.pipe(res); //流式大法好:)
 
            part.on('error', function (err) {
                console.log(err);
                messaging.setRequestDone(uniqueID);
                return res.end(err);
            });
        });
    });
});

参考

how to write node programs with streams: stream-handbook

您可能感兴趣的文章: