Live Chat на сайте: WebSocket, история, файлы, push

Реализация Live Chat на сайте

Разработка чата реального времени — задача, где архитектурные решения решают всё. Например, выбор REST вместо WebSocket при 100+ одновременных пользователях приводит к задержкам и избыточному трафику. Мы реализовали более 20 чат-систем для разных проектов — от внутренней поддержки до масштабных продакшн-решений с нагрузкой до 10 000 соединений на инстансе. Чат реального времени не только улучшает пользовательский опыт, но и снижает нагрузку на службу поддержки, позволяя обрабатывать запросы в 3-4 раза быстрее.

Полноценный чат — это не просто WebSocket с текстом. Сюда входят история сообщений, индикатор печати, статусы прочтения, поддержка файлов, оптимистичные обновления UI и push-уведомления. Каждый элемент требует отдельного решения. Рассмотрим ключевые компоненты на примере стека Socket.IO, React и Zustand.

Почему WebSocket — стандарт для live-чата?

WebSocket обеспечивает двунаправленную связь с минимальной задержкой. В отличие от long-polling, он потребляет на 90% меньше трафика и не блокирует соединение. Протокол WebSocket описан в стандарте RFC 6455. Для масштабирования используем Redis-адаптер — все инстансы сервера синхронизируют комнаты через pub/sub. Это позволяет обрабатывать десятки тысяч параллельных сессий. WebSocket лучше SSE в 10 раз по задержке: при типичной реализации время отклика составляет < 50 мс против 200–500 мс у SSE.

Структура данных сообщений

interface ChatRoom {
  id:           string;
  type:         'direct' | 'group' | 'support';
  participants: string[];    // userIds
  name?:        string;      // для групп
  lastMessage?: Message;
  unreadCount:  number;
}

interface Message {
  id:           string;
  roomId:       string;
  senderId:     string;
  type:         'text' | 'image' | 'file' | 'system';
  content:      string;
  attachments?: Attachment[];
  replyTo?:     string;       // id родительского сообщения
  editedAt?:    Date;
  deletedAt?:   Date;
  status:       'sending' | 'sent' | 'delivered' | 'read';
  createdAt:    Date;
}

interface Attachment {
  id:       string;
  type:     'image' | 'file';
  url:      string;
  name:     string;
  size:     number;
  mimeType: string;
}

Серверная часть на Socket.IO

// server/chat.ts
import { Server, Socket } from 'socket.io';
import { db } from './db';
import { redisAdapter } from '@socket.io/redis-adapter';

export function initChat(io: Server) {
  io.on('connection', async (socket: Socket) => {
    const userId = socket.data.userId;

    // Присоединение ко всем комнатам пользователя при подключении
    const rooms = await db.chatRoom.findMany({
      where: { participants: { has: userId } },
      select: { id: true },
    });
    rooms.forEach(({ id }) => socket.join(`room:${id}`));

    // Отправка сообщения
    socket.on('message:send', async (payload: {
      roomId:    string;
      content:   string;
      type:      'text' | 'image' | 'file';
      replyTo?:  string;
      clientId:  string; // временный id для оптимистичного обновления
    }, ack) => {
      // Проверяем доступ
      const room = await db.chatRoom.findFirst({
        where: { id: payload.roomId, participants: { has: userId } },
      });
      if (!room) return ack({ error: 'Access denied' });

      const message = await db.message.create({
        data: {
          roomId:    payload.roomId,
          senderId:  userId,
          type:      payload.type,
          content:   payload.content,
          replyToId: payload.replyTo,
          status:    'sent',
        },
      });

      // Broadcast в комнату
      io.to(`room:${payload.roomId}`).emit('message:new', message);

      // ACK отправителю с серверным id
      ack({ ok: true, message, clientId: payload.clientId });
    });

    // Typing indicator
    socket.on('typing:start', ({ roomId }) => {
      socket.to(`room:${roomId}`).emit('typing:update', {
        userId,
        roomId,
        isTyping: true,
      });
    });

    socket.on('typing:stop', ({ roomId }) => {
      socket.to(`room:${roomId}`).emit('typing:update', {
        userId,
        roomId,
        isTyping: false,
      });
    });

    // Прочтение сообщений
    socket.on('messages:read', async ({ roomId, upToMessageId }) => {
      await db.messageRead.upsert({
        where:  { userId_roomId: { userId, roomId } },
        update: { lastReadMessageId: upToMessageId, readAt: new Date() },
        create: { userId, roomId, lastReadMessageId: upToMessageId, readAt: new Date() },
      });

      socket.to(`room:${roomId}`).emit('messages:read:update', {
        userId,
        roomId,
        upToMessageId,
      });
    });

    // История сообщений (пагинация курсором)
    socket.on('messages:load', async ({ roomId, before, limit = 50 }, ack) => {
      const messages = await db.message.findMany({
        where: {
          roomId,
          ...(before ? { createdAt: { lt: new Date(before) } } : {}),
          deletedAt: null,
        },
        orderBy: { createdAt: 'desc' },
        take: limit + 1,
        include: { sender: { select: { id: true, name: true, avatar: true } } },
      });

      ack({
        messages:   messages.slice(0, limit).reverse(),
        hasMore:    messages.length > limit,
        nextCursor: messages.length > limit
          ? messages[limit - 1].createdAt.toISOString()
          : null,
      });
    });
  });
}

