siteservercms做的网站在后台进行修改教程,番禺做网站价格,网站上线之后要做的工作,吴家山网站建设公司前言随着系统架构的演变#xff0c;有很多名词也随之涌现#xff0c;如#xff1a;微服务、灰度发布、资源隔离、容器、领域/集成事件等#xff0c;听着的确高大上#xff0c;让很多小伙伴有一种无法征服的感觉#xff1b;其实很多东西可能之前就已经用过了#xff0c;只… 前言随着系统架构的演变有很多名词也随之涌现如微服务、灰度发布、资源隔离、容器、领域/集成事件等听着的确高大上让很多小伙伴有一种无法征服的感觉其实很多东西可能之前就已经用过了只是名字不这么叫而已就算没应用上也别慌现在很多轮子都很成熟用起来很容易上手的。这里就来说说比较常见的领域事件和集成事件。正文1.概述微服务和DDD盛行的时代领域事件和集成事件经常被提及到对于事件小伙伴可以根据不同场景去理解比如点击一个按钮时这个就是一个事件(点击事件)又或者说当购买商品时付款成功也可以理解为一个事件就像咱们在生活中对每一件事的定义是一样的。1.1 领域事件领域事件Domain Event是在一个特定领域由一个动作触发的是发生在过去的行为产生的事件(行为可以是人操作的也可以是系统自动的) 其实在项目中通常咱们会把领域事件用在一个应用程序进程内比如说在用户管理时当用户注册成功时需要发送邮件或短信提醒其中用户管理可以简单理解为一个领域用户注册成功就是事件而发送提醒就是针对事件的处理方式。这里可能对领域的比喻不是特别恰当如果小伙伴想更多了解可以看看DDD(领域驱动设计)相关资料。对于我个人的理解我认为领域事件的主要目的是为了让代码更加容易维护让业务更加容易扩展也就是对代码业务层面的优化。如下图对于原始这种方式相信很多小伙伴也和我曾经一样写过这样的代码逻辑不用想什么代码顺序直接撸码就行了但是这样扩展性不好比如我想加一个微信发送怎么办还得在原来基础上继续加如果过两天不要短信发送了还得去改原来代码。这样是不是违背了软件开发的开闭原则尽量还是少改原有逻辑的代码避免重复修改、重复测试。对于优化后的这种方式只需要在注册成功之后发布一个事件出来就行了至于后面要发送什么样的消息不用管只要捕获到事件消息只需新增额外扩展的处理器类即可就算是取消只需不捕获对应的事件就行无需改动原有用户注册代码的逻辑。这种方式的事件就可以理解为领域事件。小伙伴回想一下之前在优化代码的时候是不是也这样做过只是当时不称它为领域事件。1.2 集成事件集成事件(IntegrationEvent)同样也是指在过去的行为产生的事件(行为可以是人操作的也可以是系统自动的)一般用于跨多个微服务或外部系统。比如现在的电商系统订单模块和物流模块会拆分为不同微服务通常在订单支付成功之后物流模块需要知道订单相关的明细这样才会根据订单进行物流跟踪。所以订单在付款成功之后就会发布一个事件出去物流系统订阅到事件之后就可以处理对应业务逻辑。对于集成事件的主要目的我认为就是为了让服务模块之间或系统之间的对接耦合性变低只要约定好事件类型发事件模块和处理事件的模块就会有很少对接便于扩展和维护。如图原始的这种方式像我有点年长的小伙伴应该之前都用过当然现在有很多传统企业项目也是这种方式。这种方式主要是通过接口的形式进行模块或系统之间的对接这样对接成本稍微偏高因为订单服务还需要开发调用物流服务接口的逻辑还要各种联调考虑接口超时、失败等各种情况另外如果还有其他业务模块的系统需要对接怎么办如果接口规范不一样还得重复再开发一套调用逻辑这样后面订单服务这个模块就变得很臃肿而且模块间的耦合性比较高。优化后的方式就相对来说比较好对订单付款成功之后只需将事件发布出去就行了剩下的不用过多干涉对应的业务模块订阅到消息之后进行相关业务处理即可这种模式就算有其他业务模块加入也会很便捷模块间的耦合性比较低。由于模块间的消息需要传输所以就需要EventBus来做这个事了。这种方式看上去不错但需要第三方的消息中间件做消息转发和存储如RabbitMq、Kafka等另外使用过程中消息的持久化、消息丢失的情况都需要考虑后续会单独出相关系列的文章说这块。2.演示对于技术落地大神都把轮子造好了咱们拿来就可以用啦。2.1 领域事件技术简介MediatR是用.Net实现的简单中介者模式无需其他依赖就能处理进程内的消息传递支持请求/响应、命令、查询、通知和事件的同步或异步传递通过C#的泛型智能调度。这里就不详细说了详细说明小伙伴们可以看我之前分享的这篇文章《跟我一起学.NetCore之MediatR好像有点火》案例实操准备一个API项目引入对应的Nuget包并注册相关服务如下模拟用户注册成功发布领域事件这里在默认的控制器里添加一个接口进行测试代码如下发布的事件信息其实就是一个对象信息只是该类按照MediatR约定继承对应的接口即可如下增加对事件的处理逻辑即捕获到事件之后如何处理代码如下这个处理类可以根据需要增加这里增加一个邮件的和短信的如果还需要其他方式的只需要按照约定继承对应的接口并实现对应的方法处理业务逻辑即可。运行起来看效果是不是用起来很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_USERadmin -e RABBITMQ_DEFAULT_PASSadmin -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61613 -p 1883:1883 rabbitmq:management这个命令指定了默认用户为admin默认密码也是admin如果能正常登陆RabbitMQ系统代表安装成功了如下注我这里用的是阿里云服务器所以需要在安全组和防火墙中开启端口15672和5672的访问15672是RabbitMQ的Web界面5672是程序之间通信需要用到的。准备两个API项目一个模拟订单发布事件一个模拟物流订阅事件首先都需要引入相关的Nuget包MassTransit、MassTransit.RabbitMQ并注册相关服务如下模拟订单发布付款成功事件在默认的控制器中增加对应的接口进行演示如下事件的定义这里为了方便直接定义为公共的类库同样就是一个简单的类里面的内容如下物流模块模拟物流订阅付完款成功事件这里需要稍微注意一下因为订阅到事件之后需要进行相关的业务处理所以在注册服务的时候需要把对应的处理器也注册上处理类的逻辑如下将处理器也进行注册如下启动时候订单的端口为5001物流模块的端口为5000只要避免两个模块的端口不一样就行端口不能重复用这样就可以运行看效果了两个模块都启动起来在订单模块访问发布接口物流模块收到事件消息之后就会马上处理如下注以上演示方式没有指定对应队列所以采用的是RabbitMQ中的Fanout模式Fanout是一种广播机制的发布与订阅模式也就是所有的订阅者都可以收到生产者发布的事件实际场景中这种模式用的不多通常比较常用的是direct模式小伙伴可以根据实际情况指定即可关于RabbitMQ系列的文章我正在整理后续会分享给大家。相关源码地址https://gitee.com/CodeZoe/dot-net-core-study-demo总结关于领域事件和集成事件的介绍和使用暂时先说这么多只是简单介绍了我对领域事件和集成事件的理解及应用更多细节还得小伙伴根据实际业务需求进配置和改进但用法就是这么简单对于消息丢失、持久化等相关问题后续会跟随消息队列的文章分享出来。
