消费端的消息ACK与重回队列
消费端的手工ACK和NACK
ACK分为自动和手动
消费端进行消费的时候, 如果由于业务异常我们可以进行日志的记录, 然后进行补偿
如果由于服务器宕机等严重问题, 那我们就需要手工进行...ACK保障消费端消费成功
消费端的重回队列
消费端重回队列是为了对没有处理成功的消息, 把消息重新会递给Broker
一般我们在实际应用中, 都会关闭重回队列, 也就是设置为FALSE
为什么不使用重回队列的功能呢..., 因为消息重回队列会加入到队列的尾部, 也会造成一条甚至大量消息一直重复投递在队列中死循环
说道这里, 其实我是真实碰到过的, 当时正是双11, 我们的失败策略就是用的重回队列, 导致有大量的消息一直因为业务的异常..., 重回队列, 导致了4000万的订单MQ消息, 一直压力下不去, 差点被领导骂死~, 后面还做了重大事故回顾会议, 哎
消息重回队列代码实现
消费者
package com.dance.redis.mq.rabbit.rqueue...启动生产者
查看消费者
可以看到flag=0的消息, 再一直被重回队列, 当然, 我们可以通过程序去控制这个是不是要重回队列
关闭重回队列测试
启动消费者
启动生产者
查看消费者
可以看到哪怕