小米官宣：2023年上半年出貨量中國第一！
今日早間，小米電視官方微博帶來消息，稱2023年小米電視上半年出貨量達到了中國第一，同時還表示小米電視的巨屏風暴即將開始。“公布一個好消息2023年#小米電視上半年出貨量中國
微服務的興起以及現(xiàn)代軟件架構對可擴展性、靈活性和可維護性的需求，促使開發(fā)者采用各種設計模式。近年來，命令查詢責任分離（Command Query Responsibility Segregation，CQRS）模式在實踐中獲得大量推廣。CQRS特別適用于那些命令（用于修改狀態(tài)）和查詢（用于讀取狀態(tài)）之間存在明顯區(qū)別的系統(tǒng)。本文將深入探討CQRS，并演示如何使用Spring微服務進行實現(xiàn)。
命令查詢職責分離（CQRS）是一種架構模式，建議將數據修改操作（命令）與數據檢索操作（查詢）分離。這種分離允許為查詢和更新數據開發(fā)專門的模型，提高應用程序的清晰度和可擴展性。
CQRS 的核心目標是通過確保每個任務負責單個操作（命令或查詢，但絕不會同時負責兩者）來簡化任務。
CQRS并不是一個全新的概念。它的根源可以追溯到CQS（Command Query Separation，命令查詢分離）原則，該原則由Eiffel編程語言的創(chuàng)建者Bertrand Meyer推廣。盡管CQS主要關注方法層面，即一個方法應該執(zhí)行命令或回答查詢，但CQRS將這一原則擴展到了應用程序的架構層面，建議使用獨立的架構組件處理命令和查詢。
在分布式系統(tǒng)中，服務通常需要具有自治性和高度解耦，CQRS提供了一個清晰的路徑。每個微服務都可以采用CQRS模式，確保它處理命令和查詢的內部細節(jié)與其他服務分離。這也與領域驅動設計（DDD）非常契合，其中領域事件可以觸發(fā)不同微服務中的命令操作。
盡管CQRS帶來了許多好處，但也存在一些挑戰(zhàn)：
Spring生態(tài)系統(tǒng)中豐富的工具和框架非常適合在微服務環(huán)境中實現(xiàn)CQRS模式。
第一步是創(chuàng)建一個基本的Spring Boot項目。如果你是第一次使用Spring Boot，可以使用Spring Initializr初始化項目。可以根據自己偏好引入一些必需的依賴項包括Spring Web、Spring Data JPA、數據庫連接器等。
在基于Spring的CQRS系統(tǒng)中，命令表示改變某個狀態(tài)的意圖，而命令處理器則用于處理這些命令。
命令示例如下：
public class CreateUserCommand { private final String userId; private final String username; // 構造函數, getters，以及其他方法...}對于每個命令，都需要定義了相應的命令處理器。該處理器需要包含處理命令的實際邏輯，如下：
@Servicepublic class CreateUserCommandHandler implements CommandHandler<CreateUserCommand> { @Autowired private UserRepository userRepository; @Override public void handle(CreateUserCommand command) { User user = new User(command.getUserId(), command.getUsername()); userRepository.save(user); }}在領域驅動設計（DDD）的上下文中，狀態(tài)變更通常發(fā)生在聚合根上。這些聚合根需要遵循所有領域規(guī)則，然后在對數據變更進行持久化。
類似地，查詢表示讀取某些狀態(tài)的請求，而查詢處理器則處理這些請求。
查詢命令示例：
public class GetUserByIdQuery { private final String userId; // 構造函數, getters, 以及其他方法}對應的查詢處理器：
@Servicepublic class GetUserByIdQueryHandler implements QueryHandler<GetUserByIdQuery, User> { @Autowired private UserRepository userRepository; @Override public User handle(GetUserByIdQuery query) { return userRepository.findById(query.getUserId()).orElse(null); }}盡管CQRS提供了分離的機制，但使用事件溯源可以簡化在命令和查詢之間維護狀態(tài)的過程。Axon Framework是一個實現(xiàn)了CQRS和事件溯源的流行框架。
在Axon中，事件在命令處理后進行發(fā)布。這些事件可以被持久化，然后用于重新創(chuàng)建聚合根的狀態(tài)，有助于保持查詢端與命令端的同步。
考慮到微服務的分布式特性，實現(xiàn)服務之間的異步通信是非常有必要的。可以將Apache Kafka集成到Spring生態(tài)系統(tǒng)中，以實現(xiàn)強大的事件驅動架構，這在CQRS設置中尤其有用。
由命令端產生的事件可以推送到Kafka的主題中，查詢端可以消費這些事件來更新自己的數據存儲。這確保了命令端和查詢端之間的解耦，使系統(tǒng)更具彈性和可擴展性。
盡管CQRS專注于分離命令和查詢的責任，但事件溯源確保將應用程序狀態(tài)的每次更改捕獲在事件對象中，并按照應用順序存儲在相同聚合根上。這樣允許你重建過去的狀態(tài)，在與CQRS結合使用時特別有優(yōu)勢。
事件溯源是一種將領域事件持久化而不是持久化狀態(tài)本身的方式。這些事件捕獲狀態(tài)轉換。通過重新播放這些事件，可以重建聚合根的當前狀態(tài)。
例如，可以存儲銀行賬戶的所有交易（像存款和提款這樣的事件），而不是僅存儲當前余額。通過重新播放這些事件，可以計算出當前余額。
CQRS和事件溯源是相輔相成的，表現(xiàn)在以下幾個方面：
正如之前提到的，Axon Framework為在Spring應用程序中實現(xiàn)CQRS和事件溯源提供了一種無縫的方案：
@Aggregatepublic class Account { @AggregateIdentifier private String accountId; private int balance; @CommandHandler public void handle(WithdrawMoneyCommand cmd) { if (cmd.getAmount() > balance) { throw new InsufficientFundsException(); } apply(new MoneyWithdrawnEvent(cmd.getAccountId(), cmd.getAmount())); } @EventSourcingHandler public void on(MoneyWithdrawnEvent evt) { this.balance -= evt.getAmount(); }}盡管CQRS和事件溯源可以帶來巨大的好處，但也帶來了復雜性。
隨著時間的推移，事件的結構或語義可能會發(fā)生變化，從而帶來以下挑戰(zhàn)：
使用CQRS和事件溯源的系統(tǒng)與不遵循這些模式的外部系統(tǒng)集成可能具有挑戰(zhàn)性，特別是在數據同步和事務管理方面。
雖然有像Axon這樣的工具和框架支持CQRS和事件溯源，但它們可能并不完全適合所有場景。可能需要進行定制實現(xiàn)，這可能會增加項目的復雜性和持續(xù)時間。
CQRS為擴展和組織微服務提供了一種獨特的方式。當與Spring生態(tài)系統(tǒng)結合使用時，它可以提供一個強大的工具包，用于構建健壯、可擴展和易于維護的系統(tǒng)。然而，就像所有架構決策一樣，需要權衡利弊并確保它是否適合你的實際場景。
本文鏈接：http://www.tebozhan.com/showinfo-26-13617-0.html從CRUD到CQRS：使用Spring微服務轉變你的架構策略
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號