Интеграция Centrifugo: real-time сообщения на сайте

Real-time доставка без задержек

Представьте: вы запустили интернет-магазин, и клиенты жалуются, что уведомления о статусе заказа приходят с опозданием на 5–10 минут. Или админы не видят новые сообщения в чате поддержки, пока не перезагрузят страницу. Классический polling на AJAX убивает сервер и батарею мобильных устройств. Решение — Centrifugo, self-hosted real-time сервер на Go, который снижает нагрузку на бэкенд и экономит инфраструктурные затраты. Мы интегрировали его в 50+ проектах и гарантируем: после нашей настройки сообщения доставляются за <100 мс (TTFB), нагрузка на бэкенд падает в 10 раз, а пользователи забывают про F5. Экономия на инфраструктуре достигает 40% по сравнению с облачными сервисами. Свяжитесь с нами, чтобы оценить выгоду для вашего проекта.

Почему Centrifugo, а не Socket.IO или Pusher?

Centrifugo написан на Go, потребляет минимум ресурсов — один инстанс на 2 vCPU держит 20 000+ WebSocket-соединений. Socket.IO после 1 000 клиентов начинает тормозить и жрать память. Pusher/Ablity — платные, с лимитами по объёму сообщений и каналам. Centrifugo бесплатен, весь код у вас на сервере, никаких лимитов. Плюс совместимость с любым бэкендом через HTTP API или gRPC.

Как Centrifugo масштабируется под нагрузкой?

Centrifugo горизонтально масштабируется с помощью Redis Pub/Sub: добавление нового узла автоматически распределяет каналы. При отказе одного инстанса соединения перераспределяются. Мы настраиваем кластер для проектов с 50 000+ одновременных подключений, обеспечивая задержку доставки <100 мс.

Что мы делаем в рамках услуги

Архитектура интеграции

Ваш бэкенд (Laravel, Node.js, Django, Go — любой) │── HTTP API → Centrifugo (публикация) │── gRPC API → Centrifugo │ Клиент (браузер) ◄── WebSocket ──► Centrifugo 

Установка через Docker

# docker-compose.yml services: centrifugo: image: centrifugo/centrifugo:v5 command: centrifugo -c /centrifugo/config.json ports: - "8000:8000" volumes: - ./centrifugo-config.json:/centrifugo/config.json 

// centrifugo-config.json { "token_hmac_secret_key": "your-secret-key", "api_key": "your-api-key", "admin": true, "admin_password": "admin-password", "allowed_origins": ["https://example.com"], "namespaces": [ { "name": "notifications", "subscribe_for_client": false, "history_size": 100, "history_ttl": "24h" }, { "name": "chat", "presence": true, "join_leave": true, "history_size": 500, "history_ttl": "1h" } ] } 

Сервер: генерация JWT и публикация

import jwt from 'jsonwebtoken'; import axios from 'axios'; // Токен для клиента function generateCentrifugoToken(userId: string): string { return jwt.sign( { sub: userId, exp: Math.floor(Date.now() / 1000) + 3600 }, process.env.CENTRIFUGO_SECRET, { algorithm: 'HS256' } ); } // Публикация сообщения через HTTP API async function publishMessage(channel: string, data: unknown): Promise<void> { await axios.post(`${process.env.CENTRIFUGO_URL}/api/publish`, { channel, data }, { headers: { 'Authorization': `apikey ${process.env.CENTRIFUGO_API_KEY}`, 'Content-Type': 'application/json' } }); } // Отправить уведомление пользователю await publishMessage(`notifications#${userId}`, { type: 'order_shipped', orderId: '12345', message: 'Ваш заказ отправлен' }); // Batch publish await axios.post(`${process.env.CENTRIFUGO_URL}/api/batch`, { commands: userIds.map(id => ({ publish: { channel: `notifications#${id}`, data: notification } })) }); 

Клиент (JavaScript)

import { Centrifuge } from 'centrifuge'; const centrifuge = new Centrifuge(process.env.NEXT_PUBLIC_CENTRIFUGO_URL, { token: await fetchCentrifugoToken(), // от вашего бэкенда debug: process.env.NODE_ENV === 'development' }); centrifuge.on('connect', (ctx) => { console.log('Connected to Centrifugo', ctx.transport); }); centrifuge.on('disconnect', (ctx) => { console.log('Disconnected', ctx.reason); }); // Подписка на персональные уведомления const sub = centrifuge.newSubscription(`notifications#${userId}`, { getToken: async (ctx) => { // Получить subscription токен для private канала const resp = await fetch('/api/centrifugo/subscription-token', { method: 'POST', body: JSON.stringify({ channel: ctx.channel }) }); return (await resp.json()).token; } }); sub.on('publication', (ctx) => { const notification = ctx.data; showNotification(notification.message); }); sub.on('subscribing', (ctx) => console.log('Subscribing...')); sub.on('subscribed', (ctx) => console.log('Subscribed')); sub.subscribe(); centrifuge.connect(); 

Presence — онлайн-статусы

Для отслеживания онлайн-статусов используется метод presence(), который возвращает список активных клиентов. Например, для документа в совместном редактировании: centrifuge.subscription('chat:doc-123').presence() возвращает объект с клиентами. Подписка на события join и leave обновляет список в реальном времени.

Как обеспечить безопасность real-time каналов?

Все соединения выполняются через WSS (WebSocket over HTTPS). Для доступа к каналам требуются JWT-токены: connect-токен для подключения к серверу, subscription-токен для подписки на private каналы. Токены имеют ограниченный срок жизни (обычно 1 час) и автоматически обновляются на клиенте. Для администраторских каналов мы добавляем проверку прав на стороне бэкенда при выдаче subscription-токена.

Как мы внедряем Centrifugo: процесс работы

1. Аналитика — выявляем сценарии real-time: уведомления, чат, лента, совместное редактирование. Определяем нагрузку: сколько соединений, частота публикаций, размер сообщений.
2. Проектирование — выбираем namespace, настраиваем каналы (personal, room, admin), продумываем модель разрешений. Проектируем схему JWT и subscription-токенов.
3. Установка и конфигурация — разворачиваем Centrifugo в Docker, настраиваем переменные окружения, SSL-сертификаты (WSS), Redis для кластеризации.
4. Интеграция с бэкендом — пишем модуль публикации: отправка уведомлений, batch-публикации, генерация токенов. Тестируем N+1 запросы.
5. Интеграция с фронтендом — подключаем SDK, реализуем подписки, обработку событий, переподключение при обрыве.
6. Тестирование — нагрузочные тесты, проверка приватных каналов, отказоустойчивость, замеры TTFB и LCP.
7. Деплой и мониторинг — настраиваем мониторинг метрик (количество соединений, задержки, ошибки), алерты, резервное копирование конфигов.

Ориентировочные сроки

Стоимость варьируется в зависимости от сложности — мы рассчитываем её индивидуально. Гарантируем фиксацию сроков и цены.

Типичные ошибки и как мы их избегаем

• Слишком длинные JWT — ставим срок жизни 1 час, автоматическое обновление на клиенте.
• Отсутствие backpressure — настраиваем лимиты публикаций и конфигурируем TTL истории.
• Путаница с токенами — чётко разделяем connect token и subscription token, используем разные секреты.
• Забыли про CORS — разрешаем только ваши домены в allowed_origins.

Сравнение: Centrifugo vs облачные сервисы

Свяжитесь с нами для консультации — мы оценим ваш проект за 1 день. Закажите интеграцию Centrifugo прямо сейчас и получите стабильное real-time за неделю.