Node.JS + Socket.io,将套接字事件处理程序移动到外部模块?

Node.JS + Socket.io, moving socket event handlers to external module?

我有一个这样的 server.js 文件:

var express = require('express'),
    app = express(),
    server = require('http').createServer(app),
    mongoose = require('mongoose'),
    bodyParser = require('body-parser'),
    apiRouter = require('./app/routes/api.js'),
    io = require('socket.io')(server),
    socketEvents = require('./app/modules/socketEvents.js')(io);

//Clears Node Console.
process.stdout.write('3c');
console.log('Server starting!');

socketEvents.attachEventHandlers();

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

app.use('/api', apiRouter);
app.use(express.static('public'));

app.use('*', function(req, res, next) {
    //All requests return single page angular application.
    res.sendFile(__dirname + '/public/index.html');
});

mongoose.connect('localhost', 'triviaattack', function(err) {
    if (err) {
        console.log('An error occured when connecting to the MongoDB Database');
        throw err;
    }
});

server.listen(1337);

和socketEvents.js

module.exports = function(io) {

    return {
        attachEventHandlers: function() {

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

                console.log('client connected');

                socket.on('joinMatchMaking', function(data) {
                    //Every time a player joins the matchmaking queue, check if a game can be created.
                    matchMakingQueue.push(data);
                    var matchedPlayers = [];
                    for (i = 0; i < matchMakingQueue.length; i++) {
                        switch (data.gameType) {
                            case '1v1':
                                matchedPlayers.push(matchMakingQueue[i].username);
                                if (matchedPlayers.length == 2) {
                                    socket.emit('matchFound', {players: matchedPlayers});
                                } 
                                console.log('user joined 1v1 queue');
                            case '2v2':
                                matchedPlayers.push(matchMakingQueue[i].username);
                                if (matchedPlayers.length == 4) {
                                    socket.emit('matchFound', {players: matchedPlayers});
                                } 
                                console.log('user joined 2v2 queue');
                        }
                    }
                    console.log(data.username + ' joined the ' + data.gameType + ' matchmaking queue');
                    console.log('users in queue: ' + matchMakingQueue.length);
                });

                socket.on('leaveMatchMaking', function(username) {
                    matchMakingQueue.splice(matchMakingQueue.indexOf(username), 1);
                    console.log(username + ' left matchmaking queue.');
                    console.log('users in queue: ' + matchMakingQueue.length);
                });

            });

        console.log('events attached');

        }
    }

};

当我在浏览器中加载我的网站时,io.on('connection), function () {...}) 事件处理程序没有被调用,它应该输出 console.log每当客户端连接时发送消息。我想将我的 socket.io 事件保留在我的主 server.js 文件之外,因为它们会有很多,我想将它们分开到它们自己的模块中。

您需要在 html 文件中包含一些套接字代码才能连接..您也可以包含它吗?

我通过将我所有的套接字事件填充到一个中间件中来做到这一点:

var io = require('socket.io');
// listen stuff
var SocketEvents = require('./socket-events.js')(io);
io.use(SocketEvents);

... 然后在 socket-events.js 中是这样的:

module.exports = function(io) {
    return function(socket, next) {
        // do stuff
        return next();
    }
}

我应该补充一点,在这种情况下,on("connection") 侦听器似乎不是必需的,因为每个中间件函数已经在每个传入套接字连接上执行。