RabbitMQ消息应答------ack机制
2016-02-15 20:44
295 查看
Message acknowledgment(消息应答)
执行一个任务可能需要花费几秒钟,你可能会担心如果一个消费者在执行任务过程中挂掉了。一旦RabbitMQ将消息分发给了消费者,就会从内存中删除。在这种情况下,如果正在执行任务的消费者宕机,会丢失正在处理的消息和分发给这个消费者但尚未处理的消息。但是,我们不想丢失任何任务,如果有一个消费者挂掉了,那么我们应该将分发给它的任务交付给另一个消费者去处理。
为了确保消息不会丢失,RabbitMQ支持消息应答。消费者发送一个消息应答,告诉RabbitMQ这个消息已经接收并且处理完毕了。RabbitMQ就可以删除它了。
如果一个消费者挂掉却没有发送应答,RabbitMQ会理解为这个消息没有处理完全,然后交给另一个消费者去重新处理。这样,你就可以确认即使消费者偶尔挂掉也不会丢失任何消息了。
没有任何消息超时限制;只有当消费者挂掉时,RabbitMQ才会重新投递。即使处理一条消息会花费很长的时间。
消息应答是默认打开的。我们通过显示的设置autoAsk=true关闭这种机制。现即自动应答开,一旦我们完成任务,消费者会自动发送应答。通知RabbitMQ消息已被处理,可以从内存删除。如果消费者因宕机或链接失败等原因没有发送ACK(不同于ActiveMQ,在RabbitMQ里,消息没有过期的概念),则RabbitMQ会将消息重新发送给其他监听在队列的下一个消费者。
代码示例:
生产者端代码不变,消费者端代码这部分就是用于开启手动应答模式的。
<span style="font-family:Arial;"> // 监听队列,手动返回完成 channel.basicConsume(QUEUE_NAME, false, consumer);</span>
注:第二个参数值为false代表关闭RabbitMQ的自动应答机制,改为手动应答。
在处理完消息时,返回应答状态。
<span style="font-family:Arial;"> // 返回确认状态 channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);</span>
在处理完消息时,返回应答状态。
相关文章推荐
- Android资源文件详解
- 160cracked-1
- 概率论与数理统计(随机变量及概率分布)
- javascript-页面跳转-(咋个办呢-zgbn)
- windows 远程桌面连接 RPi 2B
- 2.2 常用工具类 网络 支撑 JSON
- Java的构造器
- 戴尔N5110装WIN10的体验
- AndroidManifest.xml
- Android入门小示例_一键SOS
- Asp.net MVC 视图之公用代码
- 【鬼脸原创】谷歌插件--知乎快捷翻页(2016/2/17更新)
- 程序结构&&程序设计(二)
- ORACLE系统表总结
- 转载 前端基础知识体系 一个新手的学习之路
- c语言:输入两个正整数m和n,求其最大公约数和最小公倍数
- 实现两个变量的互换(不借助第三个变量)
- 【设计模式】5、单例模式
- c# 继承
- 用RMI实现基于Java的分布式计算