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