如果某个被请求的页面数据比较大，或者是一个需要一定时间来完成的数据流，那么以流的方式把已经完成的数据发送给客户端是一个比较好的做法。在express中，一般的做法是等数据完成之后，统一发送，如使用exec执行系统命令时，之后在命令结束之后，才会调用回调函数处理命令输出。

1. function cmd(command,req,callback) {
2. var sys = require(‘sys‘)
3. var exec = require(‘child_process‘).exec;
4. console.log(new Date() + ‘ Run command from ‘ + req.ip);
5. console.log(command);
6. exec(command, {
7. maxBuffer: 2000 * 1024
8. }, function (error, stdout, stderr) {
9. callback(stdout.trim());
10. })
11. }

以下的几种方式可以用来实现流式的数据传输。

持续写res方式

最直白的方式就是持续写入node的res对象，例如：

1. var sys = require(‘sys‘),
2. http = require(‘http‘);
3. http.createServer(function (req, res) {
4. res.writeHead(200, {‘Content-Type‘: ‘text/html‘});
5. var currentTime = new Date();
6. sys.puts(‘Starting sending time‘);
7. setInterval(function(){
8. res.write(
9. currentTime.getHours()
10. + ‘:‘ +
11. currentTime.getMinutes()
12. + ‘:‘ +
13. currentTime.getSeconds() + "\n"
14. );
15. setTimeout(function() {
16. res.end();
17. }, 10000);
18. },1000);
19. }).listen(8090, ‘192.168.175.128‘);

但是这种方法的缺点很多，首先express框架中被包装的res对象不支持这种方式的使用，更严重的是只有支持“XHR.readyState = 3 (partial response)”的浏览器才能这么用。另外有人建议使用Sockets.io，有兴趣的朋友可以试试。

1. WebSocket
2. WebSocket over Flash (+ XML security policy support)
3. XHR Polling
4. XHR Multipart Streaming
5. Forever Iframe
6. JSONP Polling (for cross domain)

使用stream对象的pipe

类似于 *nix 将几乎所有设备抽象为文件一样，Node 将几乎所有 IO 操作都抽象成了 Stream 的操作。Stream 是一个抽象的概念，总之就是会冒数据（以 Buffer 为单位），或者能够吸收数据的东西。

下面是上文系统命令执行的另一个例子，其中使用的spawn的stdout流：

1. function cmd_stream(command,req,res) {
2. console.log(new Date() + ‘ Run command stream from ‘ + req.ip);
3. console.log(command);
4. var spawn = require(‘child_process‘).spawn;
5. var params = command.split(/\s+/);
6. command = params.shift();
7. var cmd_process = spawn(command,params);
8. cmd_process.stderr.pipe(res);
9. }

另一个文件流pipe的例子：

1. function file_stream(file,req,res) {
2. console.log(new Date() + ‘ Run readfile stream from ‘ + req.ip);
3. var fs = require(‘fs‘);
4. var rstream = fs.createReadStream(‘/tmp/myfile‘);
5. // var rstream = fs.createReadStream(file);
6. rstream.pipe(res);
7. }