CQRS

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

Що таке CQRS

CQRS (Command Query Responsibility Segregation) — це підхід, у якому операції зміни даних і операції читання використовують різні моделі.

Command — команда, яка змінює стан системи.
Query — запит, який лише читає дані.
Write model — модель для виконання бізнес-правил і запису.
Read model — модель, оптимізована для конкретних сценаріїв читання.

У звичайному CRUD одна модель часто використовується і для читання, і для запису:

text

HTTP-запит → Order model → база даних

У CQRS потік розділяється:

text

1. Клієнт надсилає CreateOrder.
2. Write model створює замовлення.
3. Система публікує OrderCreated.
4. Проєкція обробляє подію.
5. Read model стає актуальною.
6. Query повертає замовлення у зручному форматі.

javascript

const writeModel = new Map();
const readModel = new Map();

const eventHandlers = {
  OrderCreated: async (event) => {
    // Імітуємо затримку доставки або обробки події
    await new Promise((resolve) => setTimeout(resolve, 100));

    readModel.set(event.orderId, {
      id: event.orderId,
      customerName: event.customerName,
      total: event.total,
      status: "created"
    });
  }
};

async function publish(event) {
  const handler = eventHandlers[event.type];

  if (!handler) {
    throw new Error(`Невідомий тип події: ${event.type}`);
  }

  await handler(event);
}

async function createOrder({ customerName, total }) {
  if (!customerName || total <= 0) {
    throw new Error("Некоректні дані замовлення");
  }

  const orderId = crypto.randomUUID();

  const order = {
    id: orderId,
    customerName,
    total,
    status: "created"
  };

  // Спочатку змінюємо write model
  writeModel.set(orderId, order);

  // У реальній системі подія зазвичай передається через чергу
  void publish({
    type: "OrderCreated",
    orderId,
    customerName,
    total
  });

  return orderId;
}

function getOrderSummary(orderId) {
  return readModel.get(orderId) ?? null;
}

async function main() {
  const orderId = await createOrder({
    customerName: "Олена Коваль",
    total: 2499
  });

  console.log("Відповідь одразу після команди:");
  console.log(getOrderSummary(orderId));
  // null: read model ще не встигла обробити подію

  await new Promise((resolve) => setTimeout(resolve, 150));

  console.log("Відповідь після синхронізації:");
  console.log(getOrderSummary(orderId));
}

main().catch((error) => {
  console.error(error.message);
});

text

Відповідь одразу після команди:
null

Відповідь після синхронізації:
{
  id: "...",
  customerName: "Олена Коваль",
  total: 2499,
  status: "created"
}

CQRS

Що таке CQRS

Чому одна модель може бути проблемою

Команди та запити

Команди

Запити

Події та синхронізація моделей

Приклад із затримкою read model

Синхронна та асинхронна синхронізація

Синхронне оновлення

Асинхронне оновлення

Головна складність CQRS — узгодженість

Повторна обробка подій

Порядок подій

Відновлення read model

Проблема подвійного запису

Коли CQRS доречний

Коли CQRS не потрібен

Типові помилки

Вважати CQRS синонімом мікросервісів

Вважати CQRS обов’язково асинхронним

Дозволяти запитам змінювати стан

Ігнорувати затримку узгодженості

Не робити обробники ідемпотентними

Дублювати бізнес-правила в read model

Як оцінити введення CQRS

Підсумок