Ranu's Blog: RedisStore and rooms with Socket.IO

Yes, you can. But this code only is to join multiple rooms. And you can leave rooms when event disconnect is raised. If understood correctly your question.

hi, very cool example!! i have one question though:
I don't see any '.publish(...)' or '.subscribe(...)' - commands, is that just not covered by this is example or is socket.io taking care of that itself now?
In other words: does this line 'io.set('store', new RedisStore({redisPub:pub, redisSub:sub, redisClient:store}));' take care of the redis-part?! i do not have to say '.publish(...)' on every event myself?

cheers
olaf

Yes Olaf, in the line: io.set('store', new RedisStore({redisPub:pub, redisSub:sub, redisClient:store}));' You are sending a publisher and a subscriber to Socket.io that it will use. So that work is made by socket.io.

hope it helps
Ranu

hi ranu, te hablo de colombia, he estado tratando de correr y entender este ejemplo pero aun tengo algunas dudas, por ejemplo no pude hacerlo correr con redis, recibo algunos errores al momento de iniciar el server, podrias aclararme algunas dudas con respecto a este ejemplo ?

jspot,
claro que si. Decime cual es tu duda.

Hi, I'm sorry to bother you, but can you tell me where in the code we're actually subscribing each of the sockets to the specified Room, because I'm not really sure I understand how the messages can be sent from one user to the other if the user's connections are not subscribed to certain rooms.
Thank you

Hi,
I don't understand your question. But where I call the function "join", is to the user to join a Room. And when I call the function broadcast.to(Room) is to send a message to a room. Here you can find more information https://github.com/learnboost/socket.io , read the section rooms.

Regards

Hola Ranu !

I'm Stephane from France. Nice article you have here. I'm currently learning socket.io and it's fun.

I went to have a look at your start-up at peoples room and I liked it. Specially the cartoon animation. Did you use some software to make that cartoon ? Your website is super cool !

Hope to see your start up succeed !

Stephane,
thanks for your comments. The video was made by: http://mambostudio.com.ar

Regards

	//app.js Socket IO Test
	var app = require('express').createServer(),
	redis = require('socket.io/node_modules/redis'),
	io = require('socket.io').listen(app);

	var pub = redis.createClient(port, "url");
	var sub = redis.createClient(port, "url");
	var store = redis.createClient(port, "url");
	pub.auth('pass', function(){console.log("adentro! pub")});
	sub.auth('pass', function(){console.log("adentro! sub")});
	store.auth('pass', function(){console.log("adentro! store")});

	io.configure( function(){
	io.enable('browser client minification'); // send minified client
	io.enable('browser client etag'); // apply etag caching logic based on version number
	io.enable('browser client gzip'); // gzip the file
	io.set('log level', 1); // reduce logging
	io.set('transports', [ // enable all transports (optional if you want flashsocket)
	'websocket'
	, 'flashsocket'
	, 'htmlfile'
	, 'xhr-polling'
	, 'jsonp-polling'
	]);
	var RedisStore = require('socket.io/lib/stores/redis');
	io.set('store', new RedisStore({redisPub:pub, redisSub:sub, redisClient:store}));
	});

	app.listen(8000);

	app.get('/', function (req, res) {
	res.sendfile(__dirname + '/index.html');
	});

	var buffer = [];
	io.sockets.on('connection', function(client){
	var Room = "";
	client.on("setNickAndRoom", function(nick, fn){
	fn({msg : "Hello " + nick.nick});
	client.join(nick.room);
	Room = nick.room;
	client.broadcast.to(Room).json.send({ msg: "Se conecto al room: " + nick.room, nick : nick });
	});

	client.on('message', function(message, fn){
	var msg = message; //{ message: [client.sessionId, message] };
	buffer.push(msg);
	if (buffer.length > 15)
	buffer.shift();
	client.broadcast.to(Room).json.send(msg);
	fn(msg);
	});

	client.on('disconnect', function(){
	client.broadcast.to(Room).json.send({ msg: "Se desconecto"});
	});

	});

	<html xmlns="http://www.w3.org/1999/xhtml">
	<head>
	<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
	<title>Socket IO Test</title>
	<script src="http://ajax.googleapis.com/ajax/libs/jquery/1.7.0/jquery.min.js"></script>
	<script src="/socket.io/socket.io.js"></script>
	</head>
	<body>
	<h1>Socket IO Test</h1>
	<div id="setNickSpace">
	Nickname: <input type="text" id="nickname"/> <br/>
	Room: <input type="text" id="room"/> <button id="setNickName">Set</button>
	</div>
	<div id="chat" style="display: none;">
	<div id="board"> </div>
	<textarea id="textSend"></textarea>
	<button id="send">Send</button>
	</div>
	</body>
	<script type="text/javascript">
	var chati = null;
	$(document).ready(function(){
	$("#setNickName").click(function(){
	$("#setNickSpace").hide();
	$("#chat").show();
	chati = new Chat;
	chati.Connect($("#nickname").val(), $("#room").val());
	} );
	$('textarea#textSend').bind('keypress', function(e) {
	if(e.keyCode==13){
	sendMsg();
	}
	});

	$("#send").click(function()
	{
	sendMsg();
	});
	function sendMsg(){
	var m = $("#textSend").val();
	$("#textSend").val("");
	chati.Send(m);
	}

	var today = new Date();
	var offset = -(today.getTimezoneOffset()/60);

	});


	function Chat(){
	this.socket = null;
	this.Nickname = "";
	this.Room = "";

	this.Connect = function(nick, room){
	socket = io.connect('http://192.168.55.100:8000');
	Nickname = nick;
	Room = room;
	//conectarse
	socket.on('connect',function (data) {
	socket.emit('setNickAndRoom', {nick: nick, room: room}, function(response){
	$("#board").append("<p>" + response.msg + "</p>");
	});
	});
	//mensajes
	socket.on("message", function(msg, p, c){
	$("#board").append("<p>" + msg.nick + ": " + msg.msg + "</p>");
	});
	};

	this.Send = function Send (msg) {
	socket.emit("message", {msg: msg, nick: Nickname} , function(response) {

	$("#board").append("<p>" + Nickname + ": " + msg + "</p>");
	});
	};


	}

	</script>
	</html>

jueves, noviembre 24, 2011

RedisStore and rooms with Socket.IO

9 comentarios: