领域事件和集成事件没那么高大上

前言

随着系统架构的演变,有很多名词也随之涌现,如:微服务、灰度发布、资源隔离、容器、领域/集成事件等,听着的确高大上,让很多小伙伴有一种无法征服的感觉;其实很多东西可能之前就已经用过了,只是名字不这么叫而已,就算没应用上也别慌,现在很多轮子都很成熟,用起来很容易上手的。这里就来说说比较常见的领域事件和集成事件。

正文

1.概述

微服务和DDD盛行的时代,领域事件和集成事件经常被提及到;对于事件,小伙伴可以根据不同场景去理解,比如点击一个按钮时,这个就是一个事件(点击事件),又或者说当购买商品时付款成功,也可以理解为一个事件,就像咱们在生活中对每一件事的定义是一样的。

1.1 领域事件

领域事件(Domain Event)是在一个特定领域由一个动作触发的,是发生在过去的行为产生的事件(行为可以是人操作的,也可以是系统自动的)

其实在项目中,通常咱们会把领域事件用在一个应用程序进程内,比如说在用户管理时,当用户注册成功时,需要发送邮件或短信提醒;其中用户管理可以简单理解为一个领域,用户注册成功就是事件,而发送提醒就是针对事件的处理方式。

这里可能对领域的比喻不是特别恰当,如果小伙伴想更多了解,可以看看DDD(领域驱动设计)相关资料。

对于我个人的理解,我认为领域事件的主要目的是为了让代码更加容易维护,让业务更加容易扩展,也就是对代码业务层面的优化。如下图:

6cbce848d39f411be4e038b30854af8a.png

对于原始这种方式,相信很多小伙伴也和我曾经一样写过这样的代码逻辑,不用想什么代码顺序,直接撸码就行了,但是这样扩展性不好,比如我想加一个微信发送怎么办,还得在原来基础上继续加,如果过两天不要短信发送了,还得去改原来代码。这样是不是违背了软件开发的开闭原则,尽量还是少改原有逻辑的代码,避免重复修改、重复测试。

对于优化后的这种方式,只需要在注册成功之后发布一个事件出来就行了,至于后面要发送什么样的消息不用管,只要捕获到事件消息,只需新增额外扩展的处理器类即可,就算是取消,只需不捕获对应的事件就行,无需改动原有用户注册代码的逻辑。这种方式的事件就可以理解为领域事件。

小伙伴回想一下,之前在优化代码的时候是不是也这样做过,只是当时不称它为领域事件。

1.2 集成事件

集成事件(IntegrationEvent)同样也是指在过去的行为产生的事件(行为可以是人操作的,也可以是系统自动的),一般用于跨多个微服务或外部系统。

比如现在的电商系统,订单模块和物流模块会拆分为不同微服务,通常在订单支付成功之后,物流模块需要知道订单相关的明细,这样才会根据订单进行物流跟踪。所以订单在付款成功之后,就会发布一个事件出去,物流系统订阅到事件之后就可以处理对应业务逻辑。

对于集成事件的主要目的我认为就是为了让服务模块之间或系统之间的对接耦合性变低,只要约定好事件类型,发事件模块和处理事件的模块就会有很少对接,便于扩展和维护。如图:

5e0c09fd8cb548ca128cc637b34b71e0.png

原始的这种方式,像我有点年长的小伙伴应该之前都用过,当然现在有很多传统企业项目也是这种方式。这种方式主要是通过接口的形式进行模块或系统之间的对接,这样对接成本稍微偏高,因为订单服务还需要开发调用物流服务接口的逻辑,还要各种联调,考虑接口超时、失败等各种情况;另外如果还有其他业务模块的系统需要对接怎么办,如果接口规范不一样,还得重复再开发一套调用逻辑,这样后面订单服务这个模块就变得很臃肿,而且模块间的耦合性比较高。

优化后的方式就相对来说比较好,对订单付款成功之后,只需将事件发布出去就行了,剩下的不用过多干涉,对应的业务模块订阅到消息之后进行相关业务处理即可;这种模式就算有其他业务模块加入也会很便捷,模块间的耦合性比较低。由于模块间的消息需要传输,所以就需要EventBus来做这个事了。这种方式看上去不错,但需要第三方的消息中间件做消息转发和存储,如RabbitMq、Kafka等;另外使用过程中,消息的持久化、消息丢失的情况都需要考虑,后续会单独出相关系列的文章说这块。

