Express/Socket.io：每个请求一个套接字的正确方式

Question

我正在尝试使用 Express、Socket.io 和 ntwitter 模块构建一个简单的 Node 应用程序，因此您只需搜索一个术语（即下面的 req.params.searchTerm），ntwitter 将搜索它并输出通过 socket.io 流式传输。

但是，我遇到了错误，打开了多个窗口，或者关闭了一个窗口，然后立即打开了一个窗口。有时搜索词没有更新，有时实际上会抛出某种 socket.io 错误。有人可以澄清这样做的正确方法或阐明我的错误吗？提前致谢。代码如下。

var server = http.createServer(app);

var io = require('socket.io').listen(server);

server.listen(app.get('port'), function(){
  console.log("Express server listening on port " + app.get('port'));
});

app.get('/:stream', function(req, res) {
 res.render('stream', { title: 'Search Twitter | ' + req.params.searchTerm });
    io.sockets.on('connection', function(socket) {

    var publishFlag = true;
    setInterval(function() {
        publishFlag = true;
    }, 1000);

    twit.stream('statuses/filter', { track: [req.params.searchTerm] },
        function(stream) {
            stream.on('data', function(tweet) {
                if(publishFlag) {
                    socket.emit('tweet', tweet);
                    publishFlag = false;
                }
            });
        }
    );
  });
});

Answer 1

它认为这在某种程度上是你想要做的：

服务器端：

var server = http.createServer(app);

var io = require('socket.io').listen(server);

server.listen(app.get('port'), function(){
  console.log("Express server listening on port " + app.get('port'));
});

app.get('/:stream', function(req, res) {
 res.render('stream', { title: 'Search Twitter | ' + req.params.searchTerm });
});

io.sockets.on('connection', function(socket) {

    socket.on('stream', function(searchTerm){

        twit.stream('statuses/filter', { track: [searchTerm] },
            function(stream) {
                stream.on('data', function(tweet) {
                    socket.emit('tweet', tweet);
                });
            }
        );
    };
});

客户端（/：流）

var socket = io.connect('http://localhost');
socket.on('tweet', addTweetOnPage);
socket.emit('stream', searchTerm);