Redis Pub/Sub 聊天室答案

【问题标题】：Redis Pub/Sub ChatRoomsRedis Pub/Sub 聊天室
【发布时间】：2016-01-18 08:19:26
【问题描述】：

我对 Redis Pub/sub 很陌生，所以请多多包涵。我正在尝试创建一个 IRC，用户可以在其中创建自己的聊天室，有点像 Gitter。以下是我到目前为止所做的事情。我通过用户名为用户订阅不同的频道只是为了测试。问题是当我发布到频道 x 时，被订阅频道 y 的客户仍然得到相同的结果消息.. 我正在使用 redis-cli 和 PUBLISH 命令发布。

function handleIO(socket){
    function disconnect(){
        console.log("Client disconnected");
        socket.broadcast.emit("user d/c", socket.username+" has left!");
    }

    socket.on("new user", function(username){
        socket.username = username;

        if(socket.username == "chat"){
            redisClient.subscribe("chat");
        }else{
            redisClient.subscribe("other");
        }

        socket.userColor = '#'+(Math.random()*0xFFFFFF<<0).toString(16);
        socket.emit("new_user", username);

        emitter.lrange("messages", 0, -1, function(err, messages){
            //reversing to be in correct order
            messages = messages.reverse();

            messages.forEach(function(message){
                message = JSON.parse(message);
                socket.emit("messages", message);
            });
        });

        socket.broadcast.emit("user connection", username+" has connected to the Haven!");
    });
    socket.on("disconnect", disconnect);

    socket.on("send", function(msg){
        var msg = JSON.stringify( { name: socket.username, messageText: msg, color: socket.userColor } );

        emitter.lpush("messages", msg, function(err, response){
            //keep newest 10 items
            emitter.ltrim("messages", 0, 9);
        });
        io.sockets.emit("receive", msg, socket.userColor);
    });
    redisClient.on("message", function (channel, message) {
        console.log(channel+":"+message);
        socket.emit("message", channel, message);
    });

}

【问题讨论】：

标签： node.js redis socket.io publish-subscribe

【解决方案1】：

对于迷路的流浪者......我所做的是在客户端上实现另一个事件，以基本上检查该客户端是否“有权”接收消息（即消息的频道是否属于客户端的子频道列表，如果这就说得通了）。

客户端

socket.on("message", function(channel, message){
     socket.emit("entitled", channel, message);
});

socket.on("entitled", function(reply, channel, message){
     if(reply == 1){
          $("#msgArea").append(message+"<br/>");
          $("#msgArea").prop({ scrollTop: $("#msgArea").prop("scrollHeight") });    
     }
});

服务器端

socket.on("entitled", function(channel, message){
    //check that user is subbed 
    emitter.sismember('channels:'+socket.username, channel, function(err, reply){
        if(err) throw err;
        socket.emit("entitled", reply, channel, message);
    });
});

我故意遗漏的是，我没有继续使用 socket.username，而是开始使用会话来保持持久性。我的建议是坚持使用 redis 存储，因为它是 github 上最受欢迎的存储之一。

【讨论】：