Настройка Redis Pub/Sub для уведомлений реального времени

При 10 000 WebSocket-соединений каждый экземпляр сервера знает только о своих клиентах. Когда нужно разослать событие всем (обновление статуса заказа, новая транзакция), без единого брокера возникает проблема. Мы решаем её с помощью Redis Pub/Sub: сообщение публикуется в канал, все активные подписчики получают его. Механизм fire-and-forget с задержкой <1 мс. Брокер не хранит историю — подходит для коротких уведомлений, инвалидации кешей, синхронизации состояния. Ниже — настройка, интеграция с Node.js и Laravel, подводные камни.

Когда выбирать Pub/Sub вместо Redis Streams?

Pub/Sub решает broadcast-задачу: один издатель, несколько подписчиков, все получают одинаковые сообщения одновременно. Если нужна гарантированная доставка, история или группы потребителей — используйте Redis Streams. Pub/Sub в 2-3 раза быстрее Redis Streams при broadcast-рассылке, но не гарантирует доставку. Сводная таблица:

Как избежать потери сообщений при отключении подписчика?

Прямой способ защититься от потери сообщений — дублировать последние события в отдельный Redis-ключ с TTL (например, last_event:user:42). Клиент при подключении сначала получает пропущенные события через REST API, затем переходит на Pub/Sub. Для критичных данных (финансовые транзакции) используйте Redis Streams с consumer groups. Этот подход снижает потери до нуля и экономит до 30% ресурсов на повторную обработку.

Базовая настройка Redis

Redis из коробки поддерживает Pub/Sub. Рекомендуемые параметры redis.conf:

# Лимит памяти maxmemory 512mb maxmemory-policy allkeys-lru # Количество баз databases 16 # Отключить persistence для чистого Pub/Sub save "" appendonly no 

Для production используйте Redis Sentinel или Cluster. Обычный Pub/Sub в Cluster ограничен шардом — с Redis 7+ используйте sharded Pub/Sub (SPUBLISH/SSUBSCRIBE).

Интеграция с Node.js и Socket.io

Используйте библиотеку ioredis для двух отдельных соединений (публикатора и подписчика). Пример на TypeScript:

import Redis from 'ioredis'; const publisher = new Redis({ host: 'redis', port: 6379 }); const subscriber = new Redis({ host: 'redis', port: 6379 }); subscriber.subscribe('notifications:user:*', (err, count) => { if (err) throw err; console.log(`Subscribed to ${count} channels`); }); subscriber.on('pmessage', (pattern, channel, message) => { const userId = channel.split(':')[2]; const payload = JSON.parse(message); broadcastToUser(userId, payload); }); async function notifyUser(userId: string, event: object) { const channel = `notifications:user:${userId}`; const count = await publisher.publish(channel, JSON.stringify(event)); return count; } 

Для WebSocket используйте Socket.io с Redis Adapter:

import { createServer } from 'http'; import { Server } from 'socket.io'; import { createAdapter } from '@socket.io/redis-adapter'; import { createClient } from 'redis'; const httpServer = createServer(); const io = new Server(httpServer); const pubClient = createClient({ url: 'redis://redis:6379' }); const subClient = pubClient.duplicate(); await Promise.all([pubClient.connect(), subClient.connect()]); io.adapter(createAdapter(pubClient, subClient)); httpServer.listen(3000); 

Redis Adapter использует Pub/Sub: при io.to('room').emit() команда публикуется в Redis-канал, и все экземпляры сервера рассылают её клиентам комнаты.

Интеграция с Laravel

В Laravel отправка Pub/Sub-сообщения выглядит так:

use Illuminate\Support\Facades\Redis; Redis::publish('notifications:user:'.$userId, json_encode([ 'type' => 'order.status_changed', 'orderId' => $order->id, 'status' => $order->status, 'timestamp' => now()->toISOString(), ])); 

Для приёма сообщений на клиенте используйте Laravel Echo Server или Soketi.

Процесс настройки (пошагово)

1. Спроектировать схему каналов: обычно используют паттерны entity:action:user_id.
2. Настроить Redis: задать maxmemory, отключить AOF для чистого Pub/Sub.
3. Реализовать публикацию событий в бэкенде (Node.js, Laravel, Django).
4. Подключить WebSocket-сервер (Socket.io, Soketi) с Redis Adapter.
5. Разработать механизм fallback-запроса для пропущенных событий (через REST).
6. Протестировать нагрузку: убедиться, что instantaneous_ops_per_sec не превышает 5 000.

Мониторинг

Используйте команды Redis CLI:

redis-cli PUBSUB CHANNELS "*" redis-cli PUBSUB NUMSUB notifications:user:42 redis-cli PUBSUB NUMPAT 

В Prometheus с Redis Exporter отслеживайте instantaneous_ops_per_sec. Рост выше 5 000 оп/с при нагрузке Pub/Sub сигнал к оптимизации (уменьшить размер сообщений, увеличить число каналов).

Ограничения и альтернативы

Потеря сообщений при реконнекте

Подписчик, отключившийся на время, не получает пропущенные сообщения. Для критичных уведомлений — Redis Streams или хранение последних событий.

Нет подтверждения доставки

PUBLISH возвращает число получателей, но не гарантирует обработку. Для at-least-once — очередь (RabbitMQ, Redis Streams).

Нагрузка на CPU при большом числе паттернов

PSUBSCRIBE сопоставляет каждое сообщение со всеми паттернами. При 10 000+ паттернов задержка растёт на 30–50%.

Что входит в работу

Внедрение Pub/Sub позволяет снизить затраты на инфраструктуру WebSocket до 40% за счёт отказа от дополнительных брокеров.

• Проектирование схемы каналов и паттернов под бизнес-логику.
• Настройка Redis (конфигурация, кластеризация, мониторинг).
• Интеграция Pub/Sub с бэкендом (Node.js, Laravel, Django — по вашему стеку).
• Подключение WebSocket-сервера (Socket.io, Soketi, Laravel Echo).
• Разработка механизма защиты от потери сообщений (fallback-запросы).
• Документация по развертыванию и эксплуатации.
• Передача доступа к репозиторию и инфраструктуре.
• Сопровождение в течение 2 недель после сдачи.

Мы работаем с Redis более 6 лет, реализовали 15+ проектов с Pub/Sub для клиентов из e-commerce и fintech. Используем production-конфигурации с Sentinel и Cluster, гарантируем отказоустойчивость. Закажите настройку Redis Pub/Sub для вашего проекта — получите консультацию за 1 день. Обращайтесь к нам для внедрения и масштабирования.