Laravel में CQRS / ES को जल्दी से कैसे आज़माएँ या PHP में बैंक लिखें

हाल ही में, जस्ता उत्पादन पॉडकास्ट में, मेरे दोस्तों और मैंने एलिक्सिर में सीक्यूआरएस / ईएस पैटर्न और इसके कार्यान्वयन की कुछ विशेषताओं पर चर्चा की। क्योंकि मैं अपने काम में लारवेल का उपयोग करता हूं, यह इंटरनेट में तल्लीन नहीं करने और इस ढांचे के पारिस्थितिक तंत्र में इस दृष्टिकोण को कैसे डुबोना है, यह पाप था।

मैं कट के तहत सभी को आमंत्रित करता हूं, मैंने यथासंभव विषय का वर्णन करने की कोशिश की।

कुछ परिभाषाएँ

CQRS (कमांड क्वेरी रिस्पॉन्सिबिलिटी सेग्रीगेशन) - अलग-अलग संस्थाओं में ऑपरेशन पढ़ने और लिखने का आवंटन। उदाहरण के लिए, हम मास्टर को लिखते हैं, प्रतिकृति से पढ़ते हैं। CQRS। तथ्य और गलतफहमी - आपको ज़ेन सीक्यूआरएस की पूरी समझ पाने में मदद करता है
ES (इवेंट सोर्सिंग) - एक इकाई या संस्थाओं के सेट के सभी राज्य परिवर्तनों का भंडारण।
CQRS / ES एक वास्तुशिल्प दृष्टिकोण है जिसमें हम ईवेंट टेबल में एक इकाई के राज्य परिवर्तन की सभी घटनाओं को सहेजते हैं और इसमें एक एग्रीगेट और एक प्रोजेक्टर जोड़ते हैं।
एग्रीगेट - मेमोरी में स्टोर करता है जो व्यापार तर्क निर्णयों को बनाने के लिए आवश्यक गुण हैं (लेखन को गति देने के लिए), निर्णय लेता है (व्यावसायिक तर्क) और घटनाओं को प्रकाशित करता है।
प्रोजेक्टर - घटनाओं को सुनता है और अलग तालिकाओं या डेटाबेस (तेजी से पढ़ने के लिए) को लिखता है।

लड़ाई में

लारवेल इवेंट प्रोजेक्टर - लारवेल के लिए CQRS / ES लाइब्रेरी
लारबैंक एक CQRS / ES दृष्टिकोण के साथ एक भंडार है। हम इसे परीक्षण के लिए ले जाएंगे।

लाइब्रेरी कॉन्फ़िगरेशन आपको बताएगा कि कहां देखना है और यह बताना है कि यह क्या है। हम ईवेंट-प्रोजेक्टर . php फ़ाइल को देखते हैं। काम का वर्णन करने के लिए आवश्यक:

• projectors - रजिस्टर प्रोजेक्टर;
• reactors - रजिस्टर रिएक्टर। रिएक्टर - इस लाइब्रेरी में इवेंट प्रोसेसिंग में साइड इफेक्ट्स जोड़ते हैं, उदाहरण के लिए, इस रिपॉजिटरी में, यदि आप तीन बार निकासी की सीमा को पार करने की कोशिश करते हैं, तो MoreMoneyNeeded ईवेंट लिखा जाता है और उपयोगकर्ता को उसकी वित्तीय कठिनाइयों के बारे में एक संदेश भेजा जाता है;
• replay_chunk_size - रिप्ले का हिस्सा। ईएस की विशेषताओं में से एक घटनाओं से इतिहास को पुनर्स्थापित करने की क्षमता है। इस सेटिंग का उपयोग करके ऑपरेशन के दौरान मेमोरी रिसाव के लिए तैयार किया गया लारवेल इवेंट प्रोजेक्टर।

प्रवास पर ध्यान दें। मानक लारवल तालिकाओं के अलावा, हमारे पास है

• stored_events - मेटा ईवेंट डेटा के लिए असंरचित डेटा के कई स्तंभों के साथ मुख्य ES तालिका, हम ईवेंट प्रकारों को एक पंक्ति में संग्रहीत करते हैं। महत्वपूर्ण स्तंभ aggregate_uuid - इससे संबंधित सभी घटनाओं को प्राप्त करने के लिए समुच्चय के यूआईडी को संग्रहीत करता है;
• accounts - उपयोगकर्ता खातों के प्रोजेक्टर की तालिका, शेष स्थिति पर वर्तमान डेटा की त्वरित वापसी के लिए आवश्यक है;
• transaction_counts - पूर्ण किए गए लेनदेन की संख्या की त्वरित वापसी के लिए आवश्यक उपयोगकर्ता लेनदेन की संख्या के प्रोजेक्टर की एक तालिका।

और अब मैं एक नया खाता बनाने के अनुरोध के साथ सड़क पर हिट करने का प्रस्ताव करता हूं।

खाता निर्माण

