事件溯源和CQRS適用於復(fù)雜業(yè)務(wù)系統(tǒng)，1. 事件溯源通過保存事件序列重建狀態(tài)，提供完整審計和時間旅行能力，但增加查詢複雜度；2. CQRS分離讀寫模型，提升擴展性和性能，但引入最終一致性；3. 在Java中可通過Axon Framework結(jié)合Spring Boot實現(xiàn)，使用@Aggregate處理命令，@EventSourcingHandler更新狀態(tài)，@EventHandler構(gòu)建讀模型；4. 適用於需高審計性、讀寫負(fù)載不均的場景，不適用於簡單CRUD系統(tǒng)；5. 注意事件不可變、版本控制、最終一致性處理和調(diào)試複雜性。該架構(gòu)在高要求系統(tǒng)中具有重要價值。

事件溯源（Event Sourcing）和命令查詢職責(zé)分離（CQRS）是現(xiàn)代分佈式系統(tǒng)中處理複雜業(yè)務(wù)邏輯和提升系統(tǒng)可擴展性的兩種重要模式。在Java 生態(tài)中，結(jié)合Spring Boot、Axon Framework 等工具，可以高效實現(xiàn)這兩種模式。下面從概念、應(yīng)用場景、實現(xiàn)方式和注意事項幾個方面來解析。

什麼是Event Sourcing 和CQRS？

1.事件溯源（Event Sourcing）

傳統(tǒng)系統(tǒng)中，我們通常只保存實體的當(dāng)前狀態(tài)（如用戶餘額為100 元）。而事件溯源的核心思想是：不直接保存狀態(tài)，而是保存導(dǎo)致狀態(tài)變化的事件序列。

例如，用戶賬戶的餘額變化不是直接更新balance 字段，而是記錄：

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

狀態(tài)通過重放這些事件來重建。

優(yōu)點：

• 完整審計日誌
• 易於調(diào)試和回溯
• 支持時間旅行（重建任意時間點的狀態(tài)）

缺點：

• 查詢性能可能下降（需重放事件）
• 事件版本管理複雜
• 初學(xué)門檻較高

2. CQRS（Command Query Responsibility Segregation）

CQRS 將系統(tǒng)的讀寫操作分離：

• 命令（Command） ：修改數(shù)據(jù)，對應(yīng)寫模型（Write Model）
• 查詢（Query） ：讀取數(shù)據(jù)，對應(yīng)讀模型（Read Model）

這不僅僅是分層，而是允許使用不同的數(shù)據(jù)模型、數(shù)據(jù)庫甚至技術(shù)棧來處理讀寫。

典型結(jié)構(gòu)：

 Client → Command → Command Handler → Events → Event Store
                     ↓
               Event Handlers → Update Read Model (eg, SQL, Elasticsearch)
                     ↓
Client ← Query ← Read Model

優(yōu)點：

• 讀寫模型可獨立優(yōu)化
• 易於擴展（如讀多寫少場景可橫向擴展查詢服務(wù)）
• 更清晰的職責(zé)劃分

缺點：

• 系統(tǒng)複雜度上升
• 讀寫之間存在延遲（最終一致性）

Java 中如何實現(xiàn)？使用Axon Framework

Axon 是Java 中最流行的實現(xiàn)Event Sourcing 和CQRS 的框架，與Spring 集成良好。

添加依賴（Maven）

 <dependency>
    <groupId>org.axonframework</groupId>
    <artifactId>axon-spring-boot-starter</artifactId>
    <version>4.6.0</version>
</dependency>

示例：銀行賬戶轉(zhuǎn)賬

1. 定義事件

public class MoneyDepositedEvent {
    public final String accountId;
    public final double amount;

    public MoneyDepositedEvent(String accountId, double amount) {
        this.accountId = accountId;
        this.amount = amount;
    }
}

public class MoneyWithdrawnEvent {
    public final String accountId;
    public final double amount;

    public MoneyWithdrawnEvent(String accountId, double amount) {
        this.accountId = accountId;
        this.amount = amount;
    }
}

