varapp=require('express')();varserver=require('http').Server(app);vario=require('socket.io')(server);varredis=require('redis');server.listen(27981);//server.listen(8090);io.sockets.on('connection',function(socket){console.log("new client connected");varredisClient=redis.createClient({db:2});varchannelGlobal='notification2';redisClient.subscribe(channelGlobal);redisClient.on("message",function(chn,message){console.log("New message: "+message+". In channel: "+chn);//io.sockets.in(chn).emit('message', message, socket.id); //verificar para que sirve con la siguiente linea es suficiente para enviar los datos a los clientessocket.emit(chn,message);});socket.on('set_channel',function(newChannel){//socket.leave(channel);channelGlobal=newChannel;console.log("cambio canal");redisClient.subscribe(newChannel);socket.join(newChannel);socket.emit('change channel',newChannel);});});
Comments (0)
HTTPSSSH
You can clone a snippet to your computer for local editing.
Learn more.