一、介绍
为了保证消息在发送过程中不丢失，rabbitmq引入消息应答机制，消息应答就是：消费者在接收到消息并且处理该消息之后，告诉rabbitmq它已经处理了，rabbitmq可以把该消息删除了。
二、自动应答
消息发送之后立即被认为已经传送成功，这种模式需要在高吞吐量和数据传输安全性方面做权衡，因为这种模式如果消息在接收到之前，消费者那边出现连接或者channel关闭，那么消息就丢失了，当然另一方面这种模式消费者那边可以传递过载的消息，没有对传递的的消息数量进行限制，这样导致消费者这边由于接收太多消息还来不及处理，导致这些信息积压，最终使得内存耗尽，最终这些消费者线程被操作系统杀死，所以这种模式仅适用在消费者可以高效并以某种速率能够处理这些消息的情况下使用。
三、手动应答
1> Channel.basicAck（用于肯定确认）
RabbitMQ已知道该消息被成功处理，可以将其丢弃了
2> Channel.basicNack（用于否定确认）
3> Channel.basicReject(用于否定确认)
与Channel,basicNack相比少一个参数（批量处理参数），不处理该消息了直接拒绝，可以将其丢弃了
四、Multiple
手动应答的好处是可以批量应答并且减少网络拥堵
basicAck(long deliveryTag, boolean multiple)
multiple的true和false代表不同的意思（true代表批量应答channel上未应答的消息，比如说channel上传送tag的消息5，6，7，8 当前tag是8那么此时5-8的这些还未应答的消息都会被确认收到消息应答；false与上面相比，只会应答tag=8的消息5，6，7这三个消息依然不会被确认收到消息应答）
五、消息自动重新入队
如果消费者由于某些原因失去连接（其通道已关闭，连接已关闭或TCP连接丢失），导致消息未发送ACK确认，RabbitMQ将了解到消息未完全处理，并将对其重新排列。如果此时其他消费者可以处理，他将很快将其重新分发给另一个消费者。这样，即使某个消费者偶尔死亡，也可以确保不会丢失任何消息。
六、消息手动应答代码
生产者
public class Task02 {
//队列名称
public static final String TASK_QUEUE_NAME = "ack_queue";
public static void main(String[] args) throws IOException, TimeoutException {
Channel channel = RabbitMqUtil.getChannel();
//声明队列
channel.queueDeclare(TASK_QUEUE_NAME,false,false,false,null);
//从控制台输入信息
Scanner scanner = new Scanner(System.in);
while(scanner.hasNext()){
String message = scanner.next();
channel.basicPublish("",TASK_QUEUE_NAME,null,message.getBytes());
System.out.println("生产者发出消息："+message);
}
}
}消费者
public class Worker03 {
//队列名称
public static final String TASK_QUEUE_NAME = "ack_queue";
public static void main(String[] args) throws IOException, TimeoutException {
Channel channel = RabbitMqUtil.getChannel();
System.out.println("C1等待接收消息");
DeliverCallback deliverCallback =(consumerTag,message) ->{
System.out.println("接收到的消息："+new String(message.getBody()));
//手动应答
/**
* 参数
* 1：消息的标记 tag
* 2:是否批量应答
*/
channel.basicAck(message.getEnvelope().getDeliveryTag(),false);
};
CancelCallback cancelCallback = (consumerTag) -> {
System.out.println("消费者取消消费接口回调");
};
//采用手动应答
boolean autoAck = false;
channel.basicConsume(TASK_QUEUE_NAME,autoAck,deliverCallback,cancelCallback);
}
}测试结果：生产者发出5条消息，前四条分别轮询发送给两个消费者，当从c1挂掉之后，第五条消息被c2接收并处理
