CRDT/OT синхронизация для приложений реального времени

Два разработчика одновременно редактируют один JSON-файл конфигурации. Через минуту — рассинхрон, потерянные правки. Такая ситуация знакома каждому, кто работал с конкурентным доступом. Простая трансляция событий через WebSocket ломается при одновременных изменениях. Без формальной модели данных конфликты неизбежны. Наша команда с 10-летним опытом внедряет CRDT и OT для бесконфликтной синхронизации. Решение сокращает время разработки на 30% и окупается за 3–4 месяца, экономя до 40% бюджета на разработку.

Проблемы, которые решает 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.

Почему 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

Разрешение конфликтов: как 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+ годами опыта реализовали десятки успешных проектов.