Служба NodeJS и Queue Messaging

Question

В моем проекте узла мне нужен процесс, который считывает все данные из очереди и ретранслирует данные в режиме реального времени через веб-порты всем подписчикам. Мне было интересно, можно ли добиться чего-то подобного с Редисом? У меня может быть несколько серверов, которые помещают данные в эту очередь.

Каким будет правильный подход и инструменты для достижения этого?

Спасибо!

Answer 1

Я делаю это с SocketCluster. Вместо того, чтобы иметь очередь, я, вероятно, просто подключу сервер напрямую к SocketCluster.

Так что да,

Browsers <-> SocketCluster <-> Queue or direct messaging 
        | 
       Redis 

Обратите внимание, что Redis используется SocketCluster для кластеризации. Возможно, это не лучший способ разместить ваши сообщения в очереди.