Socket.io 单个事件的多次返回

Question

我直接从 socket.io 网站复制的代码有问题。我有服务器设置，它运行良好。问题是它在第一个事件触发后复制每个事件：

我在这里读到：Socket.io message event firing multiple times

那是因为事件每次都重新注册。但它实际上并没有说明如何阻止和解决这个问题。

由于我的代码是 Socket 网站的直接副本，我真的很困惑，因为多次 Google 搜索只能提供模糊的信息，而且从来没有真正的解决方法。

这是我的基本代码：

var util = require('util'),
    express = require('express'),
    http = require('http').Server(express),
    https = require('https').Server(express),
    io = require('socket.io')(http),
    config = require('./config'),
    phash = require('phpass').PasswordHash,
    bodyParser = require('body-parser'),
    mysql = require('mysql'),
    ip = require('ip');

var connection = mysql.createConnection({
    host: config.dbhost,
    user: config.dbuser,
    password: config.dbpass,
    database: config.dbname
});

var app = express();

connection.connect(function ( err ) {
    if(!err) {
        console.log("Database is connected ... \n\n");  
    } else {
        console.log("Error connecting database ... \n\n");  
    }
});

http.listen(config.port);

app.use(bodyParser.json());
app.use(bodyParser.urlencoded({
    extended: true
}));

io.on('connection', function ( socket ) {
    socket.on('newboard', function ( data ) {
        console.log(data);
        connection.query('MYSQL', function ( err, rows, fields ) {
            if (!err) {
                console.log('The solution is: ', rows);
                io.sockets.emit('messageSuccess', { bid: rows.insertId });
            } else
                console.log('Error while performing Query. '+err);
        });
    });

    socket.on('changeboard', function ( data ) {
        console.log(data);
        connection.query('MYSQL', function ( err, rows, fields ) {
            if (!err) {
                console.log('The solution is: ', rows);
                io.sockets.emit('messageSuccess', rows);
            } else
                console.log('Error while performing Query. '+err);
        });
    });
});

更新

根据要求，我的客户端代码：

var socket = io.connect('http://localhost:8080');

socket.emit('newboard', { title: boardTitle, usid: 1 });
socket.on('messageSuccess', function ( data ) {
    bid = data.bid;
});

socket.emit('changeboard', { bid: id });
socket.on('messageSuccess', function ( data ) {
    console.log(data);
    for (i = 0; i < data.length; i++) {
        //Code run on local HTML
    }
});

如前所述，它仅在第二次调用 newboard 和 changeboard 之后执行。然后它开始加倍。如果我继续前进，它只会继续翻倍，直到我有 30 个板并刷新页面。

更新2

客户区的完整代码可以在这里找到： http://pastebin.com/dkgy4VUx

Answer 1

我猜这段代码在某种你多次调用的函数中：

socket.emit('changeboard', { bid: id });
socket.on('messageSuccess', function ( data ) {
    console.log(data);
    for (i = 0; i < data.length; i++) {
        //Code run on local HTML
    }
});   

因此，每次调用该函数时，都会为messageSuccess 消息安装另一个重复的事件处理程序。因此，在您调用该函数两次之后，您将拥有该消息的两个事件处理程序，并且您将对其进行两次处理。

您不能重复添加消息处理程序，除非您也删除它们（因为您得到重复的处理程序）。消息处理程序通常应在首次创建套接字连接时添加一次。