CRDT/OT синхронізація для застосунків реального часу

Наша компанія займається розробкою, підтримкою та обслуговуванням сайтів будь-якої складності. Від простих односторінкових сайтів до масштабних кластерних систем, побудованих на мікро сервісах. Досвід розробників підтверджено сертифікатами від вендорів.

Розробка та обслуговування будь-яких видів сайтів:

Інформаційні сайти або веб-програми
Сайти візитки, landing page, корпоративні сайти, онлайн каталоги, квіз, промо-сайти, блоги, ресурси новин, інформаційні портали, форуми, агрегатори
Сайти або веб-програми електронної комерції
Інтернет-магазини, B2B-портали, маркетплейси, онлайн-обмінники, кешбек-сайти, біржі, дропшиппінг-платформи, парсери товарів
Веб-програми для управління бізнес-процесами
CRM-системи, ERP-системи, корпоративні портали, системи управління виробництвом, парсери інформації
Сайти або веб-програми електронних послуг
Дошки оголошень, онлайн-школи, онлайн-кінотеатри, конструктори сайтів, портали надання електронних послуг, відеохостинги, тематичні портали

Це лише деякі з технічних типів сайтів, з якими ми працюємо, і кожен із них може мати свої специфічні особливості та функціональність, а також бути адаптованим під конкретні потреби та цілі клієнта.

Послуги, які ми пропонуємо
Показано 1 з 1Усі 2062 послуг
CRDT/OT синхронізація для застосунків реального часу
Складний
~2-4 тижні
Часті запитання

Наші компетенції:

Етапи розробки

Останні роботи

  • image_website-b2b-advance_0.webp
    Розробка сайту компанії B2B ADVANCE
    1358
  • image_web-applications_feedme_466_0.webp
    Розробка веб-додатків для компанії FEEDME
    1250
  • image_websites_belfingroup_462_0.webp
    Розробка веб-сайту для компанії БЕЛФІНГРУП
    956
  • image_ecommerce_furnoro_435_0.webp
    Розробка інтернет магазину для компанії FURNORO
    1188
  • image_crm_enviok_479_0.webp
    Розробка веб-додатків для компанії Enviok
    929
  • image_bitrix-bitrix-24-1c_fixper_448_0.webp
    Розробка веб-сайту для компанії ФІКСПЕР
    947

Два розробники одночасно редагують один JSON-файл конфігурації. За хвилину — розсинхрон, втрачені правки. Така ситуація знайома кожному, хто працював з конкурентним доступом. Проста трансляція подій через WebSocket ламається при одночасних змінах. Без формальної моделі даних конфлікти неминучі. Наша команда з 10-річним досвідом впроваджує CRDT та OT для безконфліктної синхронізації. Рішення скорочує час розробки на 30% і окупається за 3–4 місяці, економлячи до 40% бюджету на розробку (до $20 000 на рік).

Проблеми, які вирішує CRDT

Конкурентний доступ — коли два користувачі змінюють один об'єкт, без спеціальної моделі правки втрачаються або перезаписуються. CRDT гарантує, що всі копії зійдуться до одного стану. Offline-режим — користувач вносить зміни без інтернету, а при підключенні вони автоматично синхронізуються. OT потребує постійного з'єднання. Складність реалізації — написати свою OT для більш ніж двох клієнтів — десятки edge cases. CRDT з готовими бібліотеками (Yjs, Automerge) дає працююче рішення за дні.

Як працюють CRDT та OT: принципова різниця

OT (Operational Transformation) трансформує операції з урахуванням конкурентних змін. Метод Google Docs, працює тільки з центральним сервером-арбітром. Для >2 клієнтів реалізація стає експоненційно складною. CRDT (Conflict-free Replicated Data Types) — структури даних, математично гарантують узгодженість без координації. Операції комутативні та ідемпотентні. Детальніше Wikipedia.

Критерій OT CRDT
Центральний сервер Обов'язковий Опціональний (P2P)
Offline-підтримка Складно Нативно
Продуктивність Висока Залежить
Реалізація Складна, багато edge cases Простіше з готовими бібліотеками
Rich text Google Docs, Quill Yjs, Automerge

