var connect = require('connect'); var http = require('http'); var serveStatic = require('serve-static'); var app = connect(); app.use(serveStatic(__dirname)); var server = http.createServer(app); var io = require('socket.io')(server); io.on('connection', function (socket) { socket.on('join', function (room) { console.info('join', room); socket.join(room.room); }); socket.on('message', function (data) { console.info(data); io.to(data.room).emit('message', data); }); }); server.listen(3000);