एक्सॉन इवेंट सोर्सिंग की समझ

मैं अक्षतंतु और इवेंट सोर्सिंग के बारे में सीख रहा हूं और मुझे लगता है कि मैंने आखिरकार इसका हिस्सा समझ लिया है और यह मेरे दिमाग में समझ में आता है, लेकिन मैं यह सुनिश्चित करना चाहता हूं कि इसके बारे में मेरी समझ सही है और मैं कोई गलती नहीं कर रहा हूं। कोड काम करता है, और मैं अपनी DOMAIN_EVENT_ENTRY तालिका में भी ईवेंट देख सकता हूं।

मैं अपना कोड नीचे पोस्ट करूंगा (दस्तावेज़ों से सरल गिफ्टकार्ड उदाहरण) और अपनी विचार प्रक्रिया की व्याख्या करूंगा। अगर मैं इसे सही ढंग से नहीं समझ पाया हूं, तो क्या आप उस हिस्से को सही तरीके से समझने में मेरी मदद कर सकते हैं।

मैंने आदेश/घटनाओं को शामिल नहीं किया है क्योंकि वे आईडी, राशि के लिए फ़ील्ड के साथ बहुत सरल हैं

पहले मेरा कोड:

टेस्ट रनर.जावा

package com.example.demoaxon;

import java.util.UUID;

import org.axonframework.commandhandling.gateway.CommandGateway;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import lombok.extern.slf4j.Slf4j;

@Component
@Slf4j
public class TestRunner implements CommandLineRunner {
    
    private final CommandGateway commandGateway;
    
    @Autowired
    public TestRunner(CommandGateway commandGateway) {
        this.commandGateway = commandGateway;
    }
    
    @Override
    public void run(String... args) throws Exception {
        log.info("send command");
        String id = UUID.randomUUID().toString();
        commandGateway.sendAndWait(new IssueCardCommand(id,100));
        commandGateway.sendAndWait(new RedeemCardCommand(id,90));
        
    }
}

गिफ्टकार्ड.जावा

package com.example.demoaxon;

import org.axonframework.commandhandling.CommandHandler;
import org.axonframework.eventsourcing.EventSourcingHandler;
import org.axonframework.modelling.command.AggregateIdentifier;
import static org.axonframework.modelling.command.AggregateLifecycle.apply;
import org.axonframework.spring.stereotype.Aggregate;

import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;

@NoArgsConstructor
@Aggregate
@Slf4j
public class GiftCard {
    
    @AggregateIdentifier
    private String giftCardId;
    private Integer amount;
    
    @CommandHandler
    public GiftCard(IssueCardCommand cmd) {
        log.info("handling {}",cmd);
        apply(new CardIssuedEvent(cmd.getCardId(),cmd.getAmount()));
    }
    
    @EventSourcingHandler
    public void onCardIssuedEvent(CardIssuedEvent evt) {
        log.info("applying {}",evt);
        this.giftCardId = evt.getCardId();
        this.amount = evt.getAmount();
    }
    
    @CommandHandler
    public void redeemCardCommandHandler(RedeemCardCommand cmd) {
        log.info("handling {}",cmd);
        this.amount -= cmd.getAmount();
        apply(new CardRedeemedEvent(cmd.getCardId(),cmd.getTransactionId(),this.amount));
    }
    
    @EventSourcingHandler
    public void onCardRedeemedEvent(CardRedeemedEvent evt) {
        log.info("applying {}",evt);
        this.amount = evt.getAmount();
    }   
}

मैं जो समझ सकता हूं उससे:

1. मेरी TestRunner कक्षा में, कमांड गेटवे कमांड बस का उपयोग करके issueCardCommand को इसके CommandHandler पर भेजता है, जो तब GiftCard समुच्चय का एक नया उदाहरण बना रहा है। इस CommandHandler में हम कोई भी तर्क कर सकते हैं, और फिर हम इस apply विधि का उपयोग करते हैं।

2. apply(event) विधि का उपयोग CardIssuedEvent को GiftCard के दायरे में EventMessage के रूप में प्रकाशित करने के लिए किया जाता है और यह उस विशेष घटना के लिए EventSourcingHandler को भी आमंत्रित करता है, तो इस मामले में onCardIssuedEvent। यह EventMessage को EventBus पर प्रकाशित करता है और EventHandlers को भेजा जाता है।

3. @EventSourcingHandler onCardIssuedEvent में, हम GiftCard समुच्चय में कोई भी राज्य परिवर्तन कर सकते हैं और हम स्प्रिंग Jpa का उपयोग करके DOMAIN_EVENT_ENTRY तालिका में भी घटना को जारी रख रहे हैं।

4. एक बार यह CommandHandler निष्पादित हो जाने के बाद, समग्र वस्तु अब मौजूद नहीं है।

5. अब मेरी TestRunner कक्षा में फिर से, कमांड गेटवे RedeemCardCommand को उसके CommandHandler पर भेजता है और चूंकि पहला कमांड अब मौजूद नहीं है, खाली नो आर्ग्स कंस्ट्रक्टर का उपयोग वस्तुओं को बनाने के लिए किया जाता है। अक्षतंतु ढांचा इस DOMAIN_EVENT_ENTRY तालिका से सभी घटनाओं को पुनः प्राप्त करता है और यह वर्तमान स्थिति प्राप्त करने के लिए GiftCard कुल उदाहरण के लिए सभी घटनाओं (इवेंटसोर्सिंग हैंडलर) को फिर से चलाता है (यही कारण है कि @AggregateIdentifier है जरूरी)।

6. RedeemCardCommandHandler विधि को तब क्रियान्वित किया जाता है, यह किसी भी तर्क को निष्पादित करता है और घटना को लागू करता है, जो कुल के भीतर प्रकाशित होता है और यह EventSourcingHandler को आमंत्रित करता है। यह EventSourcingHandler फिर GiftCard की स्थिति को अपडेट करता है / DOMAIN_EVENT_ENTRYटेबल पर बना रहता है।

क्या इवेंट सोर्सिंग के काम करने के तरीके के बारे में मेरी समझ सही है?