9824247-dbd6b84206381f8e.jpg
在正式的生产环境中，我们不想丢失任何任务，如果有一个消费者挂掉了，那么我们应该将分发给它的任务交付给另一个消费者去处理。 为了确保消息不会丢失，RabbitMQ支持消息应答。消费者发送一个消息应答，告诉RabbitMQ这个消息已经接收并且处理完毕了。RabbitMQ可以删除它了。
那么如何设置RabbitMQ为手动应答模式呢？
1、Message acknowledgment（消息应答）
boolean autoAck = false;
channel.basicConsume(QUEUE_NAME, autoAck, consumer);
boolean autoAck = true;(自动确认模式)一旦RabbitMQ将消息分发给了消费者，就会从内存中删除。在这种情况下，如果杀死正在执行任务的消费者，会丢失正在处理的消息，也会丢失已经分发给这个消费者但尚未处理的消息。boolean autoAck = false;(手动确认模式) 我们不想丢失任何任务，如果有一个消费者挂掉了，那么我们应该将分发给它的任务交付给另一个消费者去处理。 为了确保消息不会丢失，RabbitMQ支持消息应答。消费者发送一个消息应答，告诉RabbitMQ这个消息已经接收并且处理完毕了。RabbitMQ可以删除它了。- 消息应答是默认打开的。也就是
boolean autoAck =false;
2、Message durability（消息持久化）
我们已经了解了如何确保即使消费者死亡，任务也不会丢失。但是如果RabbitMQ服务器停止，我们的任务仍将失去！当RabbitMQ退出或者崩溃，将会丢失队列和消息。除非你不要队列和消息。两件事儿必须保证消息不被丢失：我们必须把“队列”和“消息”设为持久化。
boolean durable = true;
channel.queueDeclare("hrabbit_queue_work", durable, false, false, null);
这里有一点需要注意的问题，我们直接把durable的false改成true就可以了吗？因为我现在运行的程序中已经存在了hrabbit_queue_work这个队列，当我再次执行的时候，会抛出如下的异常
channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'durable' for queue 'hrabbit_queue_work'
尽管这行代码是正确的，他不会运行成功。因为我们已经定义了一个名叫hrabbit_queue_work的未持久化的队列。RabbitMQ不允许使用不同的参数设定重新定义已经存在的队列，并且会返回一个错误。 一个快速的解决方案——就是声明一个不同名字的队列，比如task_queue。或者我们登录控制台将队列删除就可以了。
系列文章：
RabbitMQ：RabbitMQ-理论基础
RabbitMQ：快速入门hello word
RabbitMQ：RabbitMQ：work queues 工作队列(Round-robin/Fair dispatch)
RabbitMQ：发布/订阅 Publish/Subscribe
RabbitMQ：路由Routing
RabbitMQ：Topic类型的exchange
RabbitMQ：RabbitMQ之消息确认机制（事务+Confirm）
RabbitMQ：spring整合RabbitMQ
网友评论