4RabbitMQ-消息应答与消息持久化

Posted 2021-02-13 mrchengs

消息应答（ Message acknowledgment）

1、 Message acknowledgment（消息应答）

执行任务可能需要几秒钟。你可能想知道如果其中一个消费者开始一项长期任务并且只是部分完

成而死亡会发生什么。使用我们当前的代码，一旦RabbitMQ向消费者发送消息，它立即将其标

记为删除。在这种情况下，如果你杀死一个工人，我们将丢失它刚刚处理的消息。我们还将丢

失分发给这个特定工作者但尚未处理的所有消息。

 

但我们不想失去任何任务。如果工人死亡，我们希望将任务交付给另一名工人。

 

为了确保消息永不丢失，RabbitMQ支持 消息确认。消费者发回ack（nowledgement）告诉RabbitMQ已收到，

处理了特定消息，RabbitMQ可以自由删除它。

 

如果消费者死亡（其通道关闭，连接关闭或TCP连接丢失）而不发送确认，RabbitMQ将理解消息未完全处理并将重新

排队。如果同时有其他在线消费者，则会迅速将其重新发送给其他消费者。这样你就可以确保没有消息丢失，即使工人偶尔会死亡。

 

没有任何消息超时; 当消费者死亡时，RabbitMQ将重新发送消息。即使处理消息需要非常长的时间，也没关系。

 

默认情况下，手动消息确认已打开。在前面的示例中，我们通过autoAck = true 标志明确地将它们关闭。

一旦我们完成任务，就应该将此标志设置为false并从工作人员发送适当的确认。

 

 

 

消息持久化（Message durability）

 http://www.rabbitmq.com/tutorials/tutorial-two-java.html

我们已经学会了如何确保即使消费者死亡，任务也不会丢失。

但是如果RabbitMQ服务器停止，我们的任务仍然会丢失。

 

当RabbitMQ退出或崩溃时，它将忘记队列和消息，除非你告诉它不要。

确保消息不会丢失需要做两件事：我们需要将队列和消息都标记为持久。

 

DeclareOk com.rabbitmq.client.Channel.queueDeclare(String queue, boolean durable,

 boolean exclusive, boolean autoDelete, Map<String, Object> arguments) throws IOException

 

已经运行的工程之后，再次运行将会报错！！！！

 

 

尽管这行代码是正确的，他不会运行成功。因为我们已经定义了一个名叫 test_queue_work 的未持久化的队列。

RabbitMQ 不允许使用不同的参数设定重新定义已经存在的队列，并且会返回一个错误。

一个快速的解决方案——就是声明一个不同名字的队列，比如 task_queue。或者我们登录控制台将队列删除就可以了

 

官方解释：

将消息标记为持久性并不能完全保证消息不会丢失。虽然它告诉RabbitMQ将消息保存到磁盘，

但是当RabbitMQ接受消息并且尚未保存消息时，仍然有一个短时间窗口。

此外，RabbitMQ不会为每条消息执行fsync（2） - 它可能只是保存到缓存而不是真正写入磁盘。

持久性保证不强，但对于我们简单的任务队列来说已经足够了。