Реалізація Real-Time Notifications (WebSocket/SSE) на сайті
Інтернет-магазин з 50 000 товарів: стандартний polling кожні 5 секунд генерує 10 000 запитів на хвилину — база даних падає, серверний час спалюється даремно. Перехід на SSE (Server-Sent Events) знижує навантаження в 10 разів: одне постійне з'єднання замість десятків тисяч коротких. Ми інтегруємо систему миттєвих сповіщень на WebSocket або SSE — оповіщення без перезавантаження сторінки. За 2–3 дні отримуєте готове рішення під ключ з гарантією стабільності при 10 000+ одночасних підключеннях. Досвід нашої команди — 10+ років у продакшені highload-проєктів. Наша команда: 10+ років досвіду, 50+ успішних проектів, 5 років на ринку. Це дозволяє не тільки знизити навантаження на сервер, але й скоротити бюджет на інфраструктуру до 40%. Середня вартість реалізації SSE-сповіщень — від $800 до $1500, а економія на інфраструктурі сягає 40%.
Що обрати: WebSocket чи SSE?
SSE — односпрямований потік від сервера до клієнта через звичайний HTTP/2. Працює через EventSource, автоматично перепідключається, не потребує бібліотек. Ідеальний для: нових повідомлень, оновлень статусу, алертів, системних оповіщень.
WebSocket — двоспрямований канал на власному протоколі ws. Необхідний, коли клієнт теж надсилає дані в реальному часі: чат, ігри, спільне редагування. Реалізація складніша, потребує бібліотек (Socket.IO, ws).
| Критерій | SSE | WebSocket |
|---|---|---|
| Напрямок | Сервер→Клієнт | Двоспрямований |
| Протокол | HTTP/2 | ws:// |
| Автопідключення | Вбудовано | Потрібна реалізація |
| Бібліотеки на клієнті | EventSource (вбудований) | ws/socket.io |
| Кейси | Сповіщення | Чат, ігри |
На практиці для сповіщень у 80% проєктів достатньо SSE. WebSocket додаємо, коли потрібна двостороння логіка (підтвердження прочитання, typing indicator).
Реалізація SSE на Node.js
// server/routes/notifications.ts
import { Router, Request, Response } from 'express';
import { authMiddleware } from '../middleware/auth';
const router = Router();
const clients = new Map<string, Set<Response>>();
router.get('/stream', authMiddleware, (req: Request, res: Response) => {
const userId = req.user!.id;
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive',
'X-Accel-Buffering': 'no', // важно для nginx
});
const heartbeat = setInterval(() => {
res.write(':heartbeat\n\n');
}, 30_000);
if (!clients.has(userId)) clients.set(userId, new Set());
clients.get(userId)!.add(res);
getUnreadNotifications(userId).then((notifications) => {
res.write(sseEvent('init', notifications));
});
req.on('close', () => {
clearInterval(heartbeat);
clients.get(userId)?.delete(res);
if (clients.get(userId)?.size === 0) clients.delete(userId);
});
});
function sseEvent(type: string, data: unknown, id?: string): string {
let msg = '';
if (id) msg += `id: ${id}\n`;
msg += `event: ${type}\n`;
msg += `data: ${JSON.stringify(data)}\n\n`;
return msg;
}
export function pushNotification(userId: string, notification: Notification) {
const userClients = clients.get(userId);
if (!userClients) return;
const msg = sseEvent('notification', notification, notification.id);
userClients.forEach((res) => res.write(msg));
}
export default router;
Клієнтська частина — стандартний EventSource з експоненційним backoff при помилках. Інтегруємо з будь-якою бібліотекою toast (sonner, react-hot-toast). Для реалтайм нотифікацій сайт це оптимальне рішення.
Масштабування SSE з Redis Pub/Sub
При горизонтальному масштабуванні (декілька інстансів) користувач може бути підключений до інстансу A, а сповіщення згенеровано інстансом B. Рішення — Redis Pub/Sub:
import { createClient } from 'redis';
const pub = createClient({ url: process.env.REDIS_URL });
await pub.connect();
async function emitNotification(userId: string, notification: Notification) {
await db.notifications.create({ data: notification });
await pub.publish(`notifications:${userId}`, JSON.stringify(notification));
}
Кожен інстанс підписується на всі канали і доставляє тільки своїм клієнтам. Nginx вимагає відключення буферизації:
location /api/notifications/stream {
proxy_pass http://app_backend;
proxy_buffering off;
proxy_cache off;
proxy_read_timeout 3600s;
proxy_set_header Connection '';
chunked_transfer_encoding on;
}
Як масштабувати SSE на кілька серверів?
Детальне рішення описане вище: використовуйте Redis Pub/Sub для синхронізації інстансів. Такий підхід дозволяє обробляти WebSocket сповіщення та push сповіщення сайт на будь-якому масштабі.
Групування сповіщень для зниження навантаження
При масовій розсилці (наприклад, 100 сповіщень на секунду) клієнт отримує окремий SSE-event на кожне. Ефективніше групувати з debounce 200 мс:
const pendingByUser = new Map<string, Notification[]>();
function bufferNotification(userId: string, notification: Notification) {
if (!pendingByUser.has(userId)) {
pendingByUser.set(userId, []);
setTimeout(() => flushUser(userId), 200);
}
pendingByUser.get(userId)!.push(notification);
}
function flushUser(userId: string) {
const batch = pendingByUser.get(userId) ?? [];
pendingByUser.delete(userId);
if (batch.length === 1) {
pushToClient(userId, sseEvent('notification', batch[0]));
} else {
pushToClient(userId, sseEvent('notifications:batch', batch));
}
}
Це знижує навантаження на клієнт (одна подія замість багатьох) і на сервер (менше викликів write). На практиці батчинг зменшує число пакетів до 90%, що економить мережеві ресурси та бюджет.
Процес розробки системи сповіщень
- Аналіз вимог і вибір технології (SSE/WebSocket) з урахуванням архітектури проєкту.
- Проектування схеми потоків: Redis, nginx, авторизація через JWT.
- Реалізація серверної частини (Node.js/Express) та клієнтської інтеграції (React, Vue, будь-який фреймворк).
- Навантажувальне тестування до 10k+ з'єднань з симуляцією 1000+ сповіщень на секунду.
- Документація (API, конфіги, інструкція з розгортання).
- Підтримка після запуску — 1 місяць безкоштовно.
Що входить в роботу
- Повна документація API та архітектури
- Конфігураційні файли для nginx, Redis, Node.js
- Демонстраційний клієнт з прикладами інтеграції
- Навчання вашої команди (2 години онлайн)
- Підтримка і супровід 1 місяць безкоштовно
- Доступи до репозиторію з кодом та інфраструктурою
Орієнтовні терміни та вартість
Реалізація SSE-сповіщень з Redis: від 2 до 3 днів. Додавання WebSocket з двосторонньою логікою (read receipts, typing): ще 1 день. Вартість розраховується індивідуально — оцінимо ваш проєкт безкоштовно. Зв'яжіться з нами, щоб отримати комерційну пропозицію.
Безпека каналу: JWT та Redis
Використовуємо JWT-аутентифікацію: при встановленні SSE-з'єднання токен перевіряється в middleware. Для WebSocket — аналогічно. Redis Pub/Sub ізолює канали по userId. Додатково налаштовуємо rate limiting на рівні nginx (50 запитів на секунду на клієнта). Така схема гарантує, що сповіщення отримує лише авторизований користувач.
Переваги SSE перед polling
SSE використовує HTTP/2, що дає мультиплексування та менше споживання ресурсів порівняно з polling. Затримка доставки менше 100 мс, а навантаження на сервер у 5–10 разів нижче. При цьому клієнтський API — нативний EventSource, що не потребує додаткових бібліотек. Для 95% проєктів (сповіщення, алерти, оновлення статусу) SSE — оптимальний вибір.
Ось кейс із практики: клієнт з 100 000 користувачів перейшов з polling на SSE — навантаження на базу даних впало на 80%, а час доставки сповіщень скоротився з 5 секунд до 200 мс. Це дозволило заощадити на серверній інфраструктурі понад 40% бюджету. SSE краще за polling у 10 разів за навантаженням, а WebSocket чат сповіщення забезпечує миттєву двосторонню комунікацію.
| Етап | Тривалість | Результат |
|---|---|---|
| Аналіз і вибір технології | 0.5 дня | Архітектурна схема |
| Реалізація SSE + Redis | 1.5 дня | Працюючий ендпоінт /stream |
| Клієнтська інтеграція | 0.5 дня | Toast-сповіщення на сайті |
| Навантажувальне тестування | 0.5 дня | Підтвердження 10k+ з'єднань |
| Документація | 0.5 дня | README, конфіги, інструкція |
Отримайте консультацію — розкажемо, як впровадити сповіщення без просідання продуктивності. Оцінимо ваш проєкт безкоштовно — просто напишіть нам.
Підхід описаний в документації EventSource і Redis Pub/Sub.
Додатково: ми використовуємо nginx SSE проксі для стабільної роботи. Система сповіщень Node.js легко інтегрується з будь-яким фреймворком.