昨天上午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的优点：
Brave推出图像和视频搜索引擎Brave Search:金色财经报道，专注于隐私的搜索引擎和浏览器制造商Brave宣布推出自己的隐私保护图像和视频搜索Brave Search。该公司解释说，这意味着用户在想要图像或视频搜索结果时将不再需要离开Brave，因为结果现在将直接从Brave Search自己的独立索引提供。
Brave曾在4月份宣布将不再使用Bing的索引，该索引此前占所有查询结果的7%。Brave表示，图像和视频搜索功能已经开发了几个月，其结果现在也将通过最近推出的Brave Search API提供。[2023/8/4 16:17:43]
每个状态发生的改变都有完备的日志记录，可追溯
优化了的写的操作，提高了性能
我们身边的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某种程度上就解决了这样的问题。
加密交易所CoinMENA完成950万美元种子轮融资，Alameda Research等参投:11月8日消息，总部位于巴林的法币-加密交易所CoinMENA完成950万美元种子轮融资，BECO Capital、Kenetic Capital、Arab Bank Switzerland、Bunat Ventures、Alameda Research、Girnas Capital参投。
据悉，CoinMENA于2021年初由Dina Saman、Talal Tabbaa、Yazan Barghuthi推出，旨在促进在海湾地区便捷和安全地进行加密投资，重点关注巴林、阿拉伯联合酋长国、沙特阿拉伯和中东和北非市场的其他地区。该公司是一家由巴林中央银行授权的完全受监管的境内加密交易所。（福布斯）[2021/11/8 6:38:32]
CQRS是什么？
CQRS全称是CommandQueryRsponsibilitySegregation，将应用程序分为两部分：命令端(Command)和查询端(Query)。命令端处理程序创建，更新和删除请求，并在数据更改时发出事件。查询端通过执行查询来处理查询，并且通过订阅数据更改时发出的事件流而保持最新。CQRS使用分离的接口将数据查询操作(Queries)和数据修改操作(Commands)分离开来，这也意味着在查询和更新过程中使用的数据模型也是不一样的。这样读和写逻辑就隔离开来了。
CQRS里面的一些概念：
Command(命令):不返回任何结果，被校验成功后但会改变对象的状态。
为以太坊矿工提供套利工具的项目Archer治理代币上线Uniswap:匿名团队开发的以太坊矿工可提取价值（MEV）套利产品Archer的治理代币ARCH已上线Uniswap，项目方提供的初始流动性为370个ETH和100万个ARCH，官方称这部分流动性将会被锁定至少6个月。ARCH代币总量为1亿枚，以初始流动性的价格计算，该项目的总市值超过2000万美元。
注：Archer通过使用链上激励机制来为矿工增加收入来源，包括通过DEX套利和贷款清算等零风险或风险较低的方式为开采出来的区块增加价值。Archer表示自己有助于提升以太坊用户体验，包括降低抵押率、使各个DEX的现货价格趋于一致、更可靠的激励机制、减少不友好的抢先交易频率以及通过私有渠道提交交易。[2020/11/23 21:48:13]
Query(查询):有返回结果，但是不会改变对象的状态。
Aggregate(聚合):保存状态,处理command，和改变状态。
EventStore:存储Events。
怎么遵循CQRS模式建立应用程序?
首先我们会基于一个Commanded,一个Elixir遵循CQRS/ES模式实现Commandside的库。
1.Commands
Commands是用户发送给应用程序的指令，表示用户的一种请求，当然请求是有可能失败的，如果想在余额有10的账户里面取出1000块这样的操作。每一个指令对应是一个module，然后使用defstruct定义域，命名方式是MineCoin，动名结构。
动态 | CMC将整合机构级数字资产评估产品SIMETRI Research:据Crypto Briefing消息，CoinMarketCap（CMC）将整合机构级数字资产评估产品SIMETRI Research。[2019/7/10]
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。
分析 | Research and Markets：加密货币硬件钱包市场五年内将达5亿美元:据bitcoinexchangeguide报道，市场研究机构Research and Markets最近的一份报告显示，在过去的5年里，加密货币硬件钱包的市场增长了300％以上。报告称，硬件钱包市场在2018年价值为1.2869亿美元，预计到2024年将达到4.999亿美元，年均复合增长率为24.93％（2019年至2024年）。[2019/3/15]
|{: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
↙点击登陆报名听课
郑重声明： 本文版权归原作者所有， 转载文章仅为传播更多信息之目的， 如作者信息标记有误， 请第一时间联系我们修改或删除， 多谢。