2.演示

对于技术落地,大神都把轮子造好了,咱们拿来就可以用啦。

2.1 领域事件
  • 技术简介

    MediatR是用.Net实现的简单中介者模式,无需其他依赖就能处理进程内的消息传递,支持请求/响应、命令、查询、通知和事件的同步或异步传递,通过C#的泛型智能调度

    这里就不详细说了,详细说明小伙伴们可以看我之前分享的这篇文章《跟我一起学.NetCore之MediatR好像有点火》

  • 案例实操

    准备一个API项目,引入对应的Nuget包,并注册相关服务,如下:

    b433e1bd89714a65de49022a649041fd.png

    模拟用户注册成功发布领域事件,这里在默认的控制器里添加一个接口进行测试,代码如下:

    a14cc4950ca0a4a3eecadebab66816b7.png

    发布的事件信息其实就是一个对象信息,只是该类按照MediatR约定继承对应的接口即可,如下:

    0b83bdc421ac213f051238bc62e3d3cd.png

    增加对事件的处理逻辑,即捕获到事件之后如何处理,代码如下:

    be3f50700c3e0906e9675d7ff03af2a9.png

    这个处理类可以根据需要增加,这里增加一个邮件的和短信的,如果还需要其他方式的,只需要按照约定继承对应的接口,并实现对应的方法处理业务逻辑即可。

    运行起来看效果:

    a3c1b374cc10d268b861feca4223ea3d.png

    是不是用起来很Easy~~~,集成事件也是一样。

2.2 集成事件
  • 技术简介

    这块自己比较常用是CAP和Masstransit,关于CAP自己也分享过一篇文章《分布式事务最终一致性-CAP框架轻松搞定》,也可以用其进行事件的发布,这里就不再赘述。

    Masstransit是一个免费的、开源的.NET 分布式应用程序框架,轻量级的消息总线(EventBus) ,即专门用来传输和接收消息的;集成很多消息中间件,如:RabbitMQ、AcitveMQ、Azure Service Bus、Kafka、Redis等,这里我们主要说应用,更多详情小伙伴们查看官网,如下:

    官网地址:http://masstransit-project.com/getting-started/

    开源地址:https://github.com/MassTransit/MassTransit

  • 案例实操

    其实可以用内存的方式进行演示,但为了更符合真实场景,这里采用RabbitMQ的方式进行演示,所以首先需要安装RabbitMQ,为了方便,还是用Docker的方式进行安装,如果对Docker还不了解的小伙伴,可以查阅我分享的系列文章《Docker系列》。

    在确保有Docker的环境下,执行如下命令即可:

    docker run -di --name myrabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61613 -p 1883:1883 rabbitmq:management

    这个命令指定了默认用户为admin,默认密码也是admin,如果能正常登陆RabbitMQ系统,代表安装成功了,如下:

    8106d78df728a7f22078b87ab486b959.png

    注:我这里用的是阿里云服务器,所以需要在安全组和防火墙中开启端口15672和5672的访问,15672是RabbitMQ的Web界面,5672是程序之间通信需要用到的。

    准备两个API项目,一个模拟订单发布事件,一个模拟物流订阅事件,首先都需要引入相关的Nuget包:MassTransit、MassTransit.RabbitMQ,并注册相关服务,如下:

    2abca545a6e67d6b5b8b16c414c147a0.png

    模拟订单发布付款成功事件,在默认的控制器中增加对应的接口进行演示,如下:

    13d098991e49ae3645aecf8c5c7bf1b2.png

    事件的定义这里为了方便直接定义为公共的类库,同样就是一个简单的类,里面的内容如下:

    e32896483a6ed037018b9df8805c3bf2.png

    物流模块

    模拟物流订阅付完款成功事件,这里需要稍微注意一下,因为订阅到事件之后需要进行相关的业务处理,所以在注册服务的时候,需要把对应的处理器也注册上,处理类的逻辑如下:

    a99010c48d84750748351ba18c164f7c.png

    将处理器也进行注册,如下:

    26db19815e04c776bee7f971b5b5fc53.png

    启动时候订单的端口为5001,物流模块的端口为5000,只要避免两个模块的端口不一样就行,端口不能重复用,这样就可以运行看效果了,两个模块都启动起来:

    在订单模块访问发布接口,物流模块收到事件消息之后就会马上处理如下:

    9cc6dee10e1809cf6763f9ac42f5a20e.png

    注:以上演示方式没有指定对应队列,所以采用的是RabbitMQ中的Fanout模式,Fanout是一种广播机制的发布与订阅模式,也就是所有的订阅者都可以收到生产者发布的事件,实际场景中这种模式用的不多,通常比较常用的是direct模式,小伙伴可以根据实际情况指定即可;关于RabbitMQ系列的文章我正在整理,后续会分享给大家。

