Download the PHP package sbooker/command-bus without Composer
On this page you can find all versions of the php package sbooker/command-bus. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Informations about the package command-bus
Read in English
Asynchronous Command Bus (sbooker/command-bus)
Надежная, транзакционная, персистентная шина для асинхронного выполнения команд с поддержкой повторных попыток и отслеживанием состояния.
Назначение библиотеки
Эта библиотека решает две ключевые задачи в современных приложениях:
1. Надежное асинхронное выполнение задач. Библиотека позволяет атомарно сохранить команду на выполнение долгой или ненадежной операции (отправка email, запрос к API) в базу данных. Отдельный фоновый процесс (воркер) гарантированно выполнит эту команду позже.
2. Создание фундамента для отказоустойчивых Process Managers (Sagas). В event driven системах обработка доменных событий может быть хрупкой. Например, если подписчик на событие OrderPaid пытается выполнить операцию Warehouse::reserve() и получает ошибку, вся очередь обработки событий может быть заблокирована. Выход — сделать обработку событий простой и безошибочной, преобразуя событие или последовательность событий в команду(ы). Обычно для этого используют паттерн Process Manager (Saga). Ответственность за преобразование события в команду лежит на вашем коде (в подписчике на события). Сама библиотека не реализует паттерн Process Manager, но существенно облегчает его реализацию, предоставляя надежный, транзакционный механизм для асинхронного выполнения этой команды, изолируя сбои и не блокируя обработку других событий.
Ключевые особенности
- Основа для Process Manager / Saga: Предоставляет надежный механизм выполнения команд, который является ключевой частью реализации Process Manager.
- Транзакционная надежность: Прием команды происходит атомарно благодаря интеграции с sbooker/transaction-manager.
- Декларативные стратегии ретраев: Логика повторных попыток не находится в обработчике. Она декларативно настраивается для каждой команды через
TimeoutCalculator. Сама персистентная сущностьCommandотслеживает количество попыток и время следующего запуска. Воркер лишь пытается выполнить готовые к запуску команды. - Гарантированное выполнение (At-Least-Once): Команда будет выполняться до тех пор, пока не завершится успешно или не исчерпает все попытки.
- Отслеживание состояния: В любой момент можно узнать статус команды (
created,pending,success,fail). - Хуки на результат: Определяйте колбэки (
Invoker) на успешное или неуспешное завершение.
Установка
Вам также понадобятся зависимости из экосистемы и адаптеры:
Быстрый старт
Сценарий 1: Асинхронное выполнение задачи
Задача: Отправить приветственный email, не заставляя пользователя ждать.
1. Команда и ее Endpoint:
2. Отправка команды:
Сценарий 2 (Продвинутый): Построение Process Manager
Задача: После оплаты заказа (OrderPaid event) надежно зарезервировать товары на складе.
1. Команда и ее Endpoint:
2. Подписчик на событие (Process Manager):
Общие шаги: Конфигурация и запуск воркера
Независимо от сценария, вам нужно настроить Registry и запустить воркер.
1. Конфигурация Registry:
2. Запуск воркера:
3. Настройка Doctrine:
Вам нужно предоставить маппинг для сущности Sbooker\CommandBus\Command и ее embeddables, а также зарегистрировать кастомный тип для Status.
Или использовать поставляемые с библиотекой
4. Так же в комплекте:
- Консольная команда для ручного запуска обработки команды по ее идентификатору ExecuteCommand
- Консольная команда для очистки отработанных команд Clean
License
See LICENSE file.
All versions of command-bus with dependencies
ramsey/uuid Version ^4.0
sbooker/workflow Version ^1.1
sbooker/transaction-manager Version ^2.2 || ^3.0
symfony/serializer Version ^5.0 || ^6.0
symfony/property-access Version ^5.0 || ^6.0