मानक resource रूटिंग एकाउंट्सकंट्रोलर का वर्णन करता है। हम store विधि में रुचि रखते हैं

 public function store(Request $request) { $newUuid = Str::uuid(); //   ,   uuid  //      AccountAggregateRoot::retrieve($newUuid) //           ->createAccount($request->name, auth()->user()->id) //          ->persist(); return back(); } 

AccountAggregateRoot को लाइब्रेरी AggregateRoot विरासत में मिली। आइए कंट्रोलर नामक विधियों को देखें।

 //  uuid      public static function retrieve(string $uuid): AggregateRoot { $aggregateRoot = (new static()); $aggregateRoot->aggregateUuid = $uuid; return $aggregateRoot->reconstituteFromEvents(); } public function createAccount(string $name, string $userId) { //        //  ,   recordThat,  ,    , // ..     ) $this->recordThat(new AccountCreated($name, $userId)); return $this; } 

storeMany विधि storeMany पद्धति storeMany इवेंट-प्रोजेक्टर में निर्दिष्ट मॉडल storeMany stored_event_model । हमारे मामले में stored_event_model रूप में कॉन्फ़िगरेशन कॉन्फ़िगर करें, StoredEvent

 public static function storeMany(array $events, string $uuid = null): void { collect($events) ->map(function (ShouldBeStored $domainEvent) use ($uuid) { $storedEvent = static::createForEvent($domainEvent, $uuid); return [$domainEvent, $storedEvent]; }) ->eachSpread(function (ShouldBeStored $event, StoredEvent $storedEvent) { //   ,     // QueuedProjector* Projectionist::handleWithSyncProjectors($storedEvent); if (method_exists($event, 'tags')) { $tags = $event->tags(); } //         $storedEventJob = call_user_func( [config('event-projector.stored_event_job'), 'createForEvent'], $storedEvent, $tags ?? [] ); dispatch($storedEventJob->onQueue(config('event-projector.queue'))); }); } 

* कतारबद्धप्रकारक

प्रोजेक्टर अकाउंटप्रोजेक्टर और ट्रांजैक्शनकाउंटप्रोजेक्टर Projector लागू करते हैं Projector इसलिए वे अपनी रिकॉर्डिंग के साथ घटनाओं पर प्रतिक्रिया देंगे।

ठीक है, एक खाता बनाया गया है। मैं यह विचार करने का प्रस्ताव करता हूं कि क्लाइंट इसे कैसे पढ़ेगा।

चालान प्रदर्शन

 //    `accounts`     id public function index() { $accounts = Account::where('user_id', Auth::user()->id)->get(); return view('accounts.index', compact('accounts')); } 

यदि खातों का प्रोजेक्टर QueuedProjector इंटरफ़ेस को लागू करता है, तो उपयोगकर्ता को कुछ भी नहीं दिखाई देगा जब तक कि घटना को बदले में संसाधित नहीं किया जाता है।

अंत में, हम यह अध्ययन करेंगे कि खाते के कार्यों से प्राप्त धन की वापसी और निकासी कैसे होती है।

टॉप-अप और निकासी

फिर से, अकाउंटकंट्रोलर को देखें :

 //    uuid  //       //   ,     public function update(Account $account, UpdateAccountRequest $request) { $aggregateRoot = AccountAggregateRoot::retrieve($account->uuid); $request->adding() ? $aggregateRoot->addMoney($request->amount) : $aggregateRoot->subtractMoney($request->amount); $aggregateRoot->persist(); return back(); } 

AccountAggregateRoot पर विचार करें

खाता भरने के बाद:

 public function addMoney(int $amount) { $this->recordThat(new MoneyAdded($amount)); return $this; } //    ""  recordThat // AggregateRoot*? //     apply(ShouldBeStored $event), //       'apply' . EventClassName  // ,     `MoneyAdded` protected function applyMoneyAdded(MoneyAdded $event) { $this->accountLimitHitInARow = 0; $this->balance += $event->amount; } 

* एग्रीगेटट्रूट

धनराशि निकालते समय:

 public function subtractMoney(int $amount) { if (!$this->hasSufficientFundsToSubtractAmount($amount)) { //        $this->recordThat(new AccountLimitHit()); //      ,  //   ,     //     if ($this->needsMoreMoney()) { $this->recordThat(new MoreMoneyNeeded()); } $this->persist(); throw CouldNotSubtractMoney::notEnoughFunds($amount); } $this->recordThat(new MoneySubtracted($amount)); } protected function applyMoneySubtracted(MoneySubtracted $event) { $this->balance -= $event->amount; $this->accountLimitHitInARow = 0; } 

निष्कर्ष

मैंने Laravel पर CQRS / ES में "ऑनबोर्डिंग" की प्रक्रिया का वर्णन करने की कोशिश की ताकि पानी से मुक्त हो सके। अवधारणा बहुत दिलचस्प है, लेकिन सुविधाओं के बिना नहीं। लागू करने से पहले, याद रखें:

• अंततः स्थिरता;
• अलग-अलग डोमेन में DDD का उपयोग करना वांछनीय है, आपको इस पैटर्न पर पूरी तरह से एक बड़ा सिस्टम नहीं बनाना चाहिए;
• घटना तालिका के स्कीमा में परिवर्तन बहुत दर्दनाक हो सकता है;
• यह घटनाओं की बारीकियों की पसंद से संपर्क करने के लिए सार्थक है, जितनी अधिक ठोस घटनाएं हैं, उतना ही वे तालिका में होंगे और उनके साथ काम करने के लिए अधिक संसाधनों की आवश्यकता होगी।

त्रुटियों को नोटिस करने में मुझे खुशी होगी।