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 日志集中式处理
Inuyasha-Monster/LocalTransactionTableTest
利用rabbitmq做消息队列,通过本地消息事务表序列化消息,通过定时轮训保证消息强行落地,最终达到数据最终一致性
C#