0

我正在玩 node.js 和 socket.io,试图让计数程序正常工作。基本上它应该是每次连接的客户端按下按钮时将共享计数器增加 1,并将该数字显示给所有连接的客户端。

我得到的是每个客户都有一个单独的计数器。例如,如果我在一个客户端上数到 10,然后开始从另一个客户端开始数,它从 1 开始。如果我回去,第一个客户端将从 10 恢复。我已经尽力解决这个问题,但是当涉及到 JS 范围问题(我怀疑这是)或套接字时,我不太了解。

var socketio = require('socket.io');
var io;
var count = 1;

exports.listen = function(server){
    io = socketio.listen(server);
    io.set('log level', 1);

    io.sockets.on('connection', function (socket){
        joinRoom(socket, 'Lobby');
        count = handleCounter(socket, count);
    });
};

function handleCounter(socket, count){
    socket.on('endCount', function(){
        io.sockets.emit('endCount', {
            success: true,
            num: count
        });
            count++;
            console.log(count);
    });
    return count;
}

function joinRoom(socket, room){
    socket.join(room);
}

作为一个注释,我之前只是将handleCounter中的代码放入io.sockets.on('connection')函数中时它工作过,但我想知道为什么当我尝试像上面的代码一样将它放在外面时它不会工作。

非常感谢任何帮助,谢谢。

4

2 回答 2

3

count在 结束时返回handleCounter(),但它在异步函数中递增,因此在返回之前它没有递增。

count您可以直接引用count您在文件顶部声明的变量,而不是四处传递,该变量在您的所有闭包中都可用。endCount如果您只想在每次客户端连接时向客户端发送新计数,您也不需要侦听器和发射器。

var socketio = require('socket.io');
var io;
var count = 1;

exports.listen = function(server){
    io = socketio.listen(server);
    io.set('log level', 1);

    io.sockets.on('connection', function (socket){
        joinRoom(socket, 'Lobby');
        handleCounter();
    });
};

function handleCounter(){
    count++;
    console.log(count);

    io.sockets.emit('count', {
        success: true,
        num: count
    });
}

function joinRoom(socket, room){
    socket.join(room);
}
于 2013-04-14T01:14:20.473 回答
0

http://realtimeanswer-5042.usw1.actionbox.io:4000/

简而言之,在连接时发送数据,并在单击按钮时将数据发送给所有客户端。

客户端只有在从服务器收到消息时才更新 dom。

我在您的代码中看到的最大问题是您使计数范围复杂化。它是模块范围,可以简单地使用而无需传递它。

服务器:

var app = require('express')()
  , server = require('http').createServer(app)
  , io = require('socket.io').listen(server)
  , count = 0;

var port = 4000;

server.listen(port);

app.get('/', function (req, res) {
  res.sendfile(__dirname + '/index.html');
});

io.set('log level', 1);

io.sockets.on('connection', function (socket) {
  console.log(count);
  socket.emit('count', count);
  socket.on('inc', function () {
    count++;
    console.log('inc', count);
    io.sockets.emit('count', count);
  });
});

客户

<!DOCTYPE html>
<meta charset='utf-8'>
<title>real time fun</title>
<script src="/socket.io/socket.io.js"></script>
<script src="http://code.jquery.com/jquery.js"></script>

<script>
  $(function() {
    var socket = io.connect();

    socket.on('count', function (count) {
      $('#count').text(count);
    });

    $('button').click(function () {
      socket.emit('inc');
    });
  });
</script>
<div id='count'></div>
<button>inc</button>
于 2013-04-14T01:10:05.437 回答