4

我正在使用 Socket.io 使用 Twitter 的 Streaming API 向我的用户流式传输实时推文（我的实现或多或少基于本教程）。

问题是每次 Socket.io 触发连接事件时，新连接的客户端都会导致连接到服务器的所有其他客户端停止更新。虽然完成我尝试过的所有黑客攻击需要很长时间，但我会说我已经玩够了，我相信这个问题是由 Socket.io 多路复用来自多个客户端的连接（默认启用）作为一个性能提升以允许多个客户端或连接共享相同的底层套接字。简而言之，我认为情况确实如此，因为如果不是连接多路复用，我认为新连接不可能以这种方式影响旧连接。换句话说，如果一个新的，每次客户端连接时都会创建与其自己的底层（TCP）套接字的独立连接，这是不可能发生的，因为一个连接对另一个连接一无所知，因此不会影响当前正在发生的任何其他客户端的状态。这也让我相信，简单地禁用多路复用功能将是解决这个问题的最简单方法，因为我不关心缩放，因为 Node.js 已经处理了我可能需要非常充分地处理的所有并发。

我已经浏览了 Socket.io 的文档，但看不到通过 API 公开“解复用”连接的能力，所以如果有人知道如何做到这一点，我会感谢您的回复。

我下面的代码非常标准和简单。但要明确一点，问题是每当一个新客户端连接到 Socket.io 时，每个其他客户端都会停止接收新推文，并且更新不再推送到旧客户端，除非我刷新浏览器，在这种情况下，新刷新的客户端将开始更新并再次接收新的推文，但其他仍然连接的客户端将停止更新。

服务器端代码：

// Code also uses ntwitter (https://github.com/AvianFlu/ntwitter) as an abstraction over Twitter's Streaming API
io.sockets.on('connection', function (socket) {
  tweet.stream('statuses/filter', { track : 'new orleans' }, function (stream) { 
    stream.on('data', function (data) {
      // The following lines simply pre-process data sent from Twitter so junk isn't
      // unnecessarily sent to the client.
      if (data.user) {
         tweets = {
         text  : data.text,
         image : data.user.profile_image_url,
         user  : data.user.name
         };
         var t = JSON.stringify(tweets);
         console.log(t);
         socket.send(t);
      }  
    });
  });
});

客户端代码

// Notice the option that I passed in as the second argument. This supposedly forces every 
// new client to create a new connection with the server but it either doesn't work or I'm 
// implementing it incorrectly. It is the very last configuration option listed in the 
// documentation linked to above.
var socket = io.connect('http://' + location.host, {'force new connection' : true });
socket.on('message', function (tweet) {
  var t = JSON.parse(tweet);
  if (t.image) {
    $('.hero-unit').prepend('<div class="media"><a class="pull-left" href="#"><img class="media-object" alt="64x64" style="width: 64px; height: 64px;" src="' + t.image + '"></a><div class="media-body"><h4 class="media-heading">' + t.user + '</h4>' + t.text + '</div></div>');
  } 
});

如果我的想法不正确，或者我的代码有问题，我绝对愿意接受任何建议。我也很乐意回复任何其他详细信息。

4

1 回答 1

0

我会尝试这样的事情

服务器端：

io.sockets.on('connection', function (socket) {
    //Other Connectiony goodness here.
    });
});

tweet.stream('statuses/filter', { track : 'new orleans' }, function (stream) { 
    stream.on('data', function (data) {
      // The following lines simply pre-process data sent from Twitter so junk isn't
      // unnecessarily sent to the client.
      if (data.user) {
         tweets = {
         text  : data.text,
         image : data.user.profile_image_url,
         user  : data.user.name
         };
         var t = JSON.stringify(tweets);
         console.log(t);
         io.sockets.emit("tweet", t);
      }  
});

客户端：

var socket = io.connect('http://' + location.host, {'force new connection' : true });
socket.on('tweet', function (tweet) {
  var t = JSON.parse(tweet);
  if (t.image) {
    $('.hero-unit').prepend('<div class="media"><a class="pull-left" href="#"><img class="media-object" alt="64x64" style="width: 64px; height: 64px;" src="' + t.image + '"></a><div class="media-body"><h4 class="media-heading">' + t.user + '</h4>' + t.text + '</div></div>');
  } 
});

基本上让来自 twitter 的流在你的套接字之外，然后在一条新的推emit文上向所有连接的人发送一条消息。

于 2013-11-01T15:41:10.793 回答