基于事件驱动架构构建微服务第8部分:在应用程序上实现事件溯源

原文链接:https://logcorner.com/building-microservices-through-event-driven-architecture-part8-implementing-eventsourcing-on-application/

在本文中,我将讨论应用程序上的事件溯源实现。

该层围绕领域并实现用例(特定于应用程序的业务规则)。

它编排数据流并使用领域模型和基础架构,并且不依赖于数据库、UI或特殊框架。

出于我们的事件溯源系统的目的,我将从聚合中取出所有未提交的事件并调用仓储的函数,该函数负责将事件保存在事件存储中。所以我会调用IEventStoreRepository 的AppendAsync(EventStore @event)函数。

因为我还没有实现更新,所以我不会关心聚合版本,(我有一个创建语音的post方法,所以聚合版本将始终等于0)。当我实现更新时,我会关注应用层和表现层中的聚合版本。

事件溯源接口

我可以定义两个接口IEventSourcingSubscriber和IEventSourcingHandler,您可以使用另一种命名约定,但现在我保留它们原样。

  • Subscribe 一个函数,它从聚合中获取所有未提交的事件,并为每个事件调用一个函数Handle,该函数将事件和当前聚合版本作为输入。

Handle是将事件序列化为字符串并调用IEventStoreRepository的AppendAsync(EventStore @event)的函数。

事件溯源实现

事件资源订阅者实现

所以第一个测试应该是:没有未提交事件的订阅不应该调用Handle

我没有未完成的事件,我什么也不做。然后断言部分将如下所示:

mockEventSourcingHandler.Verify(m => m.Handle(It.IsAny<Event>(),It.IsAny<long>()), Times.Never, “Handle must not be called”);

测试用例1:没有未提交事件的订阅不应调用Handle:

到这里,我将完成我的函数的实现

测试用例2:订阅未提交的事件应该只调用一次Handle:

mockEventSourcingHandler.Verify(m => m.Handle(It.IsAny<Event>(),It.IsAny<long>()), Times.Once, “Handle must be called only once”).

在Assert部分,我可以验证Handle函数仅被调用一次。

EventSourcingSubscriber的最终实现应该是这样的:

我为每个事件调用Handle函数。

事件源处理程序实现

测试用例3:处理空事件应该引发EventNullException:

我模拟了一些依赖项并验证如果事件为空,那么Handle应该引发异常。

下面是测试的实现。

测试用例34:处理事件应调用AppendAsync:

这里我验证如果事件不为空,那么Handle应该调用AppendAsync

下面是测试的实现。您可以观察到我使用 IEventSerializer 接口将事件序列化为 json 字符串,此 json 字符串将作为事件流的有效负载。

更新REGISTERSPEECHUSECASE

然后更新RegisterSpeechUseCase并调用Subscribe函数:await _domainEventSubscriber.Subscribe(speech);

更新PRESENTATION

打开Startup.cs文件并配置一些依赖注入

打开appsettings.Development.json并更新ConnectionStrings以使用适当的数据库服务器、数据库名称和凭据。

创建数据库的脚本位于LogCorner.EduSync.Speech.Database项目中

使用POSTAMAN测试

使用VISUAL STUDIO测试本地代码

选择LogCorner.EduSync.Speech.Presentation项目并点击F5

启动postman并运行以下HTTP Post

Endpoint : http://localhost:62694/api/speechMethod : POSTContent-Type: application/jsonBody : {
“Title”:”Le Lorem Ipsum est simplement du faux texte”,
“Description”:”Le Lorem Ipsum est simplement du faux texte employé dans la composition et la mise en page avant impression. Le Lorem Ipsum est le faux texte standard de l’imprimerie depuis les années 1500, quand un imprimeur anonyme assembla ensemble des morceaux de texte pour réaliser un livre spécimen de polices de texte”,
“Url”:”http://www.yahoo_1.fr”,
“Type”:”3″
}

打开Sql Server Management Studio并运行以下命令:

SELECT * FROM [LogCorner.EduSync.Speech.Data].[dbo].[Speech] SELECT * FROM [LogCorner.EduSync.Speech.Data].[dbo].[EventStore]

结果应该是这样的:

应该在Speech表和EventStore表上有记录,版本始终为零,因为本教程不包括更新。

使用Docker测试本地代码

找到\LogCorner.EduSync.Command\src文件夹(docker-compose.yml文件所在的文件夹)并运行以下命令

docker-compose build
docker-compose up
docker ps –all –format “table {{.ID}}\t{{.Image}}\t{{.Names}}”

