Что такое CQRS и как он применяется?

Question

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

YeaHub · Accepted Answer

Определение: CQRS — это архитектурный шаблон, который предлагает разделять операции, изменяющие состояние системы (Commands), и операции, возвращающие данные (Queries), используя для них разные модели.В традиционном подходе (CRUD) одна и та же модель объекта используется для создания, чтения, обновления и удаления. CQRS отходит от этой парадигмы.Основные компоненты CQRS:Команда (Command): Инструкция на выполнение действия, которая изменяет состояние системы. Команда не возвращает данных (кроме, возможно, статуса выполнения). Например: "Создать заказ", "Изменить адрес пользователя".Запрос (Query): Запрос на получение данных, который не изменяет состояние системы. Например: "Получить список моих заказов", "Найти товар по названию".Как это работает на практике:Сторона записи (Write Side / Command Side): Принимает команды, выполняет бизнес-логику и сохраняет данные в хранилище для записи (часто это основная база данных, "source of truth"). Модель данных здесь ориентирована на целостность и бизнес-правила.Сторона чтения (Read Side / Query Side): Обслуживает запросы, получая данные из специально оптимизированного хранилища для чтения. Это может быть та же база данных, но денормализованная проекция, отдельная NoSQL база (например, Elasticsearch для поиска) или просто кэш. Модель данных здесь ориентирована на скорость и удобство выборки.Связь между сторонами (синхронизация данных)После успешной записи в основное хранилище, сторона записи публикует событие (Event), сообщающее о произошедшем изменении (например, OrderCreatedEvent). Сторона чтения подписывается на эти события и обновляет свое хранилище для чтения соответственно. Этот механизм часто реализуется с помощью шины событий (Event Bus).Пример применения (Упрощенная система блога):Команда: PublishPostCommand(title, content, authorId). Сервис команд проверяет права, создает запись в основной базе (PostgreSQL) и публикует событие PostPublishedEvent.Запрос: GetLatestPostsQuery(page, size). Сервис запросов не идет в PostgreSQL, а берет данные из своей денормализованной таблицы в MongoDB, которая уже содержит сведенную информацию о посте и авторе, идеально подходящую для отображения ленты. Эта таблица обновляется обработчиком события PostPublishedEvent.Плюсы CQRS:Масштабируемость: Стороны чтения и записи можно масштабировать независимо. Часто нагрузка на чтение в разы выше.Гибкость: Можно использовать разные СУБД, оптимальные для каждой задачи (PostgreSQL для транзакций записи, Redis для быстрого кэша, Elasticsearch для поиска).Производительность: Модели для чтения можно денормализовать, избегая сложных JOIN, что ускоряет выполнение запросов.Более чистая модель: Разделение упрощает понимание кода, так как команды и запросы имеют разные цели.Минусы CQRS:Сложность: Архитектура становится значительно сложнее классической.Задержка (Eventual Consistency): Изменения, сделанные командой, не сразу отображаются в запросах, пока не сработают обработчики событий. Это "согласованность в конечном счете".Избыточность данных: Данные хранятся в нескольких местах.ВыводCQRS стоит применять не в каждом проекте. Он оправдан в системах со сложной бизнес-логикой, высокой нагрузкой на чтение, где требования к моделям чтения и записи кардинально различаются. Для простых CRUD-приложений CQRS добавит ненужной сложности. Часто его используют в комбинации с паттерном Event Sourcing.