При 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-рассылке, но не гарантирует доставку. Сводная таблица:
| Характеристика | Pub/Sub | Redis Streams |
|---|---|---|
| Гарантия доставки | Нет (fire-and-forget) | Да (consumer groups) |
| Хранение истории | Нет | Да (настраиваемый TTL) |
| Задержка | < 1 мс | 1-5 мс |
| Поддержка шардирования | Только sharded Pub/Sub (Redis 7+) | Да (через consumer group) |
| Применение | 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.
Процесс настройки (пошагово)
- Спроектировать схему каналов: обычно используют паттерны
entity:action:user_id. - Настроить Redis: задать maxmemory, отключить AOF для чистого Pub/Sub.
- Реализовать публикацию событий в бэкенде (Node.js, Laravel, Django).
- Подключить WebSocket-сервер (Socket.io, Soketi) с Redis Adapter.
- Разработать механизм fallback-запроса для пропущенных событий (через REST).
- Протестировать нагрузку: убедиться, что
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 сигнал к оптимизации (уменьшить размер сообщений, увеличить число каналов).
Чек-лист для production
- Убедитесь, что Redis работает в режиме Sentinel или Cluster.
- Настройте maxmemory и политику вытеснения.
- Используйте отдельные соединения для Pub/Sub (не смешивайте с обычными операциями).
- Внедрите fallback-запросы для пропущенных сообщений.
- Ограничьте частоту публикаций до 5 000 оп/с на экземпляр.
Ограничения и альтернативы
Потеря сообщений при реконнекте
Подписчик, отключившийся на время, не получает пропущенные сообщения. Для критичных уведомлений — 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 недель после сдачи.
| Этап | Срок |
|---|---|
| Аналитика и проектирование | 1–2 дня |
| Настройка Redis и Pub/Sub | 1 день |
| Интеграция с бэкендом | 1–2 дня |
| Подключение WebSocket | 1 день |
| Тестирование и отладка | 1–2 дня |
| Итого | от 4 до 6 дней |
Мы работаем с Redis более 6 лет, реализовали 15+ проектов с Pub/Sub для клиентов из e-commerce и fintech. Используем production-конфигурации с Sentinel и Cluster, гарантируем отказоустойчивость. Закажите настройку Redis Pub/Sub для вашего проекта — получите консультацию за 1 день. Обращайтесь к нам для внедрения и масштабирования.