启动postman并运行以下 HTTP Post

Endpoint : http://localhost:8080/api/speechMethod : POSTContent-Type: application/jsonBody : {
“Title”:”Le Lorem Ipsum est simplement du faux texte”,
“Description”:”Le Lorem Ipsum est simplement du faux texte employé dans la composition et la mise en page avant impression. Le Lorem Ipsum est le faux texte standard de l’imprimerie depuis les années 1500, quand un imprimeur anonyme assembla ensemble des morceaux de texte pour réaliser un livre spécimen de polices de texte”,
“Url”:”http://www.yahoo_1.fr”,
“Type”:”3″
}

最后,像这样检查正在运行的容器:

通过运行以下命令打开bash shell(其中0b是logcorner.edusync.speech.presentation.data容器Id的首字母)

Docker exec -it 0b “bash”

连接到sql server linux

/opt/mssql-tools/bin/sqlcmd -S localhost -U SA -P ‘PassW0rd’

运行sql查询

use [LogCorner.EduSync.Speech.Database]
goselect * from [dbo].[Speech]
goselect * from [dbo].[eventstore]
go

应该在Speech表和EventStore表上有记录,版本始终为零,因为本教程不包括更新。

本文的源代码可在此处获得 (Feature/Task/EventSourcingApplication)

https://github.com/logcorner/LogCorner.EduSync.Speech.Command/tree/Feature/Task/EventSourcingApplication

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/298254.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

我们来聊点成年人的话题!

1 这个话题透漏着成年人都存在的问题&#xff0c;其中心思想行走在道德底线&#xff0c;让人不得不深思&#xff0c;句句入心2 哈哈哈哈哈哈哈哈哈哈哈哈哈画面惊人 图自动漫次元酱3 对不起&#xff0c;我不是你家的鸡&#xff0c;我是一只大鸟&#xff01;&#xff01;&#x…

python3 csv读写_在python3中读取、更新和写入更新的CSV文件

我正在创建一个应用程序来本质上充当一个资产数据库&#xff0c;我试图打开一个CSV文件&#xff0c;读取值并相应地更新它们。我看到很多关于如何读写CSV文件的教程&#xff0c;但是我找不到一个详细介绍如何迭代CSV文件和更新单个值的教程。理想情况下&#xff0c;与列表相比&…

js数字相加

las_number Number(ads) Number(abs),转载于:https://www.cnblogs.com/gengaixue/archive/2011/07/08/2100971.html

js获取int类型长度_js代码比较大小前需要把string转换int

今天在写代码时发现一个容易忽略的问题&#xff0c;写下来以供参考这是做的一个验证&#xff0c;设置的最小值minValue不能小于参数本身的最小值min当输入正数的时候都没有问题&#xff0c;但是输入负数时就出现问题了正确设置参数var minValue -30 ,var min -300 ,console.l…

yum安装最新的 LNMP

2019独角兽企业重金招聘Python工程师标准>>> 先添加几个源&#xff1a; rpm -Uvh http://dl.fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-1.noarch.rpm rpm -Uvh http://rpms.famillecollet.com/enterprise/remi-release-7.rpm 1&#xff0c;安装nginx&a…

JavaScript中encodeURI,encodeURIComponent与escape的注意

大家在使用JS提交数据时&#xff0c;尤其是中文的时候&#xff0c;经常会需要将要提交的字符串进行URL编码。在JS中对字符串进行URL编码有好几种方法&#xff0c;encodeURI&#xff0c;encodeURIComponent&#xff0c;还有escape。在我看到的很多代码中escape这个函数用的最多&…

C#新版本风格项目文件(SDK风格项目 SDK-style project)

在VisualStudio中创建NetCore以上版本的项目&#xff0c;使用的都是新版本风格的项目文件。和旧版本.NetFramework版本的项目文件区别&#xff1a;双击项目可直接打开csproj文件进行编辑配置项目文件内容的改变项目属性文件夹图标更改项目引用去除&#xff0c;改成依赖项Nuget包…

史上最丧心病狂的商品定价套路:如何从数学角度,榨干你身上的每一分钱

全世界只有3.14 % 的人关注了爆炸吧知识世上没有精明的买家&#xff0c;只有精明的卖家。的确&#xff0c;卖家的嘴&#xff0c;骗人的鬼。在买与卖的博弈中&#xff0c;没有一个买家可以取胜。别不信&#xff0c;今天就让你见识下“卖家套路终极奥义”。按量定价&#xff0c;是…

python 接口自动化_Python 接口自动化测试

