基于本地消息库的调度框架。
- 存储消息
- 加载消息
- 投递消息
- 维护消息投递状态
TODO-LIST
- 由框架设置平台必要属性到消息实体,业务无需关注
- 消息id
- 消息平台
- 消息tag补齐
- 分布式追踪信息
- checkpoint模块与porter调度模块通讯,以提供即时故障恢复的机制,而不必等下次服务重启才做失败消息的failover
- 延时消息特例判定即时调度
- 处于过去时间点的延时消息投递时走即时投递流程
- 更严谨的配置校验
- 组件生命周期管理
- 防止过早启动调度。
- 更优雅的抽象实现(待定)
- 装饰器模式实现Porter以复用底层能力同时,方便增强调度特性。
- 多样MQ的多种发送消息api支持。
- 不是所有调度都需要rocketmq的事务消息投递才能保证一致性,可以考虑异步回调的方式进一步降低时延增大吞吐。
- 提供消费流程的接入或者demo
- 处理框架级别消费幂等处理。
- 框架对于MessageRepository的api是固定的,考虑BaseMapper的做法,提供简单快捷的实现而不必用户CV模板样例实现。