文章目錄
- 項目地址
- 一、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