| |
|
|
| | Имеется один канал под именем "public", в него публикуется вся публичная инфа в формате JSON. Считывается это все так:
redisClient.on('pmessage', function(pattern, channel, dataJson) {
dataJson = JSON.parse(dataJson);
// Send to Socket.io
});
|
Сначала, канал пустой (без данных). Как только в нем появляются данные - они рассылаются всем подписчикам. Когда в канале публикуется запись следующая - она рассылается всем подписчикам вместе с предыдущей.
И так до бесконечности, отправляя уже ранее отправленные. Как с этим быть? Как правильно работать с каналом?
Может как-то удалять с канала прочитанное сообщение, если оно было прочитано всеми подписчиками? | |
| |
|
