Die Rückverfolgbarkeit der Ereignisse und CQRs eignen sich für komplexe Gesch?ftssysteme. 1. Ereignisverfolgbarkeit bietet vollst?ndige Prüfungs- und Zeitreisef?higkeiten, indem Ereignissequenzrekonstruktionsstatus sparen, jedoch die Komplexit?t der Abfrage erh?ht. 2. CQRS trennt Lese- und Schreibmodelle, um die Skalierbarkeit und Leistung zu verbessern, führt jedoch die endgültige Konsistenz ein. 3. In Java kann Axon Framework in Kombination mit Spring Boot unter Verwendung von @aggregate implementiert werden, um Befehle zu verarbeiten, @EventSourcingHandler -Updates Status und @EventHandler Builds Lesemodelle; V. 5. Achten Sie auf die Unver?nderlichkeit des Ereignisses, die Versionskontrolle, die endgültige Konsistenzverarbeitung und die Komplexit?t des Debuggens. Diese Architektur ist bei hohen Nachfragesystemen von gro?em Wert.

Event Sourcing und Befehlsabfrage Trennung von Verantwortlichkeiten (CQRs) sind zwei wichtige Modelle in modernen verteilten Systemen, die sich mit komplexer Gesch?ftslogik befassen und die Systemskalierbarkeit verbessern. Im Java -?kosystem k?nnen diese beiden Modi effizient implementiert werden. Das Folgende ist eine Analyse aus verschiedenen Aspekten von Konzepten, Anwendungsszenarien, Implementierungsmethoden und Vorsichtsma?nahmen.

Was sind Event Sourcing und CQRs?

1. Ereignisbeschaffung

In herk?mmlichen Systemen speichern wir normalerweise nur den aktuellen Status der Entit?t (wie die Benutzerbilanz von 100 Yuan). Die Kernidee der Ereignisverfolgung ist: Nicht direkt den Zustand zu retten, sondern die Abfolge der Ereignisse zu retten, die zu Zustands?nderungen führen .

Beispielsweise wird die Kontostand?nderung in einem Benutzerkonto nicht direkt mit dem Saldo -Feld aktualisiert, sondern Datens?tze:

• MoneyDeposited(amount=50)
• MoneyWithdrawn(amount=20)

Der Staat wird durch Wiederholung dieser Ereignisse rekonstruiert.

Vorteil:

• Komplettes Prüfprotokoll
• Einfach zu debuggen und zurückzuziehen
• Unterstützen Sie Zeitreisen (rekonstruiert jederzeit den Status)

Mangel:

• Die Abfrageleistung kann sinken (Wiederholungsereignis erforderlich)
• Komplexer Ereignisversionsverwaltung
• Hohe Schwelle für Anf?nger

2. CQRS (Befehlsabfrageverantwortung Segregation)

CQRS trennt die Les- und Schreibvorg?nge des Systems:

• Befehl : Daten ?ndern, Modell schreiben (Modell schreiben)
• Abfrage : Daten lesen, entsprechend dem Lesemodell (Modell lesen)

Dies ist nicht nur Hierarchie, sondern erm?glicht auch verschiedene Datenmodelle, Datenbanken und sogar Technologie -Stapel, um Lesen und Schreiben zu verarbeiten.

Typische Struktur:

 Client → Befehl → Befehlshandler → Ereignisse → Event Store
                     ↓
               Ereignishandler → Modell aktualisieren (z. B. SQL, Elasticsearch)
                     ↓
Client ← Abfrage ← Modell lesen

Vorteil:

• Modelle lesen und schreiben k?nnen unabh?ngig optimiert werden
• Einfach zu skalieren (z. B. mehr Lesen und weniger Szenarien k?nnen den Abfragedienst in einem Abfragedienst skalieren)
• Eine klarere Aufteilung der Verantwortlichkeiten

Mangel:

• Die Systemkomplexit?t nimmt zu
• Es gibt eine Verz?gerung zwischen Lesen und Schreiben (endgültige Konsistenz)

Wie kann ich es in Java implementieren? Verwenden von Axon Framework

Axon ist das beliebteste Framework in Java zur Implementierung von Event Sourcing und CQRs und integriert sich gut in den Frühling.

Abh?ngigkeiten hinzufügen (Maven)

 <De vorangehen>
    <gruppe> org.axonframework </Groupid>
    <artifactid> Axon-Spring-Boot-Starter </artifactid>
    <version> 4.6.0 </Version>
</abh?ngig>

Beispiel: Bankkontoübertragung

1. Definieren Sie Ereignisse

 ?ffentliche Klasse MoneyDepoStedEvent {
    Public Final String AccountID;
    ?ffentliche endgültige doppelte Menge;

    ?ffentliches Geldverlust (String AccountID, Doppelbetrag) {
        this.accountID = AccountID;
        this.amount = Menge;
    }
}

?ffentliche Klasse MoneywithDrawnEvent {
    Public Final String AccountID;
    ?ffentliche endgültige doppelte Menge;

    ?ffentliches Geld mit
        this.accountID = AccountID;
        this.amount = Menge;
    }
}

2. Aggregat - Schreiben Sie ein Modell

 @Aggregat
