Два разработчика одновременно редактируют один 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.
| Критерий | 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 дней?
- Выбрать библиотеку: Yjs для текста, Automerge для сложных JSON.
- Заменить локальные состояния на shared типы (Y.Doc, Y.Text, Y.Map).
- Развернуть WebSocket-сервер (y-websocket или Hocuspocus) с персистентностью.
- Протестировать конкурентный доступ.
- Добавить 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 |
|---|---|---|
| Производительность | Высокая для текста | Лучше для больших 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+ годами опыта реализовали десятки успешных проектов.