Se quero poder ter vários usuários e canais, preciso então para cada usuário criar um cliente no redis(ou seja qual for o pub/sub utilizado) para se inscrever no canal? e como faria para receber as mensagens? estou pensando assim, os clientes redis-pub/sub precisariam estar no nível em que está o servidor websocket, pois a comunicação cliente servidor seria apenas por websocket, não sei o que pub/sub utiliza para comunicação, mas estou querendo apenas websocket entre cliente e servidor, e o redis(banco de dados + pub/sub) comunicando localmente dentro do servidor:
'use strict';
//CREATE WEB SERVER
var express = require('express');
var app = express();
var http = require('http').Server(app);
//CREATE WS
const WebSocket = require('ws');
const wss = new WebSocket.Server({ server: http, port: 8080 });
//CREATE REDIS
var redis = require('redis');
var redisClient = redis.createClient({host : 'localhost', port : 6379});
var clients = {};
wss.on('connection', function connection(ws) {
ws.on('message', function incoming(message) {
// Aqui dependendo de certa mensagem recebida,
// como um login por exemplo, eu faria algo assim:
ws['user'] = obj.login.user.toString();
//CRIAR UM NOVO CLIENTE REDIS SUBS
clients[obj.login.user.toString()]['cliRedis'] = redis.createClient({host : 'localhost', port : 6379});
// SE INSCREVER NO CANAL
clients[obj.login.user.toString()]['cliRedis'].subscribe();
});
if("user" in ws) {
clients[ws.user]['cliRedis'].on("message", function(channel, message) {
console.log("Msg on subscriber: " + message);
//aqui enviaria os dados por websocket para o cliente
});
}
});
Up 1:
Com a resposta e comentários do @rodorgas consegui esclarecer bastante o que tenho a fazer. Então cheguei a conclusão que existem duas possibilidades, para os vários clientes poderem escutar as mensagens enviados pelo sistema pub/sub:
1 - Utilizando o Centrifugo como indicado na resposta do @rodorgas:
2 - Utilizando o redis pub/sub:
Comparações:
A maneira 1 teria quer ter duas conexões websockets ativas, uma para o Centrifugo e outra para o ws-server, pelo menos não encontrei nada na documentação do Centrifugo em que eu possa tratar mensagens que não sejam especificas para o pub/sub, algo como centrifugo-server.on("menssage", então penso que seria mesmo necessário duas conexões websockect nesse modo. Então ambos gastariam praticamente a mesma quantidade de sockets, pois os sockets necessários para a comunicação do redis pub/sub que seriam ganhos utilizando a maneira 1, são perdidos tendo que abrir uma nova conexão para a comunicação com o client-godot. A vantagem da maneira 1 é que parece ser de mais fácil entendimento, pois o client pub/sub está mesmo no cliente, que até nem existe de verdade, porque o Centrifugo apenas requer mensagens por websocket, não existe um cli-Centrifugo como existe um cli-redis, o client-Centrifugo é apenas o client-godot enviando mensagens via websocket. Já a maneira 2 os clientes-redis estariam armazenados dentro de um objeto javascript no script do nodejs. A maneira 1 eu terei que enviar as mensagens no padrão do Centrifugo que são grandinhas comparado ao que posso fazer enviando da maneira 2.
Enfim, estou indeciso de qual modo começar implementar, talvez faça os dois e escolha o que for mais rápido. De qualquer forma estou sem tempo nos próximos dias para começar a trabalhar nisso, então ainda tenho tempo para pensar no que fazer.
Conclusão:
Escolhi implementar com o redis pub/sub, pelo que estudei eu teria mais controle sobre o que estou fazendo. Porém não descartei o Centrifugo, ele me servirá muito bem caso eu venha implementar um chat no jogo, pois ele é muito bom para essa tarefa, com ele tenho como, por exemplo, criar conversas privadas entre apenas dois clientes, entre outras facilidades que já vem implementadas para você utilizar.
socket.io
ao invés dows
(pois o socket.io implementa vários fallbacks).var clients
, e ai é que entra dúvida, tenho mesmo que criar um cliente redis para cada cliente websocket?