Клиентская реализация

Как работают оптимистичные обновления?

Сообщение отображается мгновенно, не дожидаясь сервера. При получении ACK — заменяется реальным объектом:

// store/chat.ts (Zustand)
interface ChatStore {
  messages:    Map<string, Message[]>;
  pendingIds:  Map<string, string>; // clientId -> roomId
  addOptimistic: (roomId: string, content: string) => string;
  confirmMessage: (clientId: string, serverMessage: Message) => void;
  failMessage:   (clientId: string) => void;
}

const useChatStore = create<ChatStore>((set, get) => ({
  messages:   new Map(),
  pendingIds: new Map(),

  addOptimistic(roomId, content) {
    const clientId = `pending-${Date.now()}-${Math.random()}`;
    const optimistic: Message = {
      id:        clientId,
      roomId,
      senderId:  currentUserId,
      type:      'text',
      content,
      status:    'sending',
      createdAt: new Date(),
    };

    set((s) => {
      const msgs = [...(s.messages.get(roomId) ?? []), optimistic];
      s.messages.set(roomId, msgs);
      s.pendingIds.set(clientId, roomId);
      return { messages: new Map(s.messages) };
    });

    return clientId;
  },

  confirmMessage(clientId, serverMessage) {
    set((s) => {
      const roomId = s.pendingIds.get(clientId)!;
      const msgs = s.messages.get(roomId) ?? [];
      const idx = msgs.findIndex((m) => m.id === clientId);
      if (idx !== -1) msgs[idx] = { ...serverMessage, status: 'sent' };
      s.pendingIds.delete(clientId);
      return { messages: new Map(s.messages) };
    });
  },
}));

// Отправка с оптимистичным обновлением
async function sendMessage(roomId: string, content: string) {
  const clientId = useChatStore.getState().addOptimistic(roomId, content);

  socket.emit('message:send', { roomId, content, type: 'text', clientId },
    (response: { ok: boolean; message?: Message; clientId: string }) => {
      if (response.ok) {
        useChatStore.getState().confirmMessage(clientId, response.message!);
      } else {
        useChatStore.getState().failMessage(clientId);
      }
    }
  );
}

Как реализовать индикатор печати и push-уведомления?

// В компоненте ввода
const typingTimeout = useRef<ReturnType<typeof setTimeout>>();

function handleInput(value: string) {
  setDraft(value);

  socket.emit('typing:start', { roomId });

  clearTimeout(typingTimeout.current);
  typingTimeout.current = setTimeout(() => {
    socket.emit('typing:stop', { roomId });
  }, 2000);
}

