Какой быстрый механизм выполнения действия при создании сущности?

Механизм выполнения действий при создании сущности

Для быстрого выполнения действий при создании сущности в PHP-приложениях используется комбинация нескольких архитектурных паттернов и технологий. Вот наиболее эффективные подходы:

1. Domain Events (События предметной области)

Это основной механизм для декомпозиции бизнес-логики. При создании сущности генерируется событие, которое затем обрабатывается одним или несколькими обработчиками.

<?php
class User
{
    private UserId $id;
    private string $email;
    private array $events = [];
    
    public static function create(string $email): self
    {
        $user = new self(UserId::generate(), $email);
        $user->recordEvent(new UserCreated($user->getId(), $email));
        return $user;
    }
    
    private function recordEvent(object $event): void
    {
        $this->events[] = $event;
    }
    
    public function releaseEvents(): array
    {
        $events = $this->events;
        $this->events = [];
        return $events;
    }
}

2. Event Dispatcher (Диспетчер событий)

Современные фреймворки предоставляют мощные диспетчеры событий:

<?php
// Symfony EventDispatcher пример
class UserCreationSubscriber implements EventSubscriberInterface
{
    public static function getSubscribedEvents(): array
    {
        return [
            UserCreated::class => [
                ['sendWelcomeEmail', 10],
                ['createInitialProfile', 5],
                ['notifyAdministrators', 0],
            ],
        ];
    }
    
    public function sendWelcomeEmail(UserCreated $event): void
    {
        // Отправка приветственного письма
    }
    
    public function createInitialProfile(UserCreated $event): void
    {
        // Создание начального профиля
    }
}

3. Асинхронная обработка через Message Queue

Для долгих операций используйте очереди сообщений:

<?php
class UserCreatedHandler
{
    private MessageBusInterface $messageBus;
    
    public function __invoke(UserCreated $event): void
    {
        // Отправка в очередь для асинхронной обработки
        $this->messageBus->dispatch(
            new SendWelcomeEmail($event->getUserId())
        );
        
        $this->messageBus->dispatch(
            new GenerateInitialData($event->getUserId())
        );
    }
}

4. Database Triggers vs Application Layer

Важное решение: где выполнять действия?

• Триггеры БД - быстрые, но сложные для отладки и тестирования
• Уровень приложения - более гибкие, лучше для сложной бизнес-логики

-- Пример триггера (не рекомендуется для сложной логики)
CREATE TRIGGER after_user_insert
AFTER INSERT ON users
FOR EACH ROW
BEGIN
    INSERT INTO audit_log (user_id, action, timestamp)
    VALUES (NEW.id, 'USER_CREATED', NOW());
END;

5. Паттерн Observer в рамках Aggregate

Для связанных действий внутри агрегата:

<?php
class Order
{
    private array $lineItems = [];
    private bool $isPaid = false;
    
    public function addLineItem(LineItem $item): void
    {
        $this->lineItems[] = $item;
        $this->recalculateTotal();
        $this->checkDiscountEligibility();
        // Множество действий при одном изменении
    }
    
    private function recalculateTotal(): void
    {
        // Пересчет суммы заказа
    }
}

6. Middleware в Process Manager

Для координации нескольких действий:

<?php
class UserCreationPipeline
{
    private array $middlewares = [];
    
    public function createUser(array $data): User
    {
        $pipeline = new Pipeline();
        
        return $pipeline
            ->send($data)
            ->through([
                ValidateData::class,
                CreateUserEntity::class,
                HashPassword::class,
                PersistUser::class,
                SendNotifications::class,
            ])
            ->then(function ($data) {
                return $data['user'];
            });
    }
}

Критерии выбора подхода

1. Срочность выполнения:

   • Синхронно - для обязательных валидаций
   • Асинхронно - для фоновых задач

2. Зависимости между действиями:

   • Последовательные - Use Case/Command Handler
   • Параллельные - Event-Driven Architecture

3. Масштабируемость:

   • Event Sourcing для аудита и восстановления
   • CQRS для разделения чтения/записи

Рекомендации по реализации

• Всегда отделяйте основное создание сущности от побочных эффектов
• Используйте транзакции для связанных операций, но не для долгих задач
• Реализуйте idempotency (идемпотентность) для обработчиков событий
• Мониторинг и логирование всех пост-действий
• Тестируйте изолированно каждый обработчик

Самый быстрый механизм - это комбинация синхронных Domain Events для валидаций и немедленных действий + асинхронной очереди для фоновых задач. Это обеспечивает минимальное время отклика API при гарантированном выполнении всех бизнес-процессов.