?ffentliche Klasse BankAccount {

    @AggregateIdentifier
    private String AccountID;
    privates Doppelbilanz;

    public bankAccount () {} // von Axon verlangt

    // Befehlshandler
    @CommandHandler
    public bankAccount (createAccountCommand -Befehl) {
        // Ver?ffentlichung des Account Creation Event aggregatelifecycle.Apply (New AccountCreatedEvent (command.AccountID));
    }

    @CommandHandler
    public void Handle (EinzahlungMoneyCommand -Befehl) {
        if (command.Amount <= 0) {
            Neue IllegalArgumentException werfen ("Menge muss positiv sein");
        }
        Aggregatelifecycle.Apply (neuer GelddepositedEvent (command.accountid, command.amount));
    }

    @CommandHandler
    public void Handle (resctridMoneyCommand -Befehl) {
        if (command.amount> balance) {
            Neue IllegalStateException ("Unsufficial Funds") werfen;
        }
        Aggregatelifecycle.Apply (neues GeldwithDrawnEvent (command.accountid, command.Amount));
    }

    // Event Sourcing Handler - verwendet, um den Status @EventourcingHandler zu aktualisieren
    public void on (MoneyDepoStedEvent Ereignis) {
        this.balance = event.amount;
    }

    @EventsourcingHandler
    public void on (Geld mit Ereignis) {
        this.balance -= event.amount;
    }
}

3. Ereignisverarbeitung (Modell Update Reading Modell)

 @Komponente
?ffentliche Klasse AccountProjection {

    private endgültige Accountrepository Accountrepository;

    public AccountProjection (AccountRrepository Accountrepository) {
        this.accounTRepository = Accountrepository;
    }

    @EventHandler
    public void on (MoneyDepoStedEvent Ereignis) {
        AccountView -Konto = Accountrepository.findbyId (Event.AccountID)
            .Orelse (New AccountView (Event.AccountID, 0.0));
        Account.Balance = Event.Amount;
        Accountrepository.save (Konto);
    }

    @EventHandler
    public void on (Geld mit Ereignis) {
        AccountView -Konto = Accountrepository.findbyId (Event.AccountID)
            .orelsethrow ();
        Account.Balance -= Ereignis.Amount;
        Accountrepository.save (Konto);
    }
}

4. Lesen Sie die Modellentit?t (für Abfrage)

 @Juristische Person
?ffentliche Klasse AccountView {
    @Ausweis
    private String -ID;
    privates Doppelbilanz;

    // Konstruktoren, Getters, Setters
}

5. Abfragen Sie die Schnittstelle

 @Restcontroller
?ffentliche Klasse AccountQueryController {

    @Autowired
    private Accountrepository Accountrepository;

    @Getmapping ("/concusses/{id}")
    public AccountView getAccount (@PathVariable String -ID) {
        return Accountrepository.findbyId (id) .orelse (null);
    }
}

Wann kann Event -Sourcing CQRs verwendet werden?

• Die Gesch?ftslogik ist komplex und erfordert eine Prüfverfolgung (wie Finanzen, Auftragssystem)
• Lesen und Schreiben von Ladungen variieren stark und ben?tigen unabh?ngige Expansion
• Das System muss "rückg?ngig machen", "Wiederholungen" und "Zeitreisen" unterstützen
• In der Microservice -Architektur die Kommunikation zwischen Diensten durch Ereignis

?? Nicht empfohlen für die Verwendung mit einfachen Crud-Systemen, es wird überentwickelt.

Dinge zu beachten

• Ereignis unver?nderlich : Nach der Ver?ffentlichung kann es nicht ge?ndert werden, und es k?nnen nur Vergütungsereignisse hinzugefügt werden.
• Ereignisversionskontrolle : Wenn sich die Ereignisstruktur ?ndert, muss die Serialisierungskompatibilit?t oder Migration unterstützt werden.
• Modellkonsistenz lesen : CQRS ist die endgültige Konsistenz, und das Front-End muss sich mit der Situation befassen, in der "der Betrieb erfolgreich ist, die Abfrage jedoch nicht aktualisiert wird".
• Debugging -Schwierigkeitserh?hung : Tools sind erforderlich, um Event -Stream -Anzeigen, Wiederholungen usw. zu unterstützen.

Zusammenfassen

In Java k?nnen Event Sourcing und CQRs über das Axon -Framework leichter implementiert werden:

• Verwenden Sie @Aggregate , um Schreibmodelle zu verwalten
• Aktualisieren Sie den Aggregationsstatus mit @EventSourcingHandler
• Verwenden Sie @EventHandler , um ein Lesemodell zu erstellen
• Vollst?ndige Trennung von Befehlen und Abfragen

Obwohl die Komplexit?t eingeführt wird, ist diese Architektur in Systemen sehr wertvoll, die eine hohe überwachbarkeit und Skalierbarkeit erfordern.

Grunds?tzlich alles ist der Schlüssel zu verstehen, dass "Zustand das Ergebnis von Ereignissen ist" und dass "Lesen und Schreiben unterschiedliche Wege aufnehmen k?nnen".

Das obige ist der detaillierte Inhalt vonEreignisbeschaffung und CQRS -Muster in Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!