Преодоление хаоса уведомлений: приручаем Server-Sent Events для эффективного серверного пуша

Категория: Статьи • 26 June 2025 • 4 мин чтения

Многие запускаются с WebSockets для любого сценария требующего реалтайма, часто усложняя успешный проект. Наблюдаю как инженеры создают избыточные решения там, где простые технологии вроде Server-Sent Events (SSE) решали бы вопрос эффективнее и устойчивее. Рассмотрим альтернативу, которая может изменить ваш подход к одностороннему потоку данных.

Боль реальных приложений

Представьте SaaS панель с финансовыми оповещениями. Клиентам нужны мгновенные уведомления о критических изменениях котировок или системных событиях. Требования:

  • Минимальная задержка (<1с)
  • Независимость от пользовательского взаимодействия
  • Стабильность при часах работы
  • Масштабируемость до десяти тысяч соединений на инстанс

Первое решение? Кажется, WebSocket. Но тогда приходим к этому:

javascript
// Классический подход с WebSocket
const wss = new WebSocket.Server({ port: 8080 });
const connections = new Set();

wss.on('connection', (ws) => {
  connections.add(ws);
  ws.on('close', () => connections.delete(ws));
});

function broadcastNotification(data) {
  connections.forEach(conn => {
    if (conn.readyState === WebSocket.OPEN) {
      conn.send(JSON.stringify(data));
    }
  });
}

Проблемы начинаются на уровне инфраструктуры: постоянное соединение требует балансировщиков TCP, обработки падения соединения, health checks. Для монотонного потока данных клиент → сервер это overkill.

SSE: Недооцененный инструмент

Server-Sent Events – итог HTTP спецификации для унидональной связи. Техническая суть крайне элегантна:

  1. Клиент создает долгоживущий HTTP запрос
  2. Сервер отправляет бесконечный поток с заголовком Content-Type: text/event-stream
  3. Каждое сообщение следует формату data: {Content}\n\n

Клиентская подписка:

javascript
const eventSource = new EventSource('/api/notifications');

eventSource.onmessage = (event) => {
  const notification = JSON.parse(event.data);
  displayNotification(notification);
};

eventSource.addEventListener('stock-alert', (event) => {
  handleStockAlert(JSON.parse(event.data));
});

Серверная имплементация (Node.js):

javascript
import { createServer } from 'http';
import { EventEmitter } from 'events';

const notificationBus = new EventEmitter();

createServer((req, res) => {
  if (req.url === '/api/notifications') {
    res.writeHead(200, {
      'Content-Type': 'text/event-stream',
      'Cache-Control': 'no-cache',
      'Connection': 'keep-alive'
    });

    const sendEvent = (event, data) => {
      res.write(`event: ${event}\n`);
      res.write(`data: ${JSON.stringify(data)}\n\n`);
    };

    notificationBus.on('message', sendEvent);
    
    req.on('close', () => {
      notificationBus.off('message', sendEvent);
    });
  }
}).listen(3000);

// Триггер события
notificationBus.emit('message', 'stock-alert', { symbol: 'AAPL', delta: -5.2 });

Протокол справляется со всем необходимым: переподключение автоматически контролируется браузером (retry: 3000\n в сообщении), доставка обычно появляется ниже 500 мс, работая на базовом соединении HTTP без дополнительных сложностей.

Где происходит волшебство на практике

Масштабируемость через pub/sub: Подключаем Redis для распределенной экосистемы:

javascript
import { createClient } from 'redis';

const redisSub = createClient();
await redisSub.connect();

redisSub.subscribe('notifications', (jsonData) => {
  const { channel, event, payload } = JSON.parse(jsonData);
  notificationBus.emit(channel, event, payload);
});

// Микросервис генерации оповещений
const redisPub = createClient();
await redisPub.connect();

function publishNotification(event, data) {
  redisPub.publish('notifications', JSON.stringify({
    channel: 'global',
    event,
    payload: data
  }));
}

Архитектура справляется с горизонтальным масштабированием, где каждый серверный инстанс просто является подписчиком основного канала уведомлений.

Перевод в производственно-готовое состояние

Недостаточно просто открыть соединение. Промышленное использование требует:

  1. Аутентификация через cookies: Стандартный EventSource передает credentials. Не используйте Basic Auth в URL.
  2. Тонкий контроль переподключения:
javascript
eventSource.onerror = function() {
  if (this.readyState === EventSource.CONNECTING) {
    console.log('Reconnecting...');
  } else {
    console.error('Connection failed');
  }
  this.close(); // Останавливаем запрос
};
setTimeout(() => new EventSource(...), 5000); // Ручное восстановление
  1. Военная защита: Валидация источников через Origin, лимит подключений через токены доступа
  2. Метрики жизненного цикла: Логируйте время жизни соединения, доставку сообщений
rust
// Rust + Axum пример (High-performance backend)
async fn sse_handler(user: AuthenticatedExtractor) -> Sse<impl Stream<Item = Result<Event>>> {
    let stream = watch::channel(Message::default()).1
        .map(|msg| Ok(Event::default().event("update").data(msg.to_json())));

    Sse::new(stream).keep_alive(
        KeepAlive::new()
            .interval(Duration::from_secs(15))
            .text("keep-alive-ping")
    )
}

Почему не использовать переключатель во всю техзону

Всегда появляется критика: "А Kubernetes с роутерами ingress?". Современные прокси (Nginx, Caddy, Cloudflare) прекрасно обрабатывают HTTP/2 для SSE без дополнительных подводных камней.

Затрудненные сценарии:

SSE начинает показывать четкие границы подхода который должен быть выбран по результатам трезвого рассмотрения задачи:

  • Chat applications: нет двойной коммуникации, но можно добавить отдельные HTTP запросы для отправки
  • High-frequency updates (IoT): Один поток на один клиент ограничен для биржевых роботов

Практические решения на каждый проектировочный день

Когда в следующий раз собираете систему уведомлений, конкретно примените это решение:

  1. Анализируйте поток данных: Односторонний или двусторонний?
  2. Протестируйте покрытие SSE:
    • Данная задача поддерживается: системные оповещения, лог-стримы, live dashboards
    • Не относится к сфере платформы: чаты, онлайн игры, аудио/видео конференции
  3. Сократите код инфраструктуры: Уберите прокси для WS, уменьшайте количество серверов поддержки соединения

HTTP/2+ использует единое соединение для всех динамически обновляемых потоков: один порт на множество уникальных клиентов. Автоматический failover создан на уровне браузера — помогает упростить разработку и увеличить демографическую доступность

Второй вывод — масштабируемость по сравнению простых файрволлов значительно вырастает при меньших затратах на вычисления. Мой сервис обработки уведомлений передаёт более 1M событий ежедневно с использованием 5 инстансов и Redis, где WebSockets требовали бы специальный клиентский пул.

Каждый проект должен использовать предельные технологии подходящие границам своего применения без лишней сложности добавленной для имиджа и показателя самоизоляции разработчика. Server-Sent Events — лакончничее и уже готовое решение которое заслуживает выхода из тени исключительных веб сокетов.