// Отображение
const [typingUsers, setTypingUsers] = useState<Set<string>>(new Set());

socket.on('typing:update', ({ userId, isTyping }) => {
  setTypingUsers((prev) => {
    const next = new Set(prev);
    isTyping ? next.add(userId) : next.delete(userId);
    return next;
  });
});

// UI
{typingUsers.size > 0 && (
  <div className="typing-indicator">
    <span>{getUserNames(typingUsers)} печатает...</span>
    <BouncingDots />
  </div>
)}

// Push-уведомления для фоновых вкладок (service-worker.ts)
self.addEventListener('push', (event: PushEvent) => {
  const data = event.data?.json();
  event.waitUntil(
    self.registration.showNotification(data.senderName, {
      body:  data.content,
      icon:  data.senderAvatar,
      badge: '/badge.png',
      data:  { roomId: data.roomId, url: `/chat/${data.roomId}` },
    })
  );
});

self.addEventListener('notificationclick', (event: NotificationEvent) => {
  event.notification.close();
  event.waitUntil(
    clients.openWindow(event.notification.data.url)
  );
});

Web Push API позволяет доставлять уведомления даже при закрытом приложении.

Загрузка файлов через presigned URLs

Файлы не идут через WebSocket — сначала загружаются на S3/MinIO, затем URL передаётся в сообщении:

async function sendFile(roomId: string, file: File) {
  // Загрузка через presigned URL
  const { uploadUrl, fileUrl } = await api.post('/chat/upload-url', {
    filename:  file.name,
    mimeType:  file.type,
    size:      file.size,
  });

  await fetch(uploadUrl, {
    method:  'PUT',
    body:    file,
    headers: { 'Content-Type': file.type },
  });

  const clientId = useChatStore.getState().addOptimistic(roomId, file.name);

  socket.emit('message:send', {
    roomId,
    type:    'file',
    content: file.name,
    clientId,
    attachment: { url: fileUrl, name: file.name, size: file.size, mimeType: file.type },
  }, (response) => {
    if (response.ok) {
      useChatStore.getState().confirmMessage(clientId, response.message!);
    }
  });
}

Сравнение WebSocket, SSE и Long Polling

WebSocket даёт минимальную задержку и полную гибкость. Для чата это выбор номер один. В одном из проектов клиент жаловался на задержки при 500 одновременных операторах. Мы перешли с long-polling на WebSocket, и время отклика снизилось с 2 секунд до 50 мс.

Что входит в работу

Каждый проект завершается передачей:

• Исходный код серверной и клиентской частей (TypeScript, React, Zustand).
• Docker Compose-файлы для быстрого развёртывания.
• Документация всех событий и API.
• Инструкция по настройке и деплою.
• Техническая поддержка в течение 30 дней после сдачи.
• Обучение команды заказчика работе с системой.

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

Этапы разработки

1. Аналитика — выбор протокола, оценка нагрузки, профилирование.
2. Проектирование — схема БД, комнаты, события, схема API.
3. Реализация — серверный и клиентский код, интеграция с хранилищем.
4. Тестирование — нагрузочное тестирование (k6), проверка reconnect, edge-кейсы (пустые комнаты, вложения).
5. Деплой — настройка Docker, Nginx, Redis, Web Push subscriptions.

Результат и стоимость

• Исходный код серверной и клиентской частей.
• Docker Compose для быстрого запуска.
• Документация API (событий).
• Инструкция по развёртыванию.
• Техническая поддержка 30 дней после сдачи.

Базовый чат (текст, история, присутствие) — 5–7 дней. Полная реализация с файлами, push-уведомлениями, read receipts и поиском — 2–3 недели. Стоимость разработки базового чата начинается от 150 000 рублей, полная версия — от 300 000 рублей. Обращайтесь для точной оценки — мы подготовим смету за 1–2 дня. Закажите разработку чата с гарантией качества — свяжитесь с нами, чтобы обсудить ваш проект.

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

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