作者:京東科技 倪新明
CQRS只是一種非常簡單的模式(pattern),CQRS本身并不是一種架構風格,和最終一致性/消息/讀寫分離/事件溯源/DDD等沒有必然的聯(lián)系,它最大優(yōu)勢是給我們帶來更多的架構屬性選擇
命令和查詢分離,Command and Query Segregation,其核心思想是在任何一個對象的方法可以劃分為兩類
(資料圖片)
?查詢:獲取數(shù)據(jù),返回查詢數(shù)據(jù),但不改變數(shù)據(jù)狀態(tài)
?命令:改變數(shù)據(jù)狀態(tài),不返回任何數(shù)據(jù)
基于CQS的思想,任何一個方法都可以拆分為命令和查詢兩部分:
private int origin = 0;private int add(int value){ origin += value; return origin;}
上述方法既改變了數(shù)據(jù),又返回了數(shù)據(jù)狀態(tài),如果按照CQS的思想,則該方法可以拆成Command和Query兩部分,如下:
private void add(int value){ origin += value;}private int queryValue(){ return origin;}
是否嚴格遵循上述約定存在爭議,對于命令側是否返回數(shù)據(jù)實際業(yè)務訴求中并不一定能夠完全統(tǒng)一。比如:
?"出棧" 操作同時改變棧狀態(tài)和返回數(shù)據(jù)
?某些業(yè)務場景下可能會有返回業(yè)務主鍵的訴求,比如下單操作返回訂單號
Command and Query Responsibility Segregation,即命令查詢職責分離,由Greg Young提出 。CQRS在CQS基礎之上,將分離的級別從代碼方法級別擴展到對象級別。CQRS 模式的應用非常簡單,如下圖所示
?
??
假設我們的服務為 OrderService,在非CQRS模式下同時包含了查詢和更新服務接口:
public class OrderService { // 根據(jù)id查詢訂單 Order getOrder(OrderId) // 查詢已支付訂單 ListgetPayedOrders() // 下單 void placeOrder(Order) // 取消訂單 void cancelOrder(OrderId) }
應用CQRS模式之后的OrderService被拆分成了兩個接口,分別承擔查詢和寫職責:
/**命令側服務*/public class OrderService { void placeOrder(PlaceOrderCommand command) void cancelOrder(CancelOrderCommand command)}/** 查詢服務*/public class OrderQueryService{ Order GetOrder(OrderId) ListgetPayedOrders()}
以上這種簡單的分離就是CQRS模式的全部了,是不是非常簡單?確實,單純的看,CQRS的確就是這么簡單。
CQRS最大優(yōu)勢就是基于這種職責分離能帶給我們更多的架構屬性選擇。
?“查詢” 和 “命令” 兩側進行獨立部署以獲取更好的伸縮性
?“查詢” 和 “命令” 兩側獨立架構設計
?“查詢” 和 “命令”兩側進行獨立數(shù)據(jù)模型設計
基于CQRS,我們可以衍生出更多的架構屬性,結合實際的業(yè)務場景,進行差異化的架構設計。
團隊引入CQRS模式之后,往往不僅僅是簡單的在類的職責層面對讀寫進行分離,一般會采用更為復雜的應用架構風格,如下是典型的CQRS架構風格:
?
??
?命令側:命令側引入命令總線以支持對不同命令的靈活路由;突出領域模型的應用
?查詢側:引入查詢總線對查詢請求進行路由;請求鏈路一般直接連接到存儲層,實現(xiàn)不同的定制化查詢需求
CQRS強調命令和查詢的職責分離,但在底層的數(shù)據(jù)模型層面,CQRS并沒有進行強制限定,即采用CQRS模式并沒有要求必須要進行數(shù)據(jù)模型的分離。是否要進行模型分離開發(fā)人員需要具體情況具體分析。
?分離模型:查詢側和寫側模型不互相干擾,各自在應用層的實現(xiàn)復雜度比較低。但由于模型的分離,命令側和查詢側的數(shù)據(jù)一致性需要納入考慮范圍
?不分離:不需要考慮數(shù)據(jù)一致性問題,但由于查詢側和寫側對模型的訴求可能不一致,模型的設計往往需要折衷考慮。
CQRS和消息模式沒有必然聯(lián)系,落地CQRS 并不一定需要使用消息模式。
?
??
如果我們采用了CQRS模式,但是命令和查詢兩側底層所依賴的數(shù)據(jù)模型并未分離,而是基于共享的數(shù)據(jù)存儲和數(shù)據(jù)模型,命令和查詢之間不需要額外的交互,命令側的數(shù)據(jù)更新對查詢側實時可見。在這種架構模式下,兩側基于共享的數(shù)據(jù)已經天然的集成在一起,不需要額外機制進行通信,自然也無需引入消息了。如果我們采用CQRS模式,并且命令和查詢兩側進行了數(shù)據(jù)模型的分離,二者各自依賴獨立的數(shù)據(jù)模型。同時,數(shù)據(jù)存儲也分開部署。命令側負責數(shù)據(jù)的更新,而查詢側只負責數(shù)據(jù)的查詢,如何將數(shù)據(jù)的更新及時同步到查詢側是需要解決的問題。在這種架構模式下,使用消息模式作為兩側的通信機制是個不錯的選擇,當然,這并不是唯一的選項。
ES 并不是一個新的概念,在最早的金融系統(tǒng)中就已經應用。要了解ES,我們需要先看看傳統(tǒng)的數(shù)據(jù)存儲。在傳統(tǒng)應用中,數(shù)據(jù)庫例如MySQL(假設存儲介質是數(shù)據(jù)庫,)中存儲的始終是數(shù)據(jù)的最新的狀態(tài)。例如我們對某條用戶的信息進行了多次的修改或編輯,然后保存將數(shù)據(jù)存儲到數(shù)據(jù)庫中。無論何時,數(shù)據(jù)庫中都會記錄最后的、最新的用戶狀態(tài)。我們只要根據(jù)id或其他信息查詢數(shù)據(jù)庫中相應的記錄就能獲取該用戶的最新信息。這是應用中典型的數(shù)據(jù)存儲特點。
當然,我們可以基于特定的數(shù)據(jù)模型設計以保存數(shù)據(jù)的更改記錄。???
?
這種數(shù)據(jù)存儲模式的特點是簡單,不需要額外的維護復雜的設計,我們能夠非常容易的獲取最新的用戶信息。但是不幸的是,我們丟失了歷史信息,包括用戶的意圖信息。而這些信息則有助于我們進行數(shù)據(jù)回滾、用戶行為分析以及開發(fā)過程中的調試等等。
?
??
在ES模式下,數(shù)據(jù)庫中存儲的不在是數(shù)據(jù)最新狀態(tài),而是數(shù)據(jù)的變更記錄,更官方的說法是 “事件(Event)”。數(shù)據(jù)庫中存儲的數(shù)據(jù)變化的事件流。我們基于事件流可以對最新狀態(tài)進行重建,同時也可以便捷的重現(xiàn)任何歷史節(jié)點數(shù)據(jù)。ES需要解決大量事件的存儲和高效的實例重建問題,后續(xù)單獨的文章再介紹ES。
最終一致性也常常在服務之間引入,最終一致性的目的是為了提高擴展性和可用性。
CQRS和最終一致性同樣沒有必然的聯(lián)系。往往采用CQRS后,查詢和命令兩側會采用獨立的數(shù)據(jù)模型,在這種架構模式下,命令側的數(shù)據(jù)變化后及時同步到查詢側,兩側數(shù)據(jù)并非實時,在一定的延時后兩側數(shù)據(jù)最終達成一致。
CQRS的最大優(yōu)勢在于通過將命令和查詢的職責分離,為架構師提供了更多的架構屬性選擇,我們可以在查詢側和命令側進行獨立的架構設計。對象級別的職責分離就是CQRS的全部了,但在實踐中涌現(xiàn)出了很多更為靈活也更為復雜的架構風格,比如總線的引入、數(shù)據(jù)模型的分離、一致性報這個策略、事件溯源等等。額外的組件或技術的引入必然導致復雜性和成本上升,這些選型的采納需要團隊的權衡。