RabbitMQ的消息持久化处理以及ack确认机制

管理界面中:

队列中设置 autoDelete :ture 的意思是当所有消费者客户端断开连接后,是否删除队列 (交换器也是同个意思)

ready:显示当前有多少消息没有被消费

ack机制:如果忘记了ack反馈,而处理消息出现异常,那么后果很严重,会出现内存泄露。

解决方法:1 try catch 捕获异常进行处理
2 配置中添加开启重试次数 :
springboot.rabbitmq.listener.retry.enabled=true
springboot.rabbitmq.listener.retry.max-attempts=5

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容