2015-12-27 24 views
0

我有一个server.js文件是这样的:Node.JS + Socket.io,将套接字事件处理程序移动到外部模块?

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('\033c'); 
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('连接),功能( ){...})事件处理程序没有被调用,它应该在客户端连接时输出一个console.log消息。我想将我的socket.io事件保存在我的主server.js文件之外,因为它们会有很多,我想将它们分离到它们自己的模块中。

回答

2

你需要在html文件中有一些套接字代码来连接..你可以包括它吗?

+0

嗨,这是我的错误。感谢您的回复,我错过了发送'连接'的客户端代码,woops :( –

+2

将此添加到我的index.html中\t

1

我这样做馅用我所有的插座事件的中间件:

...然后在socket-events.js类似:

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

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

+0

谢谢嗨,什么是做这种方式VS我想要的方式只是想知道,或者如果他们都达到同样的事情的优势反正在问题我有没有包括客户端io.emit('连接')...当我加入\t 我的index.html它的工作原理 –

+1

@David,我喜欢这种方法让我进一步划分功能。如果我需要将每个套接字事件分割成它自己的文件,那么这将非常容易。如果你愿意的话,我可以在一个半完成的项目中找到类似的东西,我可以与你联系。 – Connor

+0

当然,我想看看。通过我所做的方法,我将仅限于将所有事件保存在1个文件中? –

相关问题