Melaksanakan Seni Bina Didorong Peristiwa dalam PHP: Penyelaman Mendalam ke dalam Penyumberan Acara dan CQRS

Event-Driven Architecture (EDA) memfokuskan pada sistem penyahgandingan dan menjadikannya lebih fleksibel, berskala dan boleh diselenggara dengan bertindak balas kepada acara. Dalam PHP, dua corak penting yang sering digunakan dalam EDA ialah Sumber Peristiwa dan Pengasingan Tanggungjawab Pertanyaan Perintah (CQRS). Berikut ialah panduan langkah demi langkah untuk melaksanakannya menggunakan PHP, bersama-sama dengan contoh praktikal.

Gambaran Keseluruhan Konsep

1. Sumber Acara:

• Daripada mengekalkan hanya keadaan akhir aplikasi dalam pangkalan data, setiap perubahan (peristiwa) kepada keadaan aplikasi disimpan.
• Contoh: Jika anda mempunyai sistem pesanan, bukannya menyimpan hanya status pesanan terkini, anda menyimpan setiap tindakan pada pesanan seperti "Pesanan Dibuat", "Item Ditambah", "Pesanan Dibayar", dll.

2. CQRS:

• CQRS memisahkan operasi baca (pertanyaan) dan tulis (perintah). Kedua-dua model mungkin berkembang secara berasingan, dengan model tulis memfokuskan pada logik dan pengesahan perniagaan, dan model baca pada perwakilan data.
• Contoh: Untuk sistem yang kompleks seperti tapak e-dagang, logik untuk membuat pesanan (menulis) boleh dipisahkan daripada mengambil butiran pesanan (baca).

---

Aliran Seni Bina

1. Perintah:

   • Arahan ialah tindakan yang meminta perubahan dalam keadaan (cth., "PlaceOrder", "AddItemToOrder").
   • Arahan dikendalikan oleh Pengendali Perintah yang melaksanakan logik perniagaan dan memancarkan peristiwa.

2. Acara:

   • Selepas perintah diproses, acara (cth., "OrderPlaced", "ItemAdded") dinaikkan, mewakili sesuatu yang penting telah berlaku.
   • Acara tidak boleh diubah dan ia mencetuskan tindakan di bahagian lain sistem, seperti mengemas kini model baca atau memberitahu sistem luaran.

3. Baca Model:

   • Model yang dibaca sentiasa dikemas kini dengan bertindak balas terhadap peristiwa. Ia dioptimumkan untuk operasi baca dan mungkin mempunyai skema yang berbeza daripada model tulis.

---

Contoh Langkah demi Langkah: Sistem Pesanan

Langkah 1: Menyediakan Projek

Buat struktur direktori:

event-driven-php/
    ├── src/
    │   ├── Commands/
    │   ├── Events/
    │   ├── Handlers/
    │   ├── Models/
    │   └── ReadModels/
    ├── tests/
    └── vendor/

Pasang kebergantungan (cth., symfony/event-dispatcher):

composer require symfony/event-dispatcher

Langkah 2: Tentukan Perintah

Arahan mewakili tindakan yang mengubah keadaan. Contoh: PlaceOrderCommand.php.

// src/Commands/PlaceOrderCommand.php
class PlaceOrderCommand
{
    public string $orderId;
    public string $customerId;

    public function __construct(string $orderId, string $customerId)
    {
        $this->orderId = $orderId;
        $this->customerId = $customerId;
    }
}

Langkah 3: Buat Acara

Peristiwa menerangkan perkara yang berlaku dalam sistem. Contoh: OrderPlacedEvent.php.

// src/Events/OrderPlacedEvent.php
class OrderPlacedEvent
{
    public string $orderId;
    public string $customerId;

    public function __construct(string $orderId, string $customerId)
    {
        $this->orderId = $orderId;
        $this->customerId = $customerId;
    }
}

Langkah 4: Pengendali Perintah

Pengendali arahan melaksanakan logik perniagaan sebenar dan membangkitkan acara. Contoh: PlaceOrderHandler.php.

