rabbit ack机制

绝地灬酷狼 2022-06-11 00:53 233阅读 0赞

原文出处：http://rd-030.iteye.com/blog/2313286

每个Consumer可能需要一段时间才能处理完收到的数据。如果在这个过程中，Consumer出错了，异常退出了，而数据还没有处理完成，那么 非常不幸，这段数据就丢失了。因为我们采用no-ack的方式进行确认，也就是说，每次Consumer接到数据后，而不管是否处理完 成，RabbitMQ Server会立即把这个Message标记为完成，然后从queue中删除了。

如果一个Consumer异常退出了，它处理的数据能够被另外的Consumer处理，这样数据在这种情况下就不会丢失了（注意是这种情况下）。   
      为了保证数据不被丢失，RabbitMQ支持消息确认机制，即acknowledgments。为了保证数据能被正确处理而不仅仅是被Consumer收到，那么我们不能采用no-ack。而应该是在处理完数据后发送ack。   
  
    在处理数据后发送的ack，就是告诉RabbitMQ数据已经被接收，处理完成，RabbitMQ可以去安全的删除它了。   
    如果Consumer退出了但是没有发送ack，那么RabbitMQ就会把这个Message发送到下一个Consumer。这样就保证了在Consumer异常退出的情况下数据也不会丢失。   
  
    这里并没有用到超时机制。RabbitMQ仅仅通过Consumer的连接中断来确认该Message并没有被正确处理。也就是说，RabbitMQ给了Consumer足够长的时间来做数据处理。   
  
这样即使你通过Ctr-C中断了Recieve.cs，那么Message也不会丢失了，它会被分发到下一个Consumer。   
  
      如果忘记了ack，那么后果很严重。当Consumer退出时，Message会重新分发。然后RabbitMQ会占用越来越多的内存，由于 RabbitMQ会长时间运行，因此这个“内存泄漏”是致命的。去调试这种错误，可以通过一下命令打印un-acked Messages.   
  
  
如果连接没有断开应用要通知服务器让消息重新发送：   
  
  
可以通过channel.nack(message)来让不通过的消息再次进入消息队列。

Java代码   ![收藏代码][icon_star.png]

1.  **if**(body==’Hello World3!’)\{  
2.     chnl.nack(msg); //这样就可以让这个消息再次进入队列而不用重启服务  
3.  \}**else**\{  
4.     console.log(‘ack’);chnl.ack(msg);  
5.  \}

RabbitMQ将消息投递到客户端后，客户端如果没处理完这个消息就死掉了，这个消息还会不会存在？ **这取决于RabbitMQ的消息确认机制（Message acknowledgment）是否打开** 。   
  
为了确保消息不会丢失，RabbitMQ支持消息确认机制。客户端在接受到消息并处理完后，可以发送一个ack消息给RabbitMQ，告诉它该消息可以安全的删除了。假如客户端在发送ack之前意外死掉了，那么RabbitMQ会将消息投递到下一个consumer客户端。如果有多个consumer客户端，RabbitMQ在投递消息时是轮询的。   
  
RabbitMQ如何判断客户端死掉了？唯一根据是客户端连接是否断开。这里没有超时机制，也就是说客户端可以处理一个消息很长时间，只要没断开连接，RabbitMQ就一直等待ack消息。   
  
**消息确认机制默认是打开的，除非你设置no\_ack=True标记来手工关闭它。**    
  
通过如下命令查看系统里的未确认消息：   
  
\# rabbitmqctl list\_queues -p /path name messages\_unacknowledged   
Listing queues …   
queue\_storm\_actionlog 0   
dev\_queue\_storm\_actionlog 0   
…done.

[icon_star.png]: /images/20220611/d8d0d835e6164d9d8311cba6b3b90b42.png