您将如何使用 Node 创建流式 API ?就像 Twitter streaming API .
我最终想要做的是从 FriendFeed api 获取第一个更新。 ,并在新的可用时进行流式传输(如果 id 不同),然后将其公开为 Web 服务,以便我可以在我的网站上将它与 WebSockets 一起使用:)。
到目前为止,我有这个:
var sys = require('sys'),
http = require('http');
var ff = http.createClient(80, 'friendfeed-api.com');
var request = ff.request('GET', '/v2/feed/igorgue?num=1',
{'host': 'friendfeed-api.com'});
request.addListener('response', function (response) {
response.setEncoding('utf8'); // this is *very* important!
response.addListener('data', function (chunk) {
var data = JSON.parse(chunk);
sys.puts(data.entries[0].body);
});
});
request.end();
仅从 FriendFeed 获取数据,使用 Node 创建 Http 服务器很容易,但它无法返回流(或者我还没有找到方法)。
最佳答案
您可能希望建立一个系统来跟踪传入的请求并存储它们的响应对象。然后,当需要从 FriendFeed 流式传输新事件时,遍历他们的响应对象并将 responses[i].write('something')
发送给他们。
查看 LearnBoost's Socket.IO-Node ,您甚至可以将该项目用作您的框架,而不必自己编写代码。
来自 Socket.IO-Node 示例应用(用于聊天):
io.listen(server, {
onClientConnect: function(client){
client.send(json({ buffer: buffer }));
client.broadcast(json({ announcement: client.sessionId + ' connected' }));
},
onClientDisconnect: function(client){
client.broadcast(json({ announcement: client.sessionId + ' disconnected' }));
},
onClientMessage: function(message, client){
var msg = { message: [client.sessionId, message] };
buffer.push(msg);
if (buffer.length > 15) buffer.shift();
client.broadcast(json(msg));
}
});
关于javascript - 如何使用 NodeJS 创建流式 API,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/2906594/