वनीला PHP में CQRS की शुरुआत: फ्रेमवर्क के बिना कमांड और रीड को अलग करें

हर जगह CQRS का ज़िक्र सुनते-सुनते थक गए हैं लेकिन सोचते हैं कि Symfony या Laravel उठाए बिना इसे कैसे लागू करें? अच्छी खबर यह है कि हम सिर्फ वनीला PHP में Command Query Responsibility Segregation को देख सकते हैं। ज़रूरत बस एक साफ-सुथरी संरचना और कुछ सोची-समझी क्लास की है। अपना एडिटर खोलिए, हम मिलकर नींव तैयार करते हैं।

पूर्वापेक्षाएँ: PHP 8.4 और न्यूनतम सेटअप

• PHP 8.4 इंस्टॉल हो (CLI या वेब सर्वर)। php -v से वर्ज़न जाँचें ताकि readonly प्रॉपर्टी, स्ट्रिक्ट टाइप्स और फर्स्ट-क्लास कॉलएबल का लाभ ले सकें।
• Composer (ऑटोलोडिंग के लिए उपयोगी, हालांकि वैकल्पिक) और एक हल्का वेब सर्वर (php -S 127.0.0.1:8000 -t public प्रयोग के लिए पर्याप्त है)।

यदि आपको पुराने वर्ज़न पर रहना है तो सुनिश्चित करें कि यहाँ इस्तेमाल की गई सुविधाएँ (कंस्ट्रक्टर प्रमोशन, readonly प्रॉपर्टी आदि) उपलब्ध हों, या फिर स्निपेट्स को उसी अनुसार समायोजित करें।

1. दो मिनट में CQRS

CQRS का मतलब है रीड (Query) और राइट (Command) को अलग करना। इससे दो अनुकूलित मार्ग तैयार होते हैं:

• कमांड्स स्टेट बदलते हैं (खाता बनाना, लेख प्रकाशित करना) और एप्लिकेशन डेटा वापस नहीं करते।
• क्वेरीज़ स्टेट को पढ़ती हैं (लेख सूची, किसी खाते का विवरण) और कोई साइड इफ़ेक्ट नहीं होता।

यह विभाजन DDD की सोच से आता है, लेकिन बिना भारी-भरकम औपचारिकता के भी अपनाया जा सकता है। तुरंत मिलने वाले फायदे:

• टेस्ट आसान हो जाते हैं: हैंडलरों को अलग से यूनिट टेस्ट कर सकते हैं।
• कोड स्पष्ट रहता है: हर हैंडलर एक ही काम पर फोकस करता है।
• धीरे-धीरे स्केल कर सकते हैं: रीड और राइट साइड को अलग-अलग विकसित कर सकते हैं।

ध्यान रखें कि CQRS कुछ अतिरिक्त संरचनात्मक जटिलता लाता है। साधारण CRUD के लिए यह ज़रूरत से ज़्यादा हो सकता है। तब ही अपनाएँ जब बिज़नेस नियम या स्केलेबिलिटी की ज़रूरत इसे सही ठहराए।

2. PHP में न्यूनतम फोल्डर संरचना

एक साधारण पेड़-ढांचे से काम चल जाएगा:

src/
  Domain/
    Article.php
    ArticleRepository.php
  Application/
    Command/
      CreateArticle/
        CreateArticleCommand.php
        CreateArticleHandler.php
    Query/
      ListArticles/
        ListArticlesQuery.php
        ListArticlesHandler.php
    Bus/
      CommandBus.php
      QueryBus.php
  Infrastructure/
    InMemoryArticleRepository.php
public/
  index.php

यहाँ हम Domain (बिज़नेस नियम), Application (उपयोग केस) और Infrastructure (कंक्रीट इम्प्लीमेंटेशन) को साफ़ तौर पर अलग रखते हैं।

3. न्यूनतम डोमेन मॉडल

अब Article एग्रीगेट और उसका रिपॉज़िटरी बनाएँ:

