Jak zaprojektować redis pub / sub dla systemu komunikatorów?

Jestem nowy w redis pub / sub. Mam czat w systemie, który jest jak im. Więc chciałbym użyć redis pub / sub. Ponieważ zbadałem próbki, większość z nich została zaprojektowana w oparciu o Czat. W moim systemie będę miał wiele czatów między użytkownikami jak;

A:B
A:C
D:C
E:F

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))
        });
    });
});

Jak widzisz, tworzę nowego abonenta redis dla każdego połączenia. W innym czacie próbki redis klient Abonenta jest tworzony globalnie. I istnieją tylko trzy połączenia przez cały czas i to rozwiązuje ich problem, ponieważ kiedy wydawca publikuje wiadomość, wszyscy podłączeni klienci powinni ją otrzymać. Ale mam tu pewne ograniczenia. Chcę otworzyć sesję czatu między dwoma użytkownikami i tylko ci użytkownicy powinni być subskrybentami. Powyższy kod działa tak, jak chciałbym, ale nie wiem, czy redis jest w porządku, aby utworzyć nowego klienta Abonenta dla każdego połączenia.

To miło będzie usłyszeć Twoje sugestie. Z góry dzięki.