ArcBlock 课堂 ⑦ | Intro to CQRS and Commanded(全程视频 + 文字)

昨天上午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的优点:

滚石乐队与Nadya Tolokonnikova合作推出了“Matriarchy Now”NFT 系列:金色财经报道,滚石乐队与 Pussy Riot 联合创始人Nadya Tolokonnikova合作推出了“Matriarchy Now”NFT 系列。NFT 与著名摄影师和艺术家 Ellen von Unwerth 合作创作,将在 Coinbase NFT 市场上发布。[2023/1/5 9:53:32]

每个状态发生的改变都有完备的日志记录,可追溯

优化了的写的操作,提高了性能

我们身边的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是什么?

Dour Darcels24小时交易额近200万美元,增幅166.42%:3月11日,据 NFTGO.io 数据显示,NFT 项目 Dour Darcels 24 小时交易额达 199 万美元,增幅 166.42%,当前地板价为 0.864 ETH,涨幅 140.59%。[2022/3/11 13:51:16]

CQRS全称是CommandQueryRsponsibilitySegregation,将应用程序分为两部分:命令端(Command)和查询端(Query)。命令端处理程序创建,更新和删除请求,并在数据更改时发出事件。查询端通过执行查询来处理查询,并且通过订阅数据更改时发出的事件流而保持最新。CQRS使用分离的接口将数据查询操作(Queries)和数据修改操作(Commands)分离开来,这也意味着在查询和更新过程中使用的数据模型也是不一样的。这样读和写逻辑就隔离开来了。

CQRS里面的一些概念:

Command(命令):不返回任何结果,被校验成功后但会改变对象的状态。

Query(查询):有返回结果,但是不会改变对象的状态。

Aggregate(聚合):保存状态,处理command,和改变状态。

EventStore:存储Events。

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

首先我们会基于一个Commanded,一个Elixir遵循CQRS/ES模式实现Commandside的库。

1.Commands

Opium融资325万美元,Alameda Research等参投:加密衍生品交易所Opium获得325万美元融资,投资者包括QCP Soteria、Kenetic Capital和Alameda Research。

Opium创始人兼CEO Andrey Belyakov表示,创建Opium是为了解决传统衍生品市场的三个问题:透明度、进入壁垒和成本效益。这三个问题都可以通过区块链解决,因为这样“每个人都可以运行自己的衍生品”。Belyakov表示,“我们短期内正在提高DeFi的效率,但我们的长期目标是在这个巨大的市场上与传统衍生品竞争。”

上个月,Opium推出USDT信用违约掉期产品。该公司还计划推出不同的信用违约掉期,以与保险市场上的其他解决方案竞争。(CoinDesk)[2020/11/2 11:28:32]

Commands是用户发送给应用程序的指令,表示用户的一种请求,当然请求是有可能失败的,如果想在余额有10的账户里面取出1000块这样的操作。每一个指令对应是一个module,然后使用defstruct定义域,命名方式是MineCoin,动名结构。

defmoduleMineCoindo

defstruct[

:account_id,

:nonce

]

end

2.Events

Events是由Command产生,最终导致状态改变。会最终在eventstore里面序列化存储,可以用于日后想要恢复状态。命名方式相比于Command来说发生了变化,CoinMined,过去式表达一种过去发生的事实。

动态 | 德国汽车制造商戴姆勒完成在区块链贸易融资平台 Marco Polo 首个交易:总部位于德国的汽车制造商戴姆勒完成其在联盟链组织 R3 旗下区块链贸易融资平台 Marco Polo 的首个贸易交易,该笔交易是戴姆勒公司处理与零件制造商 Dürr 执行首付款的数据,德国 LBBW 银行也参与该笔交易。 Dürr 首席财务官 Susanne Schlegel 表示,该笔成功的交易表明了提高数字贸易融资流程的内在效率的潜力,Marco Polo 和 Corda 等创新平台和技术能够“降低订单履行的复杂性”。据此前报道,今年 8 月,Macro Polo 表示其“自动触发付款”为该平台的里程碑之一。Marco Polo 平台由联盟链组织 R3 和 TradeIX 于 2017 年合作开发,基于 R3 的 Corda 平台搭建,旨在降低融资成本,目前成员包括美国银行、法国巴黎银行、德国商业银行、万事达卡等 26 个金融机构。[2019/9/25]

defmoduleCoinMineddo

defstruct[

:account_id,

:nonce

]

end

3.Aggregates

Aggregates作为接受处理Command,产生或者引起对应事件的发生,以及一些改变状态的处理器。

里面包含两个函数:execute方法使用来添加我们的校验Command的一些逻辑,输入时状态和command,如果成功输出就是Event。apply函数用来更改状态,注意这里的对象是已经是生成出来的event。

分析 | Cumberland Research:市场过于关注以太坊君士坦丁堡硬分叉:据cointelegraph报道,Cumberland Research最近分享的一份报告显示,市场过于关注以太坊君士坦丁堡硬分叉和Serenity升级,使重要的升级蒙上阴影。根据该报告,当前状态下的以太坊网络无法支持数百万个DAPP以及以太坊虚拟机(EVM)架构的不灵活性,ETH向完整PoS过渡的任何进一步延迟都会加剧那些问题。[2019/2/7]

|{: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

↙点击登陆报名听课

郑重声明: 本文版权归原作者所有, 转载文章仅为传播更多信息之目的, 如作者信息标记有误, 请第一时间联系我们修改或删除, 多谢。

银河链

屎币IDAX开放LINDA充提、交易公告

亲爱的用户:?? ??IDAX将上线LINDA。开通LINDA/BTC交易。???充值开放时间:10月27日14:00(UTC08:00)??交易开放时间:10月28日14:00(UTC08:00)??提币开放时间:10月29日14:.

MANAIDAX开放XRP充提、交易公告

亲爱的用户:?? ??IDAX已上线XRP。开通XRP/ETH交易,立即前往。 规则说明: ???1、关于XRP ???2、费率说明 音乐制作人Don Jazzy和说唱歌手MI Abaga担任Quidax品牌大使:3月27日消息,音乐.

BTCPX强势登陆IDAX,交易PX返80%手续费

活动时间:10月18日14:00:00–10月21日14:00:001活动期间,参与交易PX的用户将会获得80%手续费返还!手续费折算成PX进行返还。交易越多,返还越多.

[0:15ms0-2:283ms