查看Twitter文档中标题为“ 解析响应”的部分。
从Streaming API解析JSON响应很简单,每个对象都在自己的行上返回,并以回车结尾。对象元素(例如,状态对象的文本元素)中可能出现换行符(
n),但回车符( r)不应出现。
在服务器端,继续堆积块,直到看到回车
"r"。找到回车符后,提取字符串直到回车符,这将给我们一条鸣叫。
var message = ""; // variable that collects chunksvar tweetSeparator = "r";res.on('data', function(chunk) { message += chunk; var tweetSeparatorIndex = message.indexOf(tweetSeparator); var didFindTweet = tweetSeparatorIndex != -1; if (didFindTweet) { var tweet = message.slice(0, tweetSeparatorIndex); clients.forEach(function(client) { client.send(tweet); }); message = message.slice(tweetSeparatorIndex + 1); }});客户端变得简单。只需将套接字消息整体解析为JSON。
socket.on('message', function(data) { var tweet = JSON.parse(data);});


