06 | 领域事件:解耦微服务的关键
06 | 领域事件:解耦微服务的关键
讲述:欧创新
时长17:38大小14.11M
领域事件
1. 微服务内的领域事件
2. 微服务之间的领域事件
领域事件相关案例
领域事件总体架构
1. 事件构建和发布
2. 事件数据持久化
3. 事件总线 (EventBus)
4. 消息中间件
5. 事件接收和处理
领域事件运行机制相关案例
总结
思考题
赞 37
提建议
精选留言(121)
- 阿神2019-10-25微服务内的领域事件我建议少用,增加复杂性了
作者回复: 我跟你的观点一样。
共 20 条评论59 - 兆哲2020-01-31在公司与同事沟通微服务之间的关系的时候,DDD提倡服务之间使用领域事件进行解耦, 但是某些同事觉得,rpc调用与通过总线发布事件,在执行的内容上没有本质上减少的东西(RPC 调用失败也可以加入重试机制),并且这种解耦方式可能会导致追踪调用链路更加困难。 如何看待这样的解读呢?
作者回复: 在微服务设计时,微服务之间尽量通过领域事件的方式来解耦,耦合度过高,在一个微服务出现问题时容易导致整体出现雪崩现象。这种异步方式不仅可以解耦微服务,还可以起到削峰填谷的作用。所以非实时的调用尽量采用领域事件的方式。
共 11 条评论27 - 杨杰2019-10-28关于领域事件有几个问题: 1、如果采用了主流的消息队列(如rabbitmq,kafka,rocketmq),是否领域事件还需要持久化? 2、对于领域事件的内容,是否需要把所有变化(或绝大多数)的内容都保存到事件里面(比如保单里面的所有内容)?这样的话这个这个领域事件会不会比较大? 3、关于领域事件还有一种方案就是基于数据库cdc的方式,在系统中有大量领域事件的场景下,是否cdc的形式更加灵活一点?展开
作者回复: 第一个问题:虽然这些消息队列自身有持久化的功能,但是中间过程,或者在订阅到数据后,在处理之前出问题,需要进行数据对账,这样就没法找到发布时和处理后的数据版本。关键的业务数据我建议还是落库比较好。 第二个问题:事件实体的业务数据还是按需发布比较好,避免不必要的业务信息泄露。 第三个问题:CDC的设计方式比较简单,属于数据库底层的技术,不会对上层应用产生太多的影响。
共 10 条评论23 - 游泳速度快内裤跟不上2019-10-25跨微服务的聚合间的领域事件驱动用消息中间件来衔接,这个比较容易理解,同一微服务内的聚合间的在实现层面如何来衔接呢,不太清楚这里面说的事件总线是一个什么概念,这个落实到代码上的话具体如何实现呢
作者回复: 事件总线你可以理解为运行在同一个进程内的消息中间件,它是一个很小的技术组件,可以通过配置支持异步或同步的消息机制。具体实现你可以查阅一下Eventbus组件相关的资料。
共 3 条评论15 - 信了2020-10-26在领域事件运行机制相关案例中,投保微服务有两个领域服务,createPaymentNotice 和 createPaymentNoticeEvent,createPaymentNoticeEvent是为了创建缴费通知单事件,而createPaymentNotice是做什么的?
作者回复: createPaymentNotice完成领域模型的业务逻辑:创建缴费通知单,createPaymentNoticeEvent是在领域逻辑完成后,执行领域事件发布逻辑:创建缴费通知单事件。在这个案例中,将业务逻辑处理和事件处理逻辑做了分离,然后在应用层来编排,这样的好处是可以实现事件发布逻辑的复用。如果不需要复用,你也可以直接在统一个领域服务中完成业务逻辑处理和领域事件发布逻辑,不需要上升到应用层来编排。
共 3 条评论11 - 昌南一枝花2020-08-04微服务内使用诸如SpringEvent同步方式保证在一个事务在修改多个聚合数据时,数据一致性得到了保证。但和前一讲提到的聚合设计原则跨聚合操作不应放在一个事务中,而应保证最终一致性略有矛盾。 是不是可以理解为Martinflow原本是想按聚合拆分微服务,所以跨聚合的操作不应放在一个事务里,否则没法按聚合拆分了。但实际应用中很少按聚合拆分微服务,为了方便也就允许跨聚合修改放一个本地事务里,后面万一要按聚合拆分微服务再拆分本地事务。展开
作者回复: 这是因为聚合是微服务内最小的业务功能单元。为了保证聚合内数据更新时,符合聚合内固定的业务规则,在一次事务提交时通常会将聚合内所有变更的对象数据作为整体,通过聚合领域服务或聚合根方法一次通过仓储完成数据持久化操作。如果在一次交易中需要同时更新多个聚合数据,那么每一个聚合就是一个独立的数据提交单元,我们需要确保多个聚合数据都能在这个交易中提交更新成功,以保证不同聚合数据的一致性。 为什么要做聚合之间的解耦,这是因为微服务的架构演进基本是以聚合为单位来演进的,未来在业务演进时微服务可能会根据聚合功能来重新拆分和组合聚合,所以要提前做好聚合之间的解耦,如果聚合的解耦做的不好,微服务演进时重新拆分和组合的工作量会非常大。
共 3 条评论8 - zj2019-11-21spring提供的事件机制我感觉也可以啊,可以用在微服务内
作者回复: 现在的技术路线很多,只要能保证在一个事务在修改多个聚合数据时,能保证数据一致性就可以使用。
共 2 条评论7 - cup2020-01-06老师,您好,有几个问题想请教一下 1、领域事件和一般的微服务之间的rpc调用区别是什么,因为大部分通信还是同步的rpc或者http调用,那每次rpc调用做一次更新操作就是一次领域事件么 2、大家都比较疑惑的问题 “微服务内应用服务,可以通过跨聚合的服务编排和组合,以服务调用的方式完成跨聚合的访问,这种方式通常应用于实时性和数据一致性要求高的场景。这个过程会用到分布式事务,以保证发布方和订阅方的数据同时更新成功。” 老师的答案是:微服务内主要是因为跨聚合了。一个聚合一个仓储,在一次修改多个聚合的时候,可能会存在数据不一致的情况,所以用事件总线或者分布式事务。 您这里说的一个聚合一个仓储是指的不同的聚合使用不同的数据库是么?普通数据库事务无法保证跨库操作的数据一致性,所以使用分布式事务?这样做是为了不同聚合之间解耦,方便以后的微服务拆分? 但如果简化一下,可不可以同一微服务中不同聚合的数据放在一个库里,在应用服务开启数据库事务,操作两个聚合的数据,然后结束事务 3、同一个微服务内为什么不能用消息中间件呢,比如一个聚合生产,扔到rabbitmq,同一微服务里面另一个聚合消费 消息保存到进程内部,如果消费能力较低,会不会内存溢出展开
作者回复: 1、领域事件方式主要是采用异步方式,实现数据的最终一致性。 2、一个聚合一个仓储,是指一个聚合与数据库交互的仓储服务是一个,并不是指一个聚合一个数据库。因为在DDD中为了保证聚合内数据和业务规则的一致性,通过聚合根将所有的实体等数据作为一个整体持久化到数据库中,所以一次事务只能修改一个聚合的数据。而如果一个操作跨了多个聚合的话,就需要考虑事务的概念了,其中有两种实现方式:最终一致性的事件总线机制和Saga等分布式事务的方式。这样也是为了聚合之间的解耦。 3、在同一个微服务内采用消息中间件过重了,事件总线属于轻量级的可实现发布订阅基本功能。
共 3 条评论7 - 朱振光2019-10-25内容很充实,但还是有两个问题。 1. 在采取最终一致性的情况下,event消费端如果出现错误,消费失败,但是之前的业务都成功了,虽然记录了event dB,但是后续如何处理,是需要人工介入解决吗?如果人工介入再解决,前端用户会不会看到数据不一致,体验不好? 2. 因为event都是异步发送,当最后一个event消费成功后,如何有效的通知前端界面,是用Web Socket吗?还是需要前端轮询到后台看是否都成功展开
作者回复: 第一个问题,失败的情况应该比例是很少的。失败的信息可以采用多次重发的方式,如果这个还解决不了,只能将有问题的数据放到一个问题数据区,人工解决。当然要确保一个前提,要保证数据的时序性,不能覆盖已经产生的数据。 第二个问题,一般来说发布方不会等待订阅方反馈结果。发布方有发布的事件表,订阅方有消费事件表,你可以采用每日对账的方式来发现问题数据。
共 3 条评论7 - 堵车2019-12-16我看到第一条留言,微服务领域时间建议少用,增加了复杂性。我有这么一个场景,用户入住一个房间后,要修改房态。如果不用领域事件,那么就得将入住和改房态写在同一个事务里。这里面入住是主操作,改房态是副操作。副操所除了问题,导致事务回滚,主操作也将无效,用户入住不成功。
作者回复: 在微服务内,不是少用领域事件,是少用事件总线。在DDD中是以聚合为单位进行数据管理的,如果一次操作会修改同一个微服务内的多个聚合的数据,你就需要保证多个聚合的数据一致性,为了解耦不同聚合,你需要采用分布式事务或者用事件总线两种方式,用事件总线不太方便管理服务和数据的关系,你可以用类似saga之类的分布式事务技术。总之需要确保你的不同聚合的业务规则和数据一致性,尽量减少系统建设复杂度。
共 7 条评论6 - itrickzhang2019-12-11欧老师我想问下,微服务之间用消息中间件通讯,那么注册中心是否是微服务设计的一个鸡肋
作者回复: 不是这样的。消息中间件主要用于微服务之间的异步处理,其实很多场景还是实时服务调用的。
共 3 条评论5 - Geek_a916702019-10-31"微服务内应用服务,可以通过跨聚合的服务编排和组合,以服务调用的方式完成跨聚合的访问,这种方式通常应用于实时性和数据一致性要求高的场景。这个过程会用到分布式事务,以保证发布方和订阅方的数据同时更新成功。" -------服务类的领域事件怎么还牵扯到分布式事务了呢?
作者回复: 如果一个领域事件会同时修改多个聚合之间的数据的话,可能会存在不同聚合内数据一致性的问题。事件总线的方式可以以同步或者异步的方式来保证聚合之间数据的一致性。多个聚合之上的应用服务也可以来协调这种数据一致性,但由于是跨聚合,需要保证多个聚合同时成功,这可以用事务的方式来实现。但是由于在同一个微服务内的进程内,出错的概率要比微服务之间小得多。
共 11 条评论5 - 风中舞者2020-08-20老师,不同微服务之间领域事件的调用,基于消息队列的事件发布,在微服务代码模型上是放到应用层还是领域层比较合适。
作者回复: 事件发布在领域层和应用层都可以,根据代码情况自由选择。事件订阅建议放在应用层。
3 - 乖,摸摸头2020-06-06好嘛,我摊牌了,我是写php 的,看了 第13章后又回来把这章看了一遍,基于 laravel框架做得开发, 框架里的 view controller model 层 对应 用户接口层 应用层 领域层 通用层 是怎么划分的?请教一下老师
作者回复: 建议你看一下第7章里面,里面有“三层架构如何演进到 DDD 分层架构”的内容,这里面有三层架构和DDD分层架构的对比分析。
3 - wallace2020-04-04老师好,请问从投保到核保通过是通过领域事件完成的,这种异步操作前端客户如何实时感知处理结果,并进行进一步处理,如缴费?
作者回复: 在后台会有一些监听的机制,当核保通过后,接收端会监听到核保通过的消息,接收相关数据并修改投保单核保状态后。前端可以采用待办刷新或者用Ajax等前端技术刷新后端的最新数据。
3 - Luke2020-02-01将事件发布放在应用层是否合适呢,还是应该视具体业务来? 看到老师的「领域事件运行机制相关案例」中,「创建缴费通知单事件」是在应用层,独立发布的。我们开发的业务中,事件发布的调用直接放在领域层逻辑中了。
作者回复: 事件发布应用层和领域层两个都是可以的,看具体情况。事件接收建议放应用层。
共 3 条评论3 - 观弈道人2019-10-28欧老师你好:事件有没有被消费成功(消费端成功拿到消息或消费端业务处理成功),一般如何通知到消息生产端?谢谢。
作者回复: 因为事件发布方有事件实体的原始的持久化数据,事件订阅方也有自己接收的持久化数据。一般可以通过定期对账的方式检查数据的一致性。
共 3 条评论3 - keys头2021-01-19欧老师,共享的数据类微服务,也就是数据代码类的数据字典系统应该怎么设计?有什么要点和注意事项吗?某一类字典数据可能只有一张表,是不是有必要把其他类的数据也放到同一个微服务中?比方说品牌库和行业库,各自都只有增删改查的功能。另外,有没有什么好的资料可以提供参考?
作者回复: 这类业务没有太多的业务逻辑,所以基本没有领域模型的概念,整个业务逻辑读多写少,其微服务主要是提供查询服务,所以按照传统方式设计也是可以的,不必先构建领域模型,然后设计微服务。 但是这类数据可能会与业务数据进行组合查询的可能,而他们分别在不同的微服务中。这时,你可以将这部分代码类数据以事件驱动的方式复制到业务数据库中。另外如果业务系统需要考虑多中心多活,这部分数据可能需要部署在不同的数据中心,这类数据属于全局数据,这时可以按照一写多读的设计方式,在一个地集中完成写入,而在多个数据中心提供读的数据副本,为多个数据中心提供数据查询服务。
共 3 条评论3 - 有爱有波哥2020-12-18欧老师 怎么聚合之间怎么实现强一致性
作者回复: 聚合之间强一致可以在应用层的应用服务中用事务来实现。
2 - JKing2020-08-21老师我还有一个疑问,同一个微服务跨聚合的业务编排我理解可以在应用层application进行编排吧,跨服务的业务依赖是通过领域事件来进行解耦吧?
作者回复: 是的。
2