1. 接口基础知识1.1 接口分类接口一般来说有两种&#xff0c;一种是程序内部的接口&#xff0c;一种是系统对外的接口。(1) webservice接口&#xff1a;走soap协议通过http传输&#xff0c;请求报文和返回报文都是xml格式的&#xff0c;我们在测试的时候都要通过工具才能进行调…

工厂模式 Factory

工厂模式 记得一个好友面试的时候&#xff0c;面试官问他&#xff0c;你怎么获得一个类的对象的好友说&#xff0c;new一个啊&#xff0c;的确没错&#xff0c;对象不是new难道还是create... 当然在使用new对象的时候&#xff0c;这段代码也就意味着难以以后的维护和扩展了&…

java定时器写法_java定时器的写法是什么样?

定时器的用法是java核心基础之一&#xff0c;很多特殊功能都需要用到定时器&#xff0c;下面一起来看看定时器是如何编写的吧。示例&#xff1a;一个具备周期性定时(毫秒级);单时刻定时(秒级);多时刻定时(秒级)。后两个时间的设置必须符合“yyyy-MM-ddHH:mm:ss”、“yyyy-MM-dd…

CentOS中vsftp安装、配置、卸载

CentOS中vsftp安装、配置、卸载转载http://www.zjgsq.com/1509.html转载于:https://blog.51cto.com/bbtao/1606816

struts2文件上传

/*** 单文件的上传* author Administrator**/public class FileUploadAction extends ActionSupport {private static final com.opensymphony.xwork2.util.logging.Logger logger LoggerFactory.getLogger(FileUploadAction.class);//上传文件private File upload;//保存路径…

python的所有库_Python 常用库

前言之前重写了视频字符画处理的代码&#xff0c;然后这两天又在研究命令行和网络。读了一点开源工具的代码&#xff0c;越来越觉得有必要针对性地学习一下一些重要的基础库。这里呢就列个小清单&#xff0c;把我认为有必要学习的库写一下。带 [ x ] 的表示已完成时间time&…

401 Palindrome

这道题最初我是没理解清楚题意,我以为那些reverse栏空白的字母是省略了.后来在这个论坛找到了更多的测试数据,发现了自己理解错了,重新读题 ,修改了下代码- -.弄了很久才AC 我的思路和别人有点不同的是,我是通过计算来得到在常量表中的位置 好吧 这道题本来该总结很多的,今天…

东北大姐剪纸被误认为油画,遭人质疑二十多年,只因太过逼真,看完后:真香!不愧是天下第一剪!...

全世界只有3.14 % 的人关注了爆炸吧知识“这是剪纸&#xff1f;太惟妙惟肖了&#xff0c;我还以为是水彩画呢&#xff01;”这是一位网友的留言。茂盛的树木、潺潺的流水……这些栩栩如生的场景&#xff0c;真难想象竟是出自,一双巧手和一把剪刀。这些作品&#xff0c;全部来自…

2021 年 9 月 TIOBE 指数 C# 同比增长突破 1.2%

TIOBE 编程社区指数是编程语言流行程度的指标。该指数每月更新一次。评级基于全球熟练工程师、课程和第三方供应商的数量。谷歌、必应、雅虎、维基百科、亚马逊、YouTube 和百度等流行搜索引擎用于计算评分。C# 近期发展状态不错&#xff0c;依旧在榜单中排第五&#xff0c;但排…

java基础面向对象_java基础面向对象

一、面向对象之封装1. 面向对象的三个特征是&#xff1a;封装、继承和多态。2. Java开发过程&#xff1a;要实现某个功能&#xff0c;首先要找能够实现这个功能的对象&#xff0c;如果没有找到&#xff0c;就自己造一个对象&#xff0c;将要实现的功能定义到对象中&#xff0c;…

linux 学习笔记 显示压缩文件 gong.zip 的文件内容

#zip -v gong zip zip info: xxx >删除压缩文件中俄smart.txt 文件 #zip -d gong.zip smart.txt deleting:smart.txt >向压缩文件中gong.zip中添加rpm_info.txt文件 #zip -m gong.zip ./rpm_info.txt adding:rpm_info.txt deflated 79% Unzip命令解压缩文件 >将gong.z…

2010年5月系统集成项目管理工程师上午试卷参考答案(讨论版)

鉴于个人精力有限&#xff0c;其他答案将由51CTO相关工作人员不断更新&#xff0c;详见http://training.51cto.com/art/201005/200323.htm以题会友&#xff0c;欢迎跟贴拍砖、讨论。