Интеграция LiveKit для видеоконференций на сайте с WebRTC

Интеграция LiveKit для видеоконференций на сайте

LiveKit — open-source WebRTC-сервер с архитектурой SFU, обеспечивающий низкую задержку и масштабирование до тысяч участников. Вы получаете полный контроль над данными и интерфейсом, без ограничений по числу участников и скрытых комиссий. Однако на реальных проектах мы сталкиваемся с типичными проблемами: неправильная настройка ICE-серверов, проблемы с NAT и выбор неоптимальной SFU-архитектуры, что приводит к росту задержек до 5–10 секунд. Наш опыт более 50 интеграций WebRTC показывает, что грамотная настройка LiveKit решает эти проблемы на уровне ядра.

Как снизить задержки видеозвонков с помощью LiveKit?

Архитектура SFU (Selective Forwarding Unit) обеспечивает задержку ниже 200 мс даже на слабых каналах. В отличие от Jitsi, LiveKit использует оптимизированные кодеки (VP9, H.264) и адаптивный битрейт. При 50 участниках разница в задержке достигает 3–5 раз в пользу LiveKit. Кроме того, вы не платите лицензионных отчислений: стоимость сервера для 1000 пользователей минимальна.

Как интегрировать LiveKit: кейс образовательной платформы

Недавно мы внедрили LiveKit для клиента — образовательной платформы с 5000 пользователей. Исходная архитектура использовала Jitsi, но после миграции на LiveKit задержка снизилась с 800 мс до 150 мс, а стоимость серверов упала на 40%. Использовали LiveKit Server 1.5 на Docker, бэкенд на Node.js (LiveKit SDK), фронтенд на React 18 с @livekit/components-react.

Установка LiveKit Server

# docker-compose.yml
services:
  livekit:
    image: livekit/livekit-server:latest
    command: --dev
    ports:
      - "7880:7880"
      - "7881:7881"
      - "7882:7882/udp"
    environment:
      LIVEKIT_KEYS: "APIkey: APIsecret"

Для продакшена используйте конфиг с внешним IP и TURN-серверами:

# livekit.yaml
port: 7880
rtc:
  tcp_port: 7881
  udp_port: 7882
  use_external_ip: true
keys:
  APIkey: APIsecret

Как интегрировать LiveKit в React-приложение?

Бэкенд: генерация токенов

import { AccessToken, RoomServiceClient } from 'livekit-server-sdk';

const roomService = new RoomServiceClient(
  process.env.LIVEKIT_URL,
  process.env.LIVEKIT_API_KEY,
  process.env.LIVEKIT_API_SECRET
);

await roomService.createRoom({
  name: `room-${meetingId}`,
  maxParticipants: 50,
  emptyTimeout: 10 * 60
});

function generateToken(roomName: string, participant: Participant): string {
  const at = new AccessToken(
    process.env.LIVEKIT_API_KEY,
    process.env.LIVEKIT_API_SECRET,
    { identity: participant.id, name: participant.name, ttl: '2h' }
  );
  at.addGrant({ roomJoin: true, room: roomName, canPublish: true, canSubscribe: true, canPublishData: true });
  return at.toJwt();
}

app.post('/api/meetings/:id/join', authenticate, async (req, res) => {
  const meeting = await meetingRepo.findById(req.params.id);
  if (!meeting) return res.status(404).json({ error: 'Meeting not found' });
  const token = generateToken(`room-${meeting.id}`, { id: req.user.id, name: req.user.displayName });
  res.json({ token, serverUrl: process.env.LIVEKIT_URL });
});

Клиент (React)

import { LiveKitRoom, VideoConference, RoomAudioRenderer } from '@livekit/components-react';

function VideoRoom({ roomId }) {
  const [token, setToken] = useState(null);
  const [serverUrl, setServerUrl] = useState('');

  useEffect(() => {
    fetch(`/api/meetings/${roomId}/join`, { method: 'POST' })
      .then(r => r.json())
      .then(({ token, serverUrl }) => { setToken(token); setServerUrl(serverUrl); });
  }, [roomId]);

  if (!token) return <div>Подключение...</div>;

  return (
    <LiveKitRoom token={token} serverUrl={serverUrl} connect video audio>
      <VideoConference />
      <RoomAudioRenderer />
    </LiveKitRoom>
  );
}

Это минимальный набор. Для кастомного интерфейса используйте useTracks и GridLayout.

Запись встреч

import { EgressClient, EncodedFileType } from 'livekit-server-sdk';

const egressClient = new EgressClient(
  process.env.LIVEKIT_URL,
  process.env.LIVEKIT_API_KEY,
  process.env.LIVEKIT_API_SECRET
);

const egress = await egressClient.startRoomCompositeEgress(
  `room-${meetingId}`,
  { file: { fileType: EncodedFileType.MP4, s3: { accessKey: process.env.AWS_ACCESS_KEY, secret: process.env.AWS_SECRET, bucket: 'recordings', key: `meetings/${meetingId}/${Date.now()}.mp4` } } }
);

Сравнение LiveKit с альтернативами

LiveKit в 3 раза быстрее Jitsi по задержке и не имеет скрытых затрат.

Как добиться стабильной работы при 1000 участников?

Для 1000+ участников используйте кластеризацию SFU. LiveKit поддерживает горизонтальное масштабирование через Redis и NATS. Настройте TURN-серверы (например, Coturn) для обхода NAT. Важно: выбирайте серверы в нескольких регионах для низкой задержки. Также включите адаптивный битрейт и используйте опцию AdaptiveStream в клиенте.

Возможности LiveKit: сравнение версий

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

Что входит в интеграцию

• Настройка LiveKit Server на вашем или нашем сервере (Docker).
• Разработка бэкенд-модуля для генерации токенов и управления комнатами.
• Интеграция React-компонентов @livekit/components-react с кастомным UI (по желанию).
• Настройка записи через Egress API (S3, MinIO).
• Документация по использованию и поддержка 2 недели после сдачи.
• Гарантия на стабильную работу видеозвонков 30 дней.

Сроки

• Базовая интеграция (сервер + токены + React UI) — от 5 до 10 рабочих дней.
• Расширенная (кастомный UI, запись, админка) — от 15 до 25 рабочих дней.

LiveKit также поддерживает end-to-end шифрование и аутентификацию через JWT. В нашей интеграции мы настраиваем безопасность по умолчанию.

Как заказать интеграцию?

Свяжитесь с нами для бесплатной оценки вашего проекта. Мы проанализируем требования и предложим оптимальное решение. Получите консультацию — напишите в телеграм или на почту. Внедрение LiveKit окупается за счёт снижения затрат на инфраструктуру уже в первый месяц. Закажите интеграцию LiveKit в свой проект уже сегодня.

Разработка систем реального времени: 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).

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