相关源码地址:https://gitee.com/CodeZoe/dot-net-core-study-demo

总结

关于领域事件和集成事件的介绍和使用暂时先说这么多,只是简单介绍了我对领域事件和集成事件的理解及应用,更多细节还得小伙伴根据实际业务需求进配置和改进,但用法就是这么简单;对于消息丢失、持久化等相关问题,后续会跟随消息队列的文章分享出来。

7761d471ee2249d14ab25d50df549589.png

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

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

相关文章

20142335郝昊第三周学习总结

20145335郝昊 《Java程序设计》第3周学习总结 教材学习内容总结 第四章 类与对象 定义: 对象(Object):存在的具体实体,具有明确的状态和行为。 类(Class):具有相同属性和行为的一组对象的集合&…

hierarchyviewer

为什么80%的码农都做不了架构师?>>> 学习monkeyrunner,无奈怎么都无法启动activity,人家告诉我.hierarchyviewer这个工具可以,今天我就开始学习这个了,但愿有所帮助啊。http://www.xuebuyuan.com/2104811.…

linux之如何查看哪些进程在使用某一个so

1 问题 在我们服务端,我们怎么查看哪些进程在使用某一个so 2 解决办法 lsof **.so 很明显,我们的apache的httpd几个进程在使用这个so

“威胁情报”在手,反黑客终于有地图了!

安全是一场攻防战,那么,如今这样的攻防战发展到了什么level了呢?日前,安全领域的大神们进行了一场闭门研讨 。大神们表示,如今要想保证自己的安全,你不仅需要武器,还需要侦察兵,需要…

winform插入时间类型数据到oracle数据库,winform操作访问Oracle 10g数据库,并自动填充到DataGridView...

使用oracle的ODP.NET是官方推荐,而且相对简单的方法。官方指导文档:http://www.oracle.com/technetwork/cn/testcontent/o23odp-084525-zhs.htmlapp.configForm1.aspx.csusing System;using System.Collections.Generic;using System.ComponentModel;usi…

print的describe的展示全部数据_大数据项目中的QA需要迎接新的挑战

根据IDC全球半年度大数据和分析支出指南的最新预测,到2022年全球大数据和业务分析解决方案的收入将达到2600亿美元。在大数据和业务分析解决方案上投资增长最快的行业包括银行(复合年增长率13.3%)、医疗、保险、证券和投资服务、电信&#xf…

Enum枚举类型实战总结,保证有用!

一般在我们开发时如果能使用枚举罗列的,一般都会定义一个枚举类型。将枚举类型作为方法的参数,可以方便的进行调用,给我们带来不少的便利,当然有时候它还不如直接用一个int类型带来,带来一定灵活性。但只要能满足业务咱…

linux c之通过popen执行shell命令

1 popen介绍 我是在ubuntu上面进行man popen的,解释如下 这个函数通过创建一个管道通过fork一个进程,然后执行一个command,因为在管道中,所以数据流是单向的,然后type一般只能是读“r”或者写“w”,返回值在IO流里面,用了popen之后我们要记得用pclose函数。 2 使用 #inc…

用java调用.net的wcf其实还是很简单的

前些天和我们的一个邮件服务商对接,双方需要进行一些通讯,对方是java团队,而作为.net团队的我们,只能公布出去的是一个wcf的basicbinding,想不 到问题来了,对方不知道怎么去调用这个basic,可能他…

