面板介绍

Image 4.jpg

ACK介绍

无ack模式（AcknowledgeMode.NONE）默认全部成功

rabbitmq server默认推送的所有消息都已经消费成功，会不断地向消费端推送消息。
因为rabbitmq server认为推送的消息已被成功消费，所以推送出去的消息不会暂存在server端。

消息丢失的风险

当BlockingQueue<Runnable>堆满时（BlockingQueue<Delivery>一定会先满），server端推送消息会失败，然后断开connection。
消费端从Socket读取Frame将会抛出SocketException，触发异常处理，shutdown掉connection和所有的channel，channel shutdown后WorkPool中的channel信息（包括channel inProgress,channel ready以及Map）全部清空，所以BlockingQueue<Runnable>中的数据会全部丢失。

此外，消费者服务重启时也需对内存中未处理完的消息做必要的处理，以免丢失。
在rabbitmq server，connection断掉后就没有消费者去消费这个queue，因此在server端会看到消息堆积的现象。

有ack模式（AcknowledgeMode.AUTO，AcknowledgeMode.MANUAL）

AcknowledgeMode.MANUAL 手动确认
模式需要人为地获取到channel之后调用方法向server发送ack（或消费失败时的nack）信息。
AcknowledgeMode.AUTO 自动处理
模式下，由spring-rabbit依据消息处理逻辑是否抛出异常自动发送ack（无异常）或nack（异常）到server端。

server端行为

rabbitmq server推送给每个channel的消息数量有限制，会保证每个channel没有收到ack的消息数量不会超过prefetchCount。
server端会暂存没有收到ack的消息，等消费端ack后才会丢掉；如果收到消费端的nack（消费失败的标识）或connection断开没收到反馈，会将消息放回到原队列头部。

有ACK的模式不会丢消息，但效率较低，因为server端需要等收到消费端的答复之后才会继续推送消息，当然，推送消息和等待答复是异步的，可适当增大prefetchCount提高效率。