如何使用 Socket.io 禁用多路复用

Posted 2023-02-16

【中文标题】如何使用 Socket.io 禁用多路复用

【英文标题】：How to disable Multiplexing with Socket.io

【发布时间】：2012-12-03 15:34:45

【问题描述】：

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

问题是每次 Socket.io 触发连接事件时，新连接的客户端都会导致连接到服务器的所有其他客户端停止更新。虽然完成我尝试过的所有黑客攻击需要很长时间，但我会说我已经玩够了，我相信这个问题是由 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"  style="width: 64px; height: 64px;" src="' + t.image + '"></a><div class="media-body"><h4 class="media-heading">' + t.user + '</h4>' + t.text + '</div></div>');
   
);

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

【问题讨论】：

socket.io的多路复用只能应用于同一个客户端和服务器之间的连接。使用同一个套接字同时与不同的通信伙伴通信从技术上讲是不可能的（除非您使用多播，这在 TCP 上不起作用）。

【参考方案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"  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 上向所有已连接的人发送消息。