我正在尝试使用流使用Hapi将数据发送到浏览器,但无法确定我们的方式。具体来说,我正在使用请求模块。根据文档,该reply对象接受流,所以我尝试了:
reply
reply(request.get('https://google.com'));
引发错误。在文档中说流对象必须与stream2兼容,所以我尝试了:
reply(streams2(request.get('https://google.com')));
现在,这不会引发服务器端错误,但是在浏览器中,请求永远不会加载(使用chrome)。
然后我尝试了这个:
var stream = request.get('https://google.com'); stream.on('data', data => console.log(data)); reply(streams2(stream));
并且在控制台 中 输出了数据,所以我知道流不是问题,而是Hapi。我如何在Hapi中进行流式传输工作?
尝试使用Readable.wrap:
Readable.wrap
var Readable = require('stream').Readable; ... function (request, reply) { var s = Request('http://www.google.com'); reply(new Readable().wrap(s)); }
使用Node 0.10.x和hapi 8.xx进行了测试。在我的代码示例Request中,node- request模块request是传入的hapi请求对象。
Request
request
更新
另一种可能的解决办法是监听“响应”事件从Request然后reply用http.IncomingMessage这是一个适当的读操作流。
http.IncomingMessage
function (request, reply) { Request('http://www.google.com') .on('response', function (response) { reply(response); }); }
这需要较少的步骤,并且还允许开发人员在传输之前将用户定义的属性附加到流。这对于设置200以外的状态代码很有用。