Redis pub/sub - тот же процесс, прослушивающий один канал

Question

У меня есть один сервер Node.js - я хотел бы, чтобы процесс прослушивал сообщения, отправленные от себя - это только для тестирования. Проблема, с которой я столкнулась, заключается в том, что при публикации сообщения в тот же процесс подписчик, похоже, вообще не получает его.

У меня есть эта установка:

var redis = require('redis'); 

var rcPub = redis.createClient(); 
var rcSub = redis.createClient(); 

var message = String('testing123'); 

rcSub.subscribe('redis_channel@test_overall_health'); 

rcSub.on('message', function (channel, msgs) { 

    console.log(channel,msgs); 

}); 


rcPub.publish('redis_channel@test_overall_health', message); 

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

Answer 1

Видимо, команда SUBSCRIBE отправляется после команды PUBLISH.

Клиент Redis клиента Node переводит команды до тех пор, пока соединение не будет установлено на сервер Redis и не сбросит команды в очередь на сервер, если в соке получено событие . Сначала клиент, инициировавший соединение (издатель), скорее всего получит событие connect, после чего он отправит свои команды в очередь (опубликует). Поскольку Redis обрабатывает команды в одном потоке, абонент SUBSCRIBE s только после завершения команды PUBLISH. Другие процессы могут получать сообщения, так как они уже подписались на этот канал.

Создание клиента подписчика первый должен работать в большинстве случаев, хотя и более безопасный подход будет ждать подписки завершить перед публикацией сообщений:

var redis = require('redis'); 

var publisher = redis.createClient(), 
    subscriber = redis.createClient(), 
    message = 'testing123'; 

subscriber.subscribe('redis_channel@test_overall_health'); 

subscriber.on('message', function (channel, message) { 
    console.log(channel, message); 
}); 

subscriber.on('subscribe', function (channel, count) { 
    publisher.publish('redis_channel@test_overall_health', message); 
});