(六)复习(OutBox Message)
文章目录
- 项目地址
- 一、OutBox Message
- 1.1 OutBox表配置
- 1. OutBoxMessage类
- 2. OutboxMessage表配置
- 3. 给每个模块生成outboxmessage表
- 1.2 发布OutBox Message
- 1. 修改Intercepotor
- 2. 配置Quartz
- 3. 创建Quatz方法发布领域事件
- 4. 创建Quatz定时任务
- 5. 注册Quatz服务和配置
- 6. 流程梳理
- 7. 总结
- 二、OutBox Message
- 2.1 创建自定义的事件总线
- 1. 修改IDomainEventHandler
- 2. 创建IDomainEventHandler的实现
- 3. IDomainEventHandler服务注入
- 4. DomainEventHandlersFactory
- 5. 修改Quatz定时任务发布领域事件
- 2.2 领域事件消费者
- 1. 创建消费者表
- 2. 创建幂等性处理器
项目地址
- 教程作者:
- 教程地址:
- 代码仓库地址:
- 所用到的框架和插件:
dbt
airflow
一、OutBox Message
- 用于生产者发布消息Publish Message
毛子038
1.1 OutBox表配置
1. OutBoxMessage类
- 定义OutBoxMessage类
2. OutboxMessage表配置
- 创建outbob message表
3. 给每个模块生成outboxmessage表
- 给所有模块生成该表
1.2 发布OutBox Message
- Users模块里,对Users的领域事件进行发布
1. 修改Intercepotor
- 之前不需要事务,所以直接在EF save之后,进行了事件的发布,现在需要将业务的保存和outbox message一起原子性的保存,所以,需要在s