2. 聚合（Aggregate） - 寫模型

@Aggregate
public class BankAccount {

    @AggregateIdentifier
    private String accountId;
    private double balance;

    public BankAccount() {} // Required by Axon

    // Command Handler
    @CommandHandler
    public BankAccount(CreateAccountCommand command) {
        // 發(fā)布賬戶創(chuàng)建事件AggregateLifecycle.apply(new AccountCreatedEvent(command.accountId));
    }

    @CommandHandler
    public void handle(DepositMoneyCommand command) {
        if (command.amount <= 0) {
            throw new IllegalArgumentException("Amount must be positive");
        }
        AggregateLifecycle.apply(new MoneyDepositedEvent(command.accountId, command.amount));
    }

    @CommandHandler
    public void handle(WithdrawMoneyCommand command) {
        if (command.amount > balance) {
            throw new IllegalStateException("Insufficient funds");
        }
        AggregateLifecycle.apply(new MoneyWithdrawnEvent(command.accountId, command.amount));
    }

    // Event Sourcing Handler - 用於更新狀態(tài)@EventSourcingHandler
    public void on(MoneyDepositedEvent event) {
        this.balance = event.amount;
    }

    @EventSourcingHandler
    public void on(MoneyWithdrawnEvent event) {
        this.balance -= event.amount;
    }
}

3. 事件處理（更新讀模型）

 @Component
public class AccountProjection {

    private final AccountRepository accountRepository;

    public AccountProjection(AccountRepository accountRepository) {
        this.accountRepository = accountRepository;
    }

    @EventHandler
    public void on(MoneyDepositedEvent event) {
        AccountView account = accountRepository.findById(event.accountId)
            .orElse(new AccountView(event.accountId, 0.0));
        account.balance = event.amount;
        accountRepository.save(account);
    }

    @EventHandler
    public void on(MoneyWithdrawnEvent event) {
        AccountView account = accountRepository.findById(event.accountId)
            .orElseThrow();
        account.balance -= event.amount;
        accountRepository.save(account);
    }
}

4. 讀模型實體（用於查詢）

 @Entity
public class AccountView {
    @Id
    private String id;
    private double balance;

    // constructors, getters, setters
}

5. 查詢接口

@RestController
public class AccountQueryController {

    @Autowired
    private AccountRepository accountRepository;

    @GetMapping("/accounts/{id}")
    public AccountView getAccount(@PathVariable String id) {
        return accountRepository.findById(id).orElse(null);
    }
}

何時使用Event Sourcing CQRS？

• 業(yè)務(wù)邏輯複雜，需要審計追蹤（如金融、訂單系統(tǒng)）
• 讀寫負(fù)載差異大，需要獨立擴展
• 系統(tǒng)需要支持“撤銷”、“重放”、“時間旅行”
• 微服務(wù)架構(gòu)中，服務(wù)間通過事件通信

?? 不建議用於簡單CRUD 系統(tǒng)，會過度設(shè)計。

注意事項

• 事件不可變：一旦發(fā)布，不能修改，只能追加補償事件。
• 事件版本控制：當(dāng)事件結(jié)構(gòu)變化時，需支持序列化兼容或遷移。
• 讀模型一致性：CQRS 是最終一致，前端需處理“操作成功但查詢未更新”的情況。
• 調(diào)試難度增加：需要工具支持事件流查看、重放等。

總結(jié)

在Java 中，通過Axon Framework 可以較輕鬆地實現(xiàn)Event Sourcing 和CQRS：

• 使用@Aggregate管理寫模型
• 用@EventSourcingHandler更新聚合狀態(tài)
• 用@EventHandler構(gòu)建讀模型
• 命令和查詢徹底分離

雖然引入了複雜性，但在需要高可審計性、高擴展性的系統(tǒng)中，這種架構(gòu)非常有價值。

基本上就這些，關(guān)鍵在於理解“狀態(tài)是事件的結(jié)果”，以及“讀寫可以走不同的路”。

以上是Java中的事件採購和CQRS模式的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！