php
1<?php
2// src/Domain/Article.php
3
4final class Article
5{
6    public function __construct(
7        private readonly string $id,
8        private string $title,
9        private string $content,
10        private readonly \DateTimeImmutable $publishedAt,
11    ) {
12    }
13
14    public function id(): string
15    {
16        return $this->id;
17    }
18
19    public function title(): string
20    {
21        return $this->title;
22    }
23
24    public function content(): string
25    {
26        return $this->content;
27    }
28
29    public function publishedAt(): \DateTimeImmutable
30    {
31        return $this->publishedAt;
32    }
33}

php
1<?php
2// src/Domain/ArticleRepository.php
3
4interface ArticleRepository
5{
6    public function save(Article $article): void;
7
8    /** @return Article[] */
9    public function all(): array;
10}

4. कमांड साइड: लेख बनाना

कमांड इरादा लेकर आती है। हैंडलर बिज़नेस लॉजिक को व्यवस्थित करता है।

php
1<?php
2// src/Application/Command/CreateArticle/CreateArticleCommand.php
3
4final class CreateArticleCommand
5{
6    public function __construct(
7        public readonly string $id,
8        public readonly string $title,
9        public readonly string $content,
10        public readonly string $publishedAt,
11    ) {
12    }
13}

php
1<?php
2// src/Application/Command/CreateArticle/CreateArticleHandler.php
3
4final class CreateArticleHandler
5{
6    public function __construct(private ArticleRepository $repository)
7    {
8    }
9
10    public function __invoke(CreateArticleCommand $command): void
11    {
12        $article = new Article(
13            $command->id,
14            $command->title,
15            $command->content,
16            new \DateTimeImmutable($command->publishedAt),
17        );
18
19        $this->repository->save($article);
20    }
21}

महत्वपूर्ण नोट: हैंडलर कुछ भी रिटर्न नहीं करता। लेख को दोबारा पढ़ना है तो Query का उपयोग करें।

5. क्वेरी साइड: लेख सूची दिखाना

php
1<?php
2// src/Application/Query/ListArticles/ListArticlesQuery.php
3
4final class ListArticlesQuery
5{
6}

php
1<?php
2// src/Application/Query/ListArticles/ListArticlesHandler.php
3
4final class ListArticlesHandler
5{
6    public function __construct(private ArticleRepository $repository)
7    {
8    }
9
10    /** @return array<int, array{id: string, title: string, publishedAt: string}> */
11    public function __invoke(ListArticlesQuery $query): array
12    {
13        return array_map(
14            static fn (Article $article) => [
15                'id' => $article->id(),
16                'title' => $article->title(),
17                'publishedAt' => $article->publishedAt()->format('Y-m-d H:i:s'),
18            ],
19            $this->repository->all()
20        );
21    }
22}

हम ऐसा एरे लौटाते हैं जिसे सीधे सीरियलाइज़ किया जा सके, ताकि प्रेज़ेंटेशन लेयर डोमेन मॉडल पर निर्भर न हो।

6. शुरुआत के लिए इन-मेमोरी रिपॉज़िटरी

php
1<?php
2// src/Infrastructure/InMemoryArticleRepository.php
3
4final class InMemoryArticleRepository implements ArticleRepository
5{
6    /** @var array<string, Article> */
7    private array $storage = [];
8
9    public function save(Article $article): void
10    {
11        $this->storage[$article->id()] = $article;
12    }
13
14    public function all(): array
15    {
16        return array_values($this->storage);
17    }
18}

बाद में चाहें तो Doctrine, PDO या किसी बाहरी API से इसे बदल सकते हैं—हैंडलरों को छुए बिना।

7. अल्ट्रा-लाइट बस सेटअप करना

हैंडलर रिज़ॉल्यूशन को केंद्रीकृत करते ही CQRS का स्वाद आता है:

php
1<?php
2// src/Application/Bus/CommandBus.php
3
4final class CommandBus
5{
6    /** @param array<class-string, callable> $handlers */
7    public function __construct(private array $handlers)
8    {
9    }
10
11    public function dispatch(object $command): void
12    {
13        $handler = $this->handlers[$command::class] ?? null;
14
15        if ($handler === null) {
16            throw new \RuntimeException('इस कमांड के लिए कोई हैंडलर उपलब्ध नहीं है: ' . $command::class);
17        }
18
19        $handler($command);
20    }
21}

