zoukankan      html  css  js  c++  java
  • RMQ Message ACK

    原创转载请注明出处:https://www.cnblogs.com/agilestyle/p/11808680.html

    消息持久化机制

    消息丢失了,需要将队列持久化,即将autoDelete设置成false即可

    什么是消息确认ACK

    如果在处理消息的过程中,消费者服务器、网络、出现故障挂了,那可能这条正在处理的消息就没有完成,数据就会丢失。为了确保消息不会丢失,RMQ支持消息确认ACK

    ACK的消息确认机制

    ACK机制是消费者从RMQ收到消息并处理完成后,反馈给RMQ,RMQ收到反馈后才将此消息从队列中删除。
    如果一个消费者在处理消息时挂掉(网络不稳定、服务器异常、网站故障等),那么就不会有ACK反馈,RMQ会认为这个消息没有正常消费,会将此消息重新放入队列中。
    如果在集群的情况下:RMQ会立即将这个消息推送给这个在线的其他消费者。这种机制保证了在消费者服务器故障的时候,不丢失消息和任务。
    消息永远不会从RMQ服务器中删除;只有当消费者正确的发送ACK确认反馈,RMQ确认收到后,消息才会从RMQ服务器的数据中删除。
    消息的ACK确认机制默认是打开的。

    ACK机制的开发注意事项

    如果忘记了ACK,会导致内存泄漏。当Consumer退出时,message会一直重新分发,然后RMQ会占用越来越多的内存,RMQ长时间运行后,会导致严重的内存泄漏。

    通常的解决办法是开启重试,并设置最大重试次数。

    1 # 开启重试
    2 spring.rabbitmq.listener.retry.enabled=true
    3 # 重试默认次数是 3
    4 spring.rabbitmq.listener.retry.max-attempts=5

  • 相关阅读:
    网络诊断工具:[tcpdump]
    网络诊断工具:iproute
    C语言编译全过程
    (Ruby)Ubuntu12.04安装Rails环境
    (Life)牛人的学习方法(转译文)
    (WPF)WPF事件要点WPF宝典笔记
    (WPF)依赖属性要点WPF宝典笔记
    (DP)降低代码重构的风险(转载)
    (WPF)路由事件要点WPF宝典笔记
    JDBC,MYBATIS,Hibernate性能对比!
  • 原文地址:https://www.cnblogs.com/agilestyle/p/11808680.html
Copyright © 2011-2022 走看看