Чому CRDT актуальний для сучасних застосунків?

CRDT виграє в сценаріях offline, P2P, без єдиної точки відмови. Yjs скорочує час розробки в 2–3 рази порівняно з власною OT — готові інтеграції без логіки трансформації. OT залишається для високонавантажених текстових редакторів, але для більшості веб-застосунків CRDT практичніший. Вартість інтеграції знижується на 30% за рахунок виключення власних рішень.

Як впровадити CRDT за 3–5 днів?

  1. Вибрати бібліотеку: Yjs для тексту, Automerge для складних JSON.
  2. Замінити локальні стани на shared типи (Y.Doc, Y.Text, Y.Map).
  3. Розгорнути WebSocket-сервер (y-websocket або Hocuspocus) з персистентністю.
  4. Протестувати конкурентний доступ.
  5. Додати awareness для курсоров.

Нижче — робоча конфігурація.

Приклад інтеграції з Yjs та WebSocket

npm install yjs y-websocket y-protocols

Сервер (y-websocket):

// server.js
const { WebSocketServer } = require('ws');
const { setupWSConnection } = require('y-websocket/bin/utils');
const http = require('http');

const server = http.createServer((req, res) => {
  res.writeHead(200);
  res.end('ok');
});

const wss = new WebSocketServer({ server });

wss.on('connection', (ws, req) => {
  setupWSConnection(ws, req, {
    docName: req.url.slice(1),
    gc: true,
  });
});

server.listen(1234);

Клієнт з Quill:

import * as Y from 'yjs';
import { WebsocketProvider } from 'y-websocket';
import { QuillBinding } from 'y-quill';
import Quill from 'quill';

const ydoc = new Y.Doc();
const provider = new WebsocketProvider(
  'ws://localhost:1234',
  'my-document-room',
  ydoc,
  { connect: true }
);

provider.on('status', ({ status }) => {
  console.log('WS status:', status);
});

provider.on('sync', (isSynced: boolean) => {
  if (isSynced) {
    console.log('Document synced from server');
  }
});

const ytext = ydoc.getText('quill-content');
const quill = new Quill('#editor', { theme: 'snow' });
const binding = new QuillBinding(ytext, quill, provider.awareness);

provider.awareness.setLocalStateField('user', {
  name: 'Іван Петров',
  color: '#4a9eff',
});

Зберігання даних: персистентність

Ephemeral y-websocket втрачає документ при перезапуску. Для production використовуємо Hocuspocus з PostgreSQL.

Приклад конфігурації

import { Server } from '@hocuspocus/server';
import { Database } from '@hocuspocus/extension-database';
import { Pool } from 'pg';

const pool = new Pool({ connectionString: process.env.DATABASE_URL });

const server = Server.configure({
  port: 1234,
  extensions: [
    new Database({
      fetch: async ({ documentName }) => {
        const { rows } = await pool.query(
          'SELECT data FROM documents WHERE name = $1',
          [documentName]
        );
        return rows[0]?.data ?? null;
      },
      store: async ({ documentName, state }) => {
        await pool.query(
          `INSERT INTO documents (name, data, updated_at)
           VALUES ($1, $2, NOW())
           ON CONFLICT (name)
           DO UPDATE SET data = $2, updated_at = NOW()`,
          [documentName, Buffer.from(state)]
        );
      },
    }),
  ],
});

server.listen();

Порівняння Yjs та Automerge

Критерій Yjs Automerge 2.x
Продуктивність Висока для тексту (у 2 рази швидше для документів до 1000 рядків) Краще для великих JSON
Розмір ~30 KB gzip ~50 KB gzip (WASM)
Rich text Quill, ProseMirror Пряма робота з JSON
P2P Через y-websocket Вбудована мережа
Документація Велика Хороша

Вирішення конфліктів: як CRDT обирає переможця

CRDT не усуває конфлікти — він визначає детермінованого переможця. Yjs використовує алгоритм YATA: позиція вставки визначається сусідніми елементами, а не індексом, що стійке до конкурентних вставок. Для Last-Write-Wins Map перемагає операція з пізнішим timestamp. Граничний випадок: два користувачі одночасно видаляють і редагують один елемент — CRDT зберігає «надгробок» для коректного застосування змін.

