比特幣價格 比特幣價格
Ctrl+D 比特幣價格
ads
首頁 > PEPE幣 > Info

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

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:BLOLOCLOCKBLOCKBlock Galaxy Networkblockchain錢包官網blockchainappblock幣有價值長期持有嗎

PEPE幣
OPX:【公示】OPX交易量/凈買入量大賽每日排名(11.14)_TER

?OPX于2018.11.13上線LBank,并展開每日交易量/凈買入量大賽。現公示每日交易排名數據如下:11.14日交易量數據排名公示11.14日凈買入量數據排名公示 尊敬的LBank用戶:.

1900/1/1 0:00:00
BOT:預告| 微軟云、阿里云和京東云助力Bottos超級節點培訓_bottos

各位鉑粉們,備戰Bottos4.0產品主網12月上線的超級節點培訓即將開始啦!~滿心期待~為了避免大家對超級節點概念不清楚.

1900/1/1 0:00:00
NEB:Nebulas NOVA, 想在世界各地大聲說我鐘意你!_NEBULA價格

10月31日,正值比特幣白皮書誕生十周年之際,星云研究院發布了《星云開發者激勵協議紫皮書》。紫皮書的發布是NebulasNOVA的又一重大里程碑.

1900/1/1 0:00:00
COIN:主板A免手續費機制調整預告_OIN

親愛的社區用戶: FCoin主板A區持有FT免手續費機制的公告?約定:“實行持有10000FT即免交易手續費的方案”.

1900/1/1 0:00:00
CRA:【系統】BCEX即將開啟買MATO送20%超值優惠活動,雙十壹活動提前打響_CRASH價格

尊敬的BCEX用戶: ????????BCEX已於10月30日上線MATO,開放MATO/ETH、MATO/CK.USD交易對,用戶交易尤其活躍.

1900/1/1 0:00:00
UCO:UCOT(優物鏈)舉辦2018創富中國中澳投資人高峰論壇_DaleCoin

這是優物鏈的第149篇原創文章 點上方藍字優物鏈加關注 全文約2442字,建議閱讀時間約9分鐘本文多圖,建議wifi環境下閱讀在澳洲政府對區塊鏈技術以及運用的大力支持下.

1900/1/1 0:00:00
ads