php
1<?php
2// src/Application/Bus/QueryBus.php
3
4final class QueryBus
5{
6    /** @param array<class-string, callable> $handlers */
7    public function __construct(private array $handlers)
8    {
9    }
10
11    public function ask(object $query): mixed
12    {
13        $handler = $this->handlers[$query::class] ?? null;
14
15        if ($handler === null) {
16            throw new \RuntimeException('इस क्वेरी के लिए कोई हैंडलर उपलब्ध नहीं है: ' . $query::class);
17        }
18
19        return $handler($query);
20    }
21}

ये बस अभी साधारण हैं लेकिन अवधारणा समझने को पर्याप्त हैं। वास्तविक प्रोजेक्ट में इन्हें PHP-DI या Symfony DI जैसे डिपेंडेंसी इंजेक्शन कंटेनर से जोड़ सकते हैं।

8. public/index.php में बूटस्ट्रैप उदाहरण

php
1<?php
2require_once __DIR__ . '/../vendor/autoload.php';
3
4$repository = new InMemoryArticleRepository();
5
6$createHandler = new CreateArticleHandler($repository);
7$listHandler = new ListArticlesHandler($repository);
8
9$commandBus = new CommandBus([
10    CreateArticleCommand::class => $createHandler(...),
11]);
12
13$queryBus = new QueryBus([
14    ListArticlesQuery::class => $listHandler(...),
15]);
16
17$commandBus->dispatch(new CreateArticleCommand(
18    id: uniqid('article_', true),
19    title: 'CQRS के साथ पहली चाल',
20    content: 'कमांड और रीड को आराम से अलग करते हैं…',
21    publishedAt: '2025-06-05 10:00:00',
22));
23
24$articles = $queryBus->ask(new ListArticlesQuery());
25
26header('Content-Type: application/json');
27echo json_encode($articles, JSON_PRETTY_PRINT);

(...) ऑपरेटर (first-class callable) PHP 8.1 से उपलब्ध है और PHP 8.4 में पूरी तरह समर्थित है। यदि आपको 8.0 या उससे नीचे को सपोर्ट करना है, तो इसे fn ($command) => $createHandler($command) से बदल दें।

9. क्रमशः आगे बढ़ें

जब नींव तैयार हो जाए तो समाधान को आगे बढ़ाएँ:

1. मान्यकरण: Value Objects (Title, Content) जोड़ें या एग्रीगेट बनाने से पहले Symfony Validator का उपयोग करें।
2. वास्तविक परसिस्टेंस: MySQL (PDO) या PostgreSQL रिपॉज़िटरी इम्प्लीमेंट करें बिना हैंडलरों को बदले।
3. डोमेन इवेंट्स: कमांड सफल होने पर ArticlePublished इवेंट निकालें और दूसरे लेयर में हैंडल करें।
4. समर्पित प्रोजेक्शन: रीड-ऑप्टिमाइज़्ड टेबल बनाएं ताकि भारी क्वेरी (पेजिनेशन, फुल-टेक्स्ट सर्च) संभाली जा सके।
5. टेस्टिंग: हर हैंडलर के यूनिट टेस्ट और बस के फंक्शनल टेस्ट लिखें।

10. पहली प्रोडक्शन रिलीज़ से पहले चेकलिस्ट

• हर कमांड का अपना समर्पित हैंडलर है जो कुछ वापस नहीं करता।
• हर क्वेरी अलग-थलग है और फ्रंटएंड के लिए डेटा तैयार करती है।
• तकनीकी निर्भरताएँ बाहरी स्रोत से इंजेक्ट होती हैं।
• बिज़नेस त्रुटियों को डोमेन में संभाला जाता है (विशेष अपवाद, Value Objects आदि)।
• टेस्ट कमांड, क्वेरी और बस—सभी को कवर करते हैं।

इस ढाँचे के साथ आप मौजूदा प्रोजेक्ट में धीरे-धीरे CQRS शामिल कर सकते हैं या बिना किसी फ्रेमवर्क के नया सर्विस शुरू कर सकते हैं। बस रीड और राइट की सीमा को स्पष्ट रखें और आर्किटेक्चर को चरण दर चरण विकसित करते रहें। सुखद प्रयोग की शुभकामनाएँ!