Настройка 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 день. Обращайтесь к нам для внедрения и масштабирования.