DbTool 2.0.0 Released

DbTool 2.0.0 ReleasedIntroDbTool 一个支持 DbFirst、ModelFirst 和 CodeFirst 的数据库小工具。DbFirst 是根据数据库中的表信息生成代码中的 Model,以及生成数据表结构文档ModelFirst 是根据数据表信息或者数据表结构文档生成创建数据库的脚本CodeFirst 是指根据…

[蓝桥杯] 蚂蚁感冒

[蓝桥杯] 蚂蚁感冒 峰值内存消耗 < 256M  CPU消耗 < 1000ms 【题目描述 - Problem Description】 长100厘米的细长直杆子上有n只蚂蚁。它们的头有的朝左&#xff0c;有的朝右。 每只蚂蚁都只能沿着杆子向前爬&#xff0c;速度是1厘米/秒。 当两只蚂蚁碰面时&#xff0…

Source Insight之Relation Window Properties配置和一些快捷键

1 Source Insight之Relation Window Properties配置 我们先点击source Insight的这个地方 然后鼠标右键&#xff0c;点击Relation Window Properties&#xff0c;配置如下 2 快捷键 目前就我知道的 1&#xff09;按亮和按熄这个变量 shift F8 2&#xff09;跳转到具体一行…

ArcGIS 10.2 Calculate Value(Data Management) 工具的使用

1、概述 Calculate Value tool returns a value based on a specified Python expression. 计算值工具返回一个基于特定Python表达式的值。 工具位置:ToolBox→Data Management Tools→General→Calculate Value 2、注意事项 (1)该工具只能用于MoudleBuilder,而不能用于Py…

vb6编写dll读取dat文件_【STM32Cube_15】使用硬件I2C读取温湿度传感器数据(SHT30)...

寻求更好的阅读体验&#xff0c;请移步Mculover666的个人博客&#xff1a;【STM32Cube_15】使用硬件I2C读取温湿度传感器数据&#xff08;SHT30&#xff09;​www.mculover666.cn本篇详细的记录了如何使用STM32CubeMX配置STM32L431RCT6的硬件I2C外设&#xff0c;读取SHT30温湿度…

tcp/ip ---数据封装过程

转载于:https://www.cnblogs.com/saryli/p/5306721.html

NuGet 新特性 -- 中心化的 NuGet 包版本管理

NuGet 新特性 -- 中心化的 NuGet 包版本管理IntroNuGet 支持了一个可以中心化管理 NuGet 包版本的方案&#xff0c;我们可以在一个地方统一管理 NuGet 包的版本Preface在之前的版本中我们通常在每个指定包版本引用的地方会设置 NuGet 包的版本号&#xff0c;如果项目比较多&…

Java面向对象编程学习

1、新建一个工程&#xff0c;在工程下新建一个类Method01&#xff08;勾选创建main函数&#xff09; package ClassStudy;class Person {String name; //默认为nullint age; //默认为0//构造函数public Person(){namenull;age0;}//方法public void say(){System.out.println(&…

查询工资最低的3名员工的职工工号、姓名和收入_普法课堂|你有多久没有收到工资条了?...

工资条对于现在的大多数劳动者而言&#xff0c;尤其是90、00后&#xff0c;可能是一个十分陌生的概念和事物&#xff0c;许多用人单位已经不再向劳动者发放&#xff0c;在司法实践中工资条越来越少的在庭审中予以呈现。工资条对于劳动者而言十分重要&#xff0c;即便未有用人单…

linux之通过tail命令动态跟踪日志文件里面的末尾信息

1 问题场景 比如在linux系统,我们服务端的错误日志在一个文件里面不断输入进去,我们需要动态查看,我们总不可能每次进行cat文件查看 2 tail命令和head命令 head命令默认是输出一个文件的最前面10行 tail命令默认是输出一个文件的最后面10行 1) -n参数 具体显示多少行 显示…

android数据持久化存储(2)

SharedPreferences 将数据存储到SharedPreferences中&#xff1a; 不同于文件的存储方式&#xff0c;SharedPreferences是使用键值对的方式来存储数据的。也就是说当保存一条数据的时候&#xff0c;需要给这条数据提供一个对应的健&#xff0c;这样再读取数据的时候就可以通过这…