使用Transform时,第一次可以从socket接收到客户端数据(HTTP请求),等处理并写入socket一些响应数据后,想再次处理客户端数据时,但获取不到任何数据,使用模式: var Transform = require(“stream”).Transform; var inherits = require(“util”).inherits; var Request = function() { Transform.call(this); this._transform = function(data) { console.log("recv data length " + data.length); // 这一句只处理了一次 }; }; inherits(Request, Transform);
net.createServer(function(socket) { var req = new Request(); socket.pipe(req).pipe(socket); }); 在浏览器中检查socket使用状态,在发送HTTP请求后,后续数据是发送出去的(数据发送在onopen中),客户端已经发送成功,连接也还在,说明服务器socket已经收到数据了,从Readable的角度看,是监听src的’data’事件,如果Request没有收到数据,是不是可以说src没有触发’data’事件?或者说监听src失效?
额,最近的人都不标记代码的了。
标记代码?网页自带的编辑器没有提供代码高亮啊! 代码是临时手敲的,不多也很简单,凑合着看吧~~~ 如果我不用这种方式,换一种思路,将: var req = new Request(); socket.pipe(req).pipe(socket); 换成是: Request.prototype.on(“request”, function(data) { … }); var req = new Request(); req.pipe(socket); socket.on(“readable”, function(data) { var data = socket.read(); req.emit(“request”, data); }); 之后测试代码,运行正常! 'readable’事件以被动方式取数据,就更加证实了上面的推测!
var data = socket.read(); req.emit(“request”, data); 应该是: var data = socket.read(); data && req.emit(“request”, data);