使用Transform的问题！

问答

Eepstar发布于 12 年前最后回复 12 年前

437390

使用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失效？

查看回复

epstar#412 年前

var data = socket.read(); req.emit("request", data); 应该是： var data = socket.read(); data && req.emit("request", data);

epstar#312 年前

标记代码？网页自带的编辑器没有提供代码高亮啊！代码是临时手敲的，不多也很简单，凑合着看吧～～～如果我不用这种方式，换一种思路，将： 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'事件以被动方式取数据，就更加证实了上面的推测！

think2011#212 年前

额，最近的人都不标记代码的了。

jiyinyiyong#112 年前

代码标记一下吧

参与回复

登录后即可参与回复。登录

使用Transform的问题！

回复 (4)

参与回复