/LocalTransactionTableTest

利用rabbitmq做消息队列,通过本地消息事务表序列化消息,通过定时轮训保证消息强行落地,最终达到数据最终一致性

Primary LanguageC#

todo:
1、实现serivce方法拦截:Cache应用 --ok

2、代码整理分离 迁移到 YiXinFramework --working

3、实现 Polly 重试容错处理 --ok 集成消息推送rabbitmqserver容错与消费者消费mq重试 Update: 将 Polly 重试机制迁移到 interceptor 当中去作为公共逻辑

4、实现发送消息错误报警接口设计(打算先实现邮件提醒)

5、集成分布式缓存 --ok (redis)
6、启用消费者负载均衡
7、启用rabbitmq集群模式测试
8、集成服务发现和治理(多个生产者均衡负载,但是数据库目前是同一个的模式)
9、集成quartz-ui管理界面
10、集成hangfire-RAM内存模式测试
11、集成kafka消息队列测试
12、关于解析 dbmessage 通过 eventbus 发送,做反射优化以及缓存提升性能
13、独立出来一个 MessageDbContext 发布nuget package方便使用,在使用migration迁移即可
14、集成 ExceptionLess / ELK 日志集中式处理