比特幣交易所 比特幣交易所
Ctrl+D 比特幣交易所
ads
首頁 > Luna > Info

ArcBlock 課堂 ⑦ | Intro to CQRS and Commanded(全程視頻 + 文字)_BLOCK

Author:

Time:1900/1/1 0:00:00

昨天上午8:00,ArcBlockTechnicalLearningSeries第六期“IntrotoCQRSandCommanded”,由ArcBlock后端工程師周蕾講授。

#講座全程視頻

#講座全程文字:淺談查詢職責分離(CQRS)模式

最近幾年,在DDD的領域,我們經常會看到CQRS架構的概念,CQRS是查詢職責分離模式(CommandQueryResponsibilitySegregation)的縮寫。正好這些日子Arcblock的后端的服務有考慮使用CQRS的架構,所以今天和大家一起分享一下最近的研讀收獲。今天會從EventSourcing出發介紹CQRS,以及通過Commanded,一起看一看如何遵循ES/CQRS的概念開發應用程序。

什么是EventSourcing(事件溯源)?

EventSourcing本質來說是保存了發生事件的本身,而不是當前的事物的狀態。在EventSourcing的概念里,Event作為既定的發生之后的事情,也是最小的單位。比如:

EventSourcing的工作模式:在下面這條數據流里面,由4個發生的事件(event)組成,進而每一次改變當前的狀態,同時事件們的相對順序也是我們需要保證的。

我們會得到這樣的總結:

Sn=apply(Sn-1,En)或者Sn=reduce(E,S0,apply)

其中:(S:state,E:Event)

現在我們可以發現EventSourcing的優點:

每個狀態發生的改變都有完備的日志記錄,可追溯

優化了的寫的操作,提高了性能

我們身邊的EventSourcing

每個程序員的每天都離不開的Github。在Git的世界里,Events(事件)是Commits,State(狀態)是文件系統。

WAL:也就是Write-aheadlogging,在數據寫入到數據庫之前,先寫入到日志,再將日志記錄變更到存儲器中。Events(事件)是每一個操作,State(狀態)是數據庫。

對于EventSourcing來說,想做查詢(query)怎么辦?

試想一下,在一個銀行系統里面,如果我們想要查詢賬戶余額在1000塊以上的用戶,那我們難道需要把每個賬戶的按照Sn=reduce(E,S0,apply)這個公式在重新計算一遍嗎?如果我們考慮用一個DB來保存Event,再用另外一個DB去專門為Query提供數據,同時兩個DB通過發送消息進行信息同步,如何?CQRS某種程度上就解決了這樣的問題。

CQRS是什么?

CQRS全稱是CommandQueryRsponsibilitySegregation,將應用程序分為兩部分:命令端(Command)和查詢端(Query)。命令端處理程序創建,更新和刪除請求,并在數據更改時發出事件。查詢端通過執行查詢來處理查詢,并且通過訂閱數據更改時發出的事件流而保持最新。CQRS使用分離的接口將數據查詢操作(Queries)和數據修改操作(Commands)分離開來,這也意味著在查詢和更新過程中使用的數據模型也是不一樣的。這樣讀和寫邏輯就隔離開來了。

CQRS里面的一些概念:

Command(命令):不返回任何結果,被校驗成功后但會改變對象的狀態。

Query(查詢):有返回結果,但是不會改變對象的狀態。

Aggregate(聚合):保存狀態,處理command,和改變狀態。

EventStore:存儲Events。

怎么遵循CQRS模式建立應用程序?

首先我們會基于一個Commanded,一個Elixir遵循CQRS/ES模式實現Commandside的庫。

1.Commands

Commands是用戶發送給應用程序的指令,表示用戶的一種請求,當然請求是有可能失敗的,如果想在余額有10的賬戶里面取出1000塊這樣的操作。每一個指令對應是一個module,然后使用defstruct定義域,命名方式是MineCoin,動名結構。

defmoduleMineCoindo

defstruct[

:account_id,

:nonce

]

end

2.Events

Events是由Command產生,最終導致狀態改變。會最終在eventstore里面序列化存儲,可以用于日后想要恢復狀態。命名方式相比于Command來說發生了變化,CoinMined,過去式表達一種過去發生的事實。

defmoduleCoinMineddo

defstruct[

:account_id,

:nonce

]

end

3.Aggregates

Aggregates作為接受處理Command,產生或者引起對應事件的發生,以及一些改變狀態的處理器。

里面包含兩個函數:execute方法使用來添加我們的校驗Command的一些邏輯,輸入時狀態和command,如果成功輸出就是Event。apply函數用來更改狀態,注意這里的對象是已經是生成出來的event。

|{:error,term(。

@specapply(state,event)::state

現在我們有了Command,Event,Aggregates...

那我們還需要一個派遣的角色幫助我們把Command走向對應的Aggregates。Commanded庫提供了Router:

defmoduleCoins.Routerdo

useCommanded.Commands.Router

aliasCoins.Account

aliasCoins.Commands,as:C

dispatch(

[

C.MineCoin

],

to:Account

)

end

最后我們使用Commanded推薦的EventStore,它是基于PostgreSQL作為存儲引擎,來保存Events。

現在我們可以說是齊活了,可以發現我們構建了如下的整個流程:這樣我們就可以愉快發布Commands和生成對應的Events。

最后怎么進行數據同步到讀取的DB里呢?

在這里Commaned庫推薦了CommandedEctoprojections來做Eventhandler,或者也可以采用Kafka同步信息,在這里就基于不同的應用場景選擇適合的Eventhandler。

主講

周蕾

ArcBlock后端工程師

●美國東北大學畢業

●信息系統計算機專業碩士

●區塊鏈技術愛好者

●編程語言:ElixirJavaScriptPython

下周三上午8:00,同一時間,ArcBlock區塊鏈技術培訓系列講座第7期,現在開放報名!

點擊文末左下角“閱讀原文”登陸注冊:

https://hack.arcblock.io/learning/

或登陸掘金注冊:

https://juejin.im/events/all

ArcBlock課堂①|IntrotoGraphQLandAbsinthe

ArcBlock課堂②|IntrotoEthereumSmartContract

ArcBlock課堂③|IntrotoAWSDataPipelineServices

ArcBlock課堂④|IntrotoAWSAthena

ArcBlock課堂⑤|WhatisAWSKinesis

ArcBlock課堂⑥|多步驗證那些事

ArcBlock課堂預告|是的,我們將開放大部分技術講座

相關閱讀:

ArcBlock課堂預告|是的,我們將開放大部分技術講座

ArcBlock課堂①|IntrotoGraphQLandAbsinthe

ArcBlock課堂②|IntrotoEthereumSmartContract

ArcBlock課堂③|IntrotoAWSDataPipelineServices

ArcBlock課堂④|IntrotoAWSAthena

ArcBlock課堂⑤|WhatisAWSKinesis

ArcBlock課堂⑥|多步驗證那些事

ArcBlock博客|北京黑客馬拉松小記

ArcBlock黑客松③|360分鐘11個DApp北京黑客創意令人大開眼界

ArcBlock北京黑客松,你來不來?

ArcBlock黑客松②|新SDK亮相黑客應用質量更高

ArcBlock活動|首場內測版黑客馬拉松成功舉行

ArcBlock博客|Exchange服務的工作流程以及如何集成到OCAP服務

ArcBlock博客|OCAP超簡易集成攻略

ArcBlock博客|OCAP超簡易集成攻略

ArcBlock博客|淺析數據對區塊鏈行業發展的重要性

ArcBlock博客|開放鏈訪問協議為何采用GraphQL

ArcBlock博客|如何解析BITCOIN的數據

ArcBlock博客|30天21個版本OCAPPlayground都經歷了哪些變化?

ArcBlock博客|如何在幾十個Repo中游刃有余?

ArcBlock博客|OCAPPlayground入門指南

ArcBlock分享|冒志鴻:公鏈性能焦慮是被EOS忽悠了

ArcBlock分享|冒志鴻:從互聯網、移動互聯網到區塊鏈,20年方法論總結

ArcBlock分享|從OCAP到Blocklet,為傳統開發者打開邁向區塊鏈的大門

ArcBlock分享|OCAPPlayground讓區塊鏈開發變得更友好

更多ArcBlock區塊基石信息,可關注以下渠道了解:

Twitter|https://twitter.com/ArcBlock_io

Instagram|https://www.instagram.com/arcblock/

Facebook|https://www.facebook.com/arcblock.io/

Telegram|https://t.me/ArcBlock

LinkedIn|https://www.linkedin.com/company/18355951/

Reddit|https://www.reddit.com/r/arcblock/

Medium|https://medium.com/arcblock

微博|https://weibo.com/realArcBlock

微信群|加拉群小助手:Ddchain

電報群|Telegramgroups:

Telegram(English):https://t.me/ArcBlock

Telegram(繁體中文):https://t.me/ArcblockAsian

↙點擊登陸報名聽課

Tags:BLOLOCLOCKBLOCKBLOCKIFY價格blocplatformblockidentitytokenblockchain交易所

Luna
交易瓜分500萬CEC_ITZ

交易瓜分500萬CEC!活動時間:香港時間?2018?年?11?月16?日?15:00-2018?年?11?月21?日?15:00 活動規則: 1.活動期間.

1900/1/1 0:00:00
CyberMiles最新答疑,了解一下_CYBER

CyberMiles創始人&CEO盧亮博士對社區關心的問題做了詳細解答,以下是部分文字實錄,完整問題可點擊閱讀原文聽盧總解答.

1900/1/1 0:00:00
?Pundi X(NPXS)上線DigiFinex的公告_DIG

親愛的用戶: DigiFinex將于2018年11月13日15:30(GMT8)上線PundiX(NPXS),并同步開啟充幣服務.

1900/1/1 0:00:00
星云周報第55期:行業精英云集“公有鏈技術聯盟”成立發布會_NEB

歡迎來到第55期星云周報NebulasWeekly,我們在這里發布Nebulas星云項目最新動態。Nebulas星云周報由Nebulas星云團隊維護.

1900/1/1 0:00:00
【公告】關于CoinPark支持Bitcoin Cash(BCH)硬分叉的公告_COIN

親愛的用戶: CoinPark支持BitcoinCash的硬分叉。我們將于新加坡時間2018年11月16日00:40:00進行快照,并將于新加坡時間11月15日23:00:00暫停BCH的充值、.

1900/1/1 0:00:00
“我”與INT不得不說的故事 ——INT蓋亞計劃獲獎者專訪_比特幣

編者按: 11月1日,備受關注的INT蓋亞計劃征文大賽終于公布了獲獎作品名單,至此宣告蓋亞計劃圓滿落幕.

1900/1/1 0:00:00
ads