node.js - 如何使用 Socket.io 禁用多路复用

Question

我正在使用 Socket.io 通过 Twitter 的 Streaming API 将实时推文流式传输给我的用户(我的实现或多或少基于 this tutorial )。

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

我已经通过了 Socket.io 的 documentation但看不到通过 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>');
  } 
});

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

Answer 1

我会尝试这样的事情

服务器端:

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 的流在你的套接字之外，然后在一条新推文上发出一条消息给所有连接的。