Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- app.set('port', httpPort);
- let server = http.createServer(app);
- let io = require('./socketServer')(server);
- io.adapter(redis({host: host, port: port}));
- app.set('io', io);
- io.sockets.on('connection', (socket) =>{
- var socketID = socket.handshake.user.sid;
- io.clients[socketID] = socket;
- io.clients[socketID].broadcast.emit('loggedIn',socket.handshake.user.data);
- socket.on('disconnect', () =>{
- delete io.clients[socketID];
- });
- });
- this.redis.getByMask(`sid_clients:*`,(err,rdbData) =>{
- Async.each(clients,(client,next)=>{
- let sid = `sid_clients:${client}`;
- let currentClient = rdbData[sid];
- if(!currentClient || !this.io.clients[currentClient]) return next();
- this.io.clients[currentClient].emit(event,data);
- return next();
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement