我是redis pub/sub的新手。我在系统中有一个像IM一样的聊天工具。所以我想使用redis pub/sub。正如我已经检查过的样本,其中大部分是基于聊天室设计的。在我的系统中,我将有多个用户之间的聊天室,如何设计即时通讯系统的redis pub/sub?
A:B
A:C
D:C
E:F
因此,上面的行是房间。我已经实现了像下面的node.js服务器;
var store = redis.createClient();
var pub = redis.createClient();
io.sockets.on('connection', function (socket) {
var sub = redis.createClient();
sub.on("message", function(pattern, data){
data = JSON.parse(data);
socket.send(JSON.stringify({ type: "chat", key: pattern, nick: data.nickname, message: data.text }))
}
});
socket.on('message', function (messageData) {
store.incr("messageNextId", function(e, messageId) {
var room = ""
var from = messageData.clientId > socket.nickname ? socket.nickname : messageData.clientId;
var to = messageData.clientId < socket.nickname ? socket.nickname : messageData.clientId;
room = from + ":" + to;
var message = { id: messageId, nickname: socket.nickname, text: messageData.text };
store.rpush("rooms:" + room, JSON.stringify(message), function(e, r) {
pub.publish(room, JSON.stringify(message))
});
});
});
正如你可以看到我创建每个连接的新Redis的用户。在其他聊天室示例中,redis订户客户端在全球范围内创建。并且始终只存在三个连接并解决了他们的问题,因为当发布者发布消息时,所有连接的客户端都应该获得它。但我在这里有一个限制。我想打开两个用户之间的聊天会话,只有这些用户应该是订阅者。上面的代码正如我所愿,但我不知道redis是否可以为每个连接创建一个新的订阅者客户端。
很高兴听到您的建议。提前致谢。
感谢详细的解答。我知道socket.io有房概念但我并没有意识到它是在幕后使用pub/sub,我会尝试一下,当然,我会开始基准测试,目前我只是想找到一个好的起点。 – 2012-04-13 19:58:29
@AliErsöz:太好了,如果你发现我的答案是令人满意的,请点击左上方的大号勾号,考虑接受答案为正确答案。 – 2012-04-25 16:27:30