I currently have a chat application(one to one) in node.js and socket.io. as the users in my website are increasing, i want to introduce redis in my chat app. Here is a small example of my current app:
// all requires and connections
io.sockets.on('connection', function(socket) {
socket.on('message', function(msg) {
// code to get receiverssocket
io.sockets.sockets[receiverssocket].emit('message',
{"source": msg.sendersusername,"msg": msg.msg});
});
});
Now, i am trying to find examples of how to do this with redis, but i cannot find an example of one to one chats with redis. i can only find examples in which messages are sent to all the users. Here is one of the examples i looked at
One way of i thought of doing this was to create channels for each user receiving messages, but that would result in thousands of channels. Any help on how i can do this?
Edit: added some code
io.sockets.on('connection', function (client) {
sub.on("message", function (channel, message) {
console.log("message received on server from publish ");
client.send(message);
});
client.on("message", function (msg) {
console.log(msg);
if(msg.type == "chat"){
pub.publish("chatting." + msg.tousername,msg.message);
}
else if(msg.type == "setUsername"){
sub.subscribe("chatting." + msg.user);
sub.subscribe("chatting.all" );
pub.publish("chatting.all","A new user in connected:" + msg.user);
store.sadd("onlineUsers",msg.user);
}
});
client.on('disconnect', function () {
sub.quit();
pub.publish("chatting.all","User is disconnected :" + client.id);
});
});
I think that you have to publish on a dedicated User channel .I think that there is no other way.But don't worry , pub/sub channel are volatile so that's should working well.
So for this channel , instead of publish to chatting publish on chatting.username your message , subscribe to the both.
io.sockets.on('connection', function (client) {
sub.subscribe("chatting." + client.id);
sub.subscribe("chatting.all" );
sub.on("message", function (channel, message) {
console.log("message received on server from publish ");
client.send(message);
});
client.on("message", function (msg) {
console.log(msg);
// supose that msg have a iduserto that is the distant contact id
if(msg.type == "chat"){
pub.publish("chatting." + msg.iduserto,msg.message);
}
else if(msg.type == "setUsername"){
pub.publish("chatting.all","A new user in connected:" + msg.user);
store.sadd("onlineUsers",msg.user);
}
});
client.on('disconnect', function () {
sub.quit();
pub.publish("chatting.all","User is disconnected :" + client.id);
});
});