// src/Handlers/PlaceOrderHandler.php
use Symfony\Component\EventDispatcher\EventDispatcher;

class PlaceOrderHandler
{
    private EventDispatcher $eventDispatcher;

    public function __construct(EventDispatcher $eventDispatcher)
    {
        $this->eventDispatcher = $eventDispatcher;
    }

    public function handle(PlaceOrderCommand $command)
    {
        // Business logic (e.g., check stock, validate order)

        // Emit the event
        $event = new OrderPlacedEvent($command->orderId, $command->customerId);
        $this->eventDispatcher->dispatch($event, 'order.placed');
    }
}

Langkah 5: Pengendali Acara (Membuat Data untuk Membaca Model)

Pengendali acara mendengar acara tertentu dan mengemas kini model baca. Contoh: OrderProjection.php.

// src/ReadModels/OrderProjection.php
class OrderProjection
{
    private array $orders = [];

    public function onOrderPlaced(OrderPlacedEvent $event)
    {
        // Save or update read model with necessary data
        $this->orders[$event->orderId] = [
            'orderId' => $event->orderId,
            'customerId' => $event->customerId,
            'status' => 'placed'
        ];
    }

    public function getOrder(string $orderId)
    {
        return $this->orders[$orderId] ?? null;
    }
}

Langkah 6: Menyatukannya

use Symfony\Component\EventDispatcher\EventDispatcher;

// Bootstrapping the system
$dispatcher = new EventDispatcher();
$orderProjection = new OrderProjection();

// Register event listeners
$dispatcher->addListener('order.placed', [$orderProjection, 'onOrderPlaced']);

// Create the command and command handler
$command = new PlaceOrderCommand('123', 'cust_001');
$handler = new PlaceOrderHandler($dispatcher);

// Handle the command (Place the order)
$handler->handle($command);

// Query the read model for the order
$order = $orderProjection->getOrder('123');
print_r($order);

Output:

Array
(
    [orderId] => 123
    [customerId] => cust_001
    [status] => placed
)

Langkah 7: Kedai Acara (Pilihan)

Untuk mendapatkan sumber acara penuh, anda juga akan melaksanakan kedai acara untuk meneruskan acara ke pangkalan data.

class EventStore
{
    private array $storedEvents = [];

    public function append(Event $event)
    {
        $this->storedEvents[] = $event;
    }

    public function getEventsForAggregate(string $aggregateId): array
    {
        return array_filter($this->storedEvents, function($event) use ($aggregateId) {
            return $event->aggregateId === $aggregateId;
        });
    }
}

---

Pecahan Bahagian demi Bahagian

1. Penciptaan Perintah: Mewakili niat pengguna untuk mengubah sesuatu.
2. Pengendalian Arahan: Logik perniagaan yang memproses arahan dan menimbulkan peristiwa.
3. Emisi Acara: Acara yang dibangkitkan selepas arahan berjaya dikendalikan.
4. Pengendalian Acara: Unjurkan data acara ke dalam model baca untuk pertanyaan yang dioptimumkan.
5. CQRS Separation: Model arahan memfokuskan pada logik domain, manakala model pertanyaan dioptimumkan untuk carian pantas.
6. Kedai Acara: Secara pilihan, kekalkan acara untuk memainkan semula keadaan apabila diperlukan.

---

Kesimpulan

Contoh ini menunjukkan aplikasi mudah CQRS dan Sumber Acara dalam PHP. Dengan corak ini, anda boleh membina sistem yang berskala dengan baik dan boleh diselenggara, sambil menyediakan kebolehauditan yang berkuasa dan pengendalian baca/tulis yang fleksibel. Seni bina boleh berkembang dengan unjuran tambahan, pengendalian acara yang lebih kompleks dan integrasi luaran seperti baris gilir pemesejan atau pemberitahuan pihak ketiga.

Atas ialah kandungan terperinci Melaksanakan Seni Bina Didorong Peristiwa dalam PHP: Penyelaman Mendalam ke dalam Penyumberan Acara dan CQRS. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!