如何使用Socket.io禁用多路复用
我正在使用Socket.io向我的用户发送实时tweet(我的实现或多或少基于this tutorial)。
问题是，每次Socket.io触发连接事件时，新连接的客户端都会导致连接到服务器的所有其他客户端停止更新。虽然这将花费太长的时间来检查我尝试过的所有黑客攻击，但我会说，我已经尝试了足够多的时间，我相信问题是由Socket.io多路复用来自多个客户端的连接(默认情况下启用)作为性能提升来允许多个客户端或连接共享相同的底层套接字造成的。简而言之，我认为情况就是这样，因为我认为，如果没有连接多路复用，新连接不可能以这种方式影响旧连接。换句话说，如果每次客户端连接时都创建一个具有其自己的底层(TCP)套接字的新的、独立的连接，则不可能发生这种情况，因为一个连接对另一个连接一无所知，因此不会像当前发生的那样影响任何其他客户端的状态。这也让我相信，简单地禁用多路复用功能将是解决此问题的最简单方法，因为我不关心可伸缩性，因为Node.js已经处理了我可能需要非常充分地处理的所有并发。
我已经看过了Socket.io的documentation，但是看不到通过API“多路分解”连接的能力在哪里公开，所以如果有人知道如何做到这一点，我将感谢您的回复。
我下面的代码非常标准和简单。但为了清楚起见，问题是每当一个新客户端连接到Socket.io时，每个其他客户端都会停止接收新的tweet，并且更新不再推送到旧客户端，除非我刷新浏览器，在这种情况下，新更新的客户端将开始更新并再次接收新的tweet，但其他仍然连接的客户端将停止更新。
服务器端代码：
// 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>');
}
});如果我认为这是错误的，或者如果我的代码有什么问题，我绝对愿意接受任何建议。我也很乐意回复任何额外的细节。
回答 1
Stack Overflow用户
发布于 2013-11-01 23:41:11
我会尝试像这样的东西
服务器端：
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>');
}
});基本上，在你的socket之外有来自twitter的流，然后在新的tweet上emit一条消息给所有连接的人。
https://stackoverflow.com/questions/13898917
复制相似问题
腾讯云开发者