Масштабування та multi-node синхронізація

Один WebSocket-сервер не масштабується горизонтально. Рішення: Sticky sessions (nginx), Pub/Sub через Redis (Hocuspocus з коробки), Managed сервіси (Liveblocks, PartyKit). Додаткова економія на інфраструктурі: CRDT-синхронізація не потребує дорогого центрального сервера. Наша команда налаштовує кластер з 99.9% uptime.

Що входить у нашу роботу та терміни

  • Аудит архітектури та моделі даних.
  • Вибір бібліотеки (Yjs, Automerge).
  • Інтеграція з бекендом (Node.js, PostgreSQL/Redis).
  • Розробка кастомних shared типів (дошки, форми).
  • Налаштування персистентності та багатопоточності.
  • Навантажувальне тестування з 5000 операцій/с.
  • Документація та навчання команди.

Терміни: базова інтеграція 3–5 днів, з персистентністю +2–3 дні, multi-node + тиждень. Пропонуємо впровадження під ключ. Зв'яжіться з нами для безкоштовної консультації — пишіть на пошту або телефонуйте, оцінимо ваш проєкт. Замовте впровадження — наші інженери з 10+ роками досвіду реалізували десятки успішних проєктів.

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

Ми знаємо, як боляче, коли полінг вбиває сервер. Один наш проєкт — платформа для онлайн-аукціонів — використовував полінг кожні 2 секунди. Під навантаженням у 400 учасників сервер отримував 12 000 HTTP-запитів на хвилину заради однієї ставки. 90% відповідей — пусті. Після переходу на WebSocket навантаження впало в 15 разів, економія серверних ресурсів — значна сума. Замовте розробку 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% сесій, що зекономило значні кошти на трафіку.

WebSocket (Wikipedia) WebRTC (Wikipedia)

Як правильно вибрати транспорт: покрокова інструкція

  1. Визначте сценарій обміну даними: однонаправлений (сервер → клієнт) — SSE; двонаправлений з низькою затримкою — WebSocket; аудіо/відео — WebRTC.
  2. Оцініть вимоги до затримки. Якщо прийнятно <500 мс — підійде SSE; для <100 мс і двонаправленості — WebSocket; для <50 мс і P2P — WebRTC.
  3. Перевірте бюджет на інфраструктуру. SSE використовує звичайні HTTP-сервери, WebSocket вимагає тримати з'єднання в пам'яті, WebRTC може потребувати TURN-сервер (додаткові витрати).
  4. Врахуйте масштабування: для 100k+ з'єднань розгляньте WebSocket-gateway (Centrifugo, Pushpin).
Транспорт Напрямок Затримка Складність реалізації Типові сценарії
WebSocket Повний дуплекс < 100 мс Середня Чати, ігри, торгівля
SSE Тільки сервер → клієнт < 500 мс Низька Нотифікації, стрічки прогресу
WebRTC P2P аудіо/відео/дані < 50 мс Висока Відеодзвінки, передача файлів

Що таке CRDT і чим він кращий за Operational Transformation?

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

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

Порівняння бібліотек для спільного редагування

Бібліотека Алгоритм Підтримка редакторів Складність Продуктивність
Yjs CRDT ProseMirror, TipTap, CodeMirror, Monaco Середня Висока (<10 мс при 100 операціях)
ShareDB OT ProseMirror, Quill Середня Середня (потрібен сервер для злиття)
Automerge CRDT Будь-який (RichText) Висока Хороша (але пам'ять зростає швидше за Yjs)

Проблема: розмір Yjs-документа зростає через історію операцій. Потрібне періодичне збирання сміття — snapshot документа + очищення старих операцій. Без цього документ, над яким працювали рік, може важити 50 МБ.

Приклад heartbeat на WebSocket (Node.js)
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+ з'єднань на одній ноді. Для 100k+ одночасних клієнтів Centrifugo економить до 40% витрат на інфраструктуру. Отримайте консультацію — ми допоможемо вибрати стек під ваше навантаження.

Строки

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

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