MQ 消息保证投递成功设计方案

投递主要针对生产端,什么是生产端的可靠性投递?

  • 保障消息成功的发出去
  • 保证MQ节点成功收到消息
  • 发送端收到MQ的确认应答
  • 完善的消息补偿机制,只做前三步的时候,也许生产端就失败了

BAT/TMD 互联网大厂解决方案,看具体业务和并发量

(1) 消息落库,对消息状态进行打标
(2) 消息的延迟投递,做二次检查,回调检查

消息落库步骤:

  1. 写入数据库,可能涉及多个库,业务库,消息库
  2. 发送消息
  3. 消息确认
  4. 更新数据库消息状态
  5. 定时任务获取数据库消息状态
  6. 重试发送
  7. 重试数量大于 3 次,修改状态

延迟投递:

如果再高并发的情况下,消息就不要入库了,延迟投递,可以不保证首次100%的成功,但是一定要保证性能。

  1. 首次发送,一定等到业务数据入库之后再发送消息,Upstream serivce上游服务
  2. 延迟发送刚发送消息 的 检查消息
  3. 当消费者消费消息
  4. 消息消费成功之后,发送一个确认消费消息
  5. CallBack服务收到消费者的确认消息,消费成功之后,做消息的持久化存储
  6. CallBack服务检查,处理第二步发送的检查消息,检查数据库是否有处理成功,如果处理成功了,那么就不用处理任何事情,如果处理失败了,Callback服务再通知Upstream服务再次发送消息。
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,486评论 19 139
  • “ 消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列...
    落羽成霜丶阅读 9,557评论 1 41
  • 投递主要针对生产端,什么是生产端的可靠性投递? 保障消息成功的发出去 保证MQ节点成功收到消息 发送端收到MQ的确...
    AI贺贺阅读 11,745评论 3 37
  • 消息队列设计精要 消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终...
    meng_philip123阅读 5,382评论 1 25
  • 消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能...
    Sophie12138阅读 3,980评论 0 7