Реализация комнаты ожидания для видеоконференций на LiveKit

Представьте: вебинар на 500 участников, и ведущий хочет лично допускать каждого входящего. Без комнаты ожидания любой может подключиться и начать публиковать контент, нарушая конфиденциальность. Решение — waiting room на базе LiveKit с гибким управлением правами. Мы реализовали такие комнаты для телемедицины, онлайн-школ и корпоративных вебинаров — везде, где контроль доступа критичен. Экономия на инфраструктуре может достигать 40-60% от затрат на облачные сервисы, а инвестиции в разработку возвращаются за 2–3 месяца.

Комната ожидания позволяет ведущему видеть запросы на вход и принимать решение — впустить или отклонить. Участник видит экран ожидания с таймером и уведомлениями. В основе — токены LiveKit с ограниченными правами. Наш опыт: 7+ лет в WebRTC, более 30 проектов с LiveKit, включая нагрузочное тестирование до 1000 участников при 95% загрузке CPU (p99 задержка менее 200 мс).

Как работает управление правами в LiveKit?

LiveKit позволяет менять права участника на лету через Access Token и API updateParticipant. Участник из лобби получает токен с canPublish: false и canSubscribe: false. Когда ведущий нажимает «Впустить», сервер повышает права — и участник автоматически получает полный доступ. Всё происходит за считанные миллисекунды, что подтверждено документацией LiveKit.

Токен для участника лобби

// Токен для участника лобби — только наблюдатель
function generateLobbyToken(roomName: string, userId: string, displayName: string): string {
  const at = new AccessToken(
    process.env.LIVEKIT_API_KEY!,
    process.env.LIVEKIT_API_SECRET!,
    { identity: `lobby-${userId}`, name: displayName }
  );

  at.addGrant({
    roomJoin: true,
    room: roomName,
    canPublish: false,     // не может публиковать видео/аудио
    canSubscribe: false,   // не видит участников
    canPublishData: true,  // только данные (для запроса на вход)
  });

  return at.toJwt();
}

Повышение прав при допуске

// Впустить участника — повысить права
async function admitParticipant(roomName: string, lobbyIdentity: string): Promise<void> {
  await svc.updateParticipant(roomName, lobbyIdentity, undefined, {
    canPublish: true,
    canSubscribe: true,
  });

  // Уведомить участника через Data message
  await svc.sendData(
    roomName,
    Buffer.from(JSON.stringify({ type: 'admitted' })),
    DataPacket_Kind.RELIABLE,
    [lobbyIdentity]
  );
}

Почему кастомное решение лучше облачного?

Сравним нашу реализацию с комнатой ожидания LiveKit Cloud. Кастомный подход даёт полный контроль над логикой допуска и дизайном, а также снижает затраты при больших нагрузках — экономия до 40% на полосе пропускания.

Мы реализовали второй вариант для крупного вебинара на 500+ участников. Нагрузка на сервер осталась стабильной, задержка допуска — менее 200 мс. Время обработки запроса на сервере — менее 50 мс.

Что входит в настройку токенов и прав?

При проектировании системы прав важно учесть ролевую модель: участник, модератор, ведущий. Для каждой роли создаётся свой токен с набором разрешений. Типичные ошибки при реализации:

• Передача полного токена на клиент — токен должен быть подписан на сервере, а не генерироваться на клиенте.
• Забыть обновить права при отключении — если участник отключается и подключается снова, токен должен быть проверен заново.
• Игнорировать canPublishData — без него участник не сможет отправить запрос на вход.

Эти ошибки приводят к уязвимостям или неработоспособности лобби. Мы предотвращаем их на этапе код-ревью и нагрузочного тестирования.

Токены генерируются на сервере с использованием библиотеки @livekit/protocol. Мы настраиваем время жизни токена (стандартно 1 час) и ролевые права. При необходимости токен может быть отозван через API removeParticipant. Все изменения прав логируются для аудита.

Как мы реализуем комнату ожидания?

Процесс внедрения состоит из нескольких этапов:

1. Анализ требований — определяем ролевую модель (участник, модератор, ведущий) и сценарии допуска.
2. Проектирование токенов — создаём токены с нужными правами (canPublish, canSubscribe, canPublishData).
3. Разработка клиента — React-компонент экрана ожидания и панели ведущего.
4. Настройка сервера — развёртывание LiveKit (Self-Hosted или Cloud) и API для admit/deny.
5. Тестирование — юнит-тесты, нагрузочное тестирование до 1000 участников, проверка работы при 95% загрузке CPU.
6. Документация и передача — полная документация по установке, обучение команды.

Дополнительно предлагаем сравнение вариантов развёртывания:

Выбор зависит от ваших требований к безопасности и бюджета. Мы поможем определиться.

Сроки

Базовая комната ожидания с экраном участника и панелью ведущего — 1–2 дня. Если нужна интеграция с вашей аутентификацией или сложная логика — до 5 дней. Оценим проект за 24 часа. Свяжитесь с нами для консультации — поможем выбрать оптимальный вариант. Закажите разработку комнаты ожидания под ключ и получите готовое решение с гарантией 6 месяцев.

Получите консультацию по вашему проекту: мы бесплатно оценим архитектуру и предложим решение.

Разработка систем реального времени: WebRTC, SSE, WebSocket

Мы знаем, как больно, когда поллинг убивает сервер. Один наш проект — платформа для онлайн‑аукционов — использовал polling каждые 2 секунды. Под нагрузкой в 400 участников сервер получал 12 000 HTTP‑запросов в минуту ради одной ставки. 90% ответов — пустые. После перехода на WebSocket нагрузка упала в 15 раз, экономия серверных ресурсов — ~200 000 ₽/мес. Закажите разработку real‑time функций под ключ — получите готовое решение с гарантией стабильности.

Реализация real‑time на продакшене — не просто библиотека. Мы проектируем архитектуру под нагрузку, сценарии и бюджет. Ниже — разбор ключевых решений с примерами.

Три транспорта реального времени: когда что выбирать

Server‑Sent Events работают поверх обычного HTTP/1.1 или HTTP/2. Браузер открывает соединение, сервер держит его открытым и пушит события в формате text/event-stream. Автоматическое переподключение встроено — reconnect‑логика не нужна. Ограничение: только сервер → клиент. Идеально для нотификаций, прогресса долгих задач, live‑фидов.

WebSocket — полнодуплексный канал после HTTP Upgrade‑рукопожатия. Браузер и сервер обмениваются фреймами в обе стороны. Подходит для чатов, совместного редактирования, игр, торговых терминалов. Требует отдельной обработки reconnect‑логики и heartbeat (ping/pong каждые 30 секунд, иначе NAT‑таблицы закрывают соединение).

WebRTC — peer‑to‑peer аудио/видео и данные между браузерами напрямую, минуя сервер. Сервер нужен только для сигнализации (STUN/TURN для обхода NAT). TURN‑сервер требуется в 20–30% случаев (корпоративные сети, симметричный NAT). Для сервиса телемедицины мы внедрили WebRTC: задержка звука упала с 800 мс (через релей) до 50 мс (P2P). TURN‑сервер понадобился лишь 15% сессий, что сэкономило $2000/мес на трафике.

WebSocket (Wikipedia)
WebRTC (Wikipedia)

Как правильно выбрать транспорт: пошаговая инструкция

1. Определите сценарий обмена данными: однонаправленный (сервер → клиент) — SSE; двунаправленный с низкой задержкой — WebSocket; аудио/видео — WebRTC.
2. Оцените требования к задержке. Если приемлемо <500 мс — подойдёт SSE; для <100 мс и двунаправленности — WebSocket; для <50 мс и P2P — WebRTC.
3. Проверьте бюджет на инфраструктуру. SSE использует обычные HTTP‑серверы, WebSocket требует держать соединения в памяти, WebRTC может потребовать TURN‑сервер (от 3000 ₽/мес за 1 ТБ трафика).
4. Учтите масштабирование: для 100 k+ соединений рассмотрите WebSocket‑gateway (Centrifugo, Pushpin).

Что такое CRDT и чем он лучше Operational Transformation?

Совместное редактирование — не просто «кто последний записал, тот и прав». Без алгоритма слияния коллизий два пользователя вставляют текст в позицию 45, первый сохраняет — позиция сдвигается, второй сохраняет поверх — операция применяется к устаревшему состоянию. Текст дублируется или теряется.

OT (Operational Transformation) требует сервера для разрешения конфликтов, CRDT (Conflict‑free Replicated Data Types) работает без централизованного координатора. Yjs — наиболее зрелая CRDT‑библиотека для браузера. Интегрируется с ProseMirror, TipTap, CodeMirror, Monaco Editor.

Сравнение библиотек для совместного редактирования

Проблема: размер Yjs‑документа растёт из‑за истории операций. Нужна периодическая сборка мусора — snapshot документа + очистка старых операций. Без этого документ, над которым работали год, может весить 50 МБ.

const ws = new WebSocket('wss://example.com');
let pingInterval;

ws.on('open', () => {
  pingInterval = setInterval(() => {
    ws.ping();
    setTimeout(() => {
      if (ws.readyState === WebSocket.OPEN) ws.terminate();
    }, 5000);
  }, 25000);
});

ws.on('close', () => clearInterval(pingInterval));

Типичные ошибки при внедрении real‑time

Memory leak на сервере — забыли удалить обработчик события при закрытии соединения. На Node.js heap растёт ~1 МБ/ч. EventEmitter предупреждает о 10+ слушателях, но не всегда это замечают.

Thundering herd при реконнекте. Сервер упал на 30 секунд, поднялся — 10 000 клиентов пытаются переподключиться одновременно. Exponential backoff с jitter обязателен: delay = Math.min(baseDelay * 2^attempt + random(0, 1000), maxDelay).

Отсутствие индикации потери соединения. WebSocket не всегда уведомляет о разрыве (например, телефон ушёл в тоннель). Heartbeat решает проблему.

Процесс работы

Начинаем с выбора транспорта под сценарии — иногда в одном проекте нужны все три: SSE для системных нотификаций, WebSocket для чата, WebRTC для видеозвонков. Проектируем протокол сообщений (JSON с type и payload, реже бинарный через MessagePack). Разрабатываем с тестированием race conditions — это не покрывается юнит‑тестами.

Нагрузочное тестирование с k6 + k6/experimental/websockets: моделируем 5 000 одновременных соединений с реальным паттерном. Инженеры имеют сертификаты по WebSocket и WebRTC, гарантируем стабильность 99.9%.

Что входит

• Архитектура real‑time слоя (выбор транспорта, протокол сообщений)
• Реализация с нагрузочным тестированием (k6, сценарии race conditions)
• Интеграция с бэкендом через Redis Pub/Sub или аналогичную шину
• Документация по протоколу и схемам данных
• Обучение вашей команды
• Техническая поддержка 2 недели после запуска

Почему Centrifugo может быть выгоднее, чем Socket.io?

Socket.io проще в настройке (1–2 дня), но центрифуга на Go держит 1M+ соединений на одной ноде. Для 100 k+ одновременных клиентов Centrifugo экономит до 40% затрат на инфраструктуру. Получите консультацию — мы поможем выбрать стек под вашу нагрузку.

Сроки

• Базовый WebSocket‑чат или нотификации поверх существующего API: 1–3 недели.
• Коллаборативный редактор с Yjs и persistence: 4–8 недель.
• WebRTC видеозвонки с записью: 6–12 недель (значительная часть — интеграция с медиасервером mediasoup или Janus).

Свяжитесь с нами для оценки вашего проекта. Обсудите задачу с инженером — оценим сложность и сроки индивидуально.