Skip to content

FantasyZsp/msg-schedule

Repository files navigation

基于本地消息库的调度框架。

  • 存储消息
  • 加载消息
  • 投递消息
    • 维护消息投递状态

TODO-LIST

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

About

No description, website, or topics provided.

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages