zoukankan      html  css  js  c++  java
  • [转] RabbitMQ 消息如何保证100%的投递成功

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

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

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

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

    细节

    消息落库步骤:

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

    延迟投递:

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

    1. 首次发送,一定等到业务数据入库之后再发送消息,Upstream serivce上游服务
    2. 延迟发送刚发送消息 的 检查消息
    3. 当消费者消费消息
    4. 消息消费成功之后,发送一个确认消费消息
    5. CallBack服务收到消费者的确认消息,消费成功之后,做消息的持久化存储
    6. CallBack服务检查,处理第二步发送的检查消息,检查数据库是否有处理成功,如果处理成功了,那么就不用处理任何事情,如果处理失败了,Callback服务再通知Upstream服务再次发送消息。

    作者:Real_man
    链接:https://www.jianshu.com/p/7944bbd5efc5
    来源:简书
    著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

    MQ系列整个内容,我们将讨论:

  • 相关阅读:
    python day09
    python day08
    python day07
    python day06
    python day05
    Django-Form组件之字段
    python装饰器
    npm常用命令
    python常用模块-re 正则表达式
    Django-forms效验组件
  • 原文地址:https://www.cnblogs.com/eedc/p/12851670.html
Copyright © 2011-2022 走看看