Что такое CQRS и как он реализуется?

Что такое CQRS?

CQRS (Command Query Responsibility Segregation) — это паттерн проектирования, который разделяет операции чтения и записи данных. В традиционных системах одна модель данных используется и для чтения, и для записи, что может приводить к конфликтам производительности и сложности. CQRS предлагает использовать отдельные модели: одна для команд (изменение состояния), другая для запросов (чтение).

Как это работает?

Команды — это операции, которые изменяют состояние системы (например, создать заказ, обновить профиль). Запросы — это операции, которые только читают данные (например, получить список заказов). В CQRS команды и запросы обрабатываются разными сервисами или модулями, часто с разными хранилищами данных. Например, запись может идти в реляционную БД, а чтение — в NoSQL или кэш.

Пример реализации

// Командная модель (запись)
class OrderCommandService {
  createOrder(data) {
    // Валидация и сохранение в основную БД
    db.orders.insert(data);
    // Публикация события для обновления read-модели
    eventBus.publish('order.created', data);
  }
}

// Запросная модель (чтение)
class OrderQueryService {
  getOrders(userId) {
    // Чтение из оптимизированной read-модели
    return readDb.orders.find({ userId });
  }
}

В этом примере команда сохраняет данные в основную БД и публикует событие. Отдельный обработчик обновляет read-модель, которая оптимизирована для быстрых запросов.

Когда применять?

CQRS полезен в системах с высокой нагрузкой на чтение, где требуется масштабирование чтения независимо от записи. Также он хорошо сочетается с event sourcing, когда состояние системы восстанавливается из событий. Однако для простых CRUD-приложений CQRS может быть избыточен и усложнить архитектуру.

Итог: CQRS стоит применять в сложных доменных системах с асимметричной нагрузкой на чтение и запись, когда нужна гибкость масштабирования и оптимизация производительности.