springboot + rabbitmq 消费者消息确认 (Ack)
2019-01-31 14:49
525 查看
springboot + rabbitmq 消费者消息确认 (Ack)
开启消息确认
spring.rabbitmq.listener.direct.acknowledge-mode=manual spring.rabbitmq.listener.simple.acknowledge-mode=manual
消费者
@Component public class RabbitMqComponent7 { @RabbitListener(queues = "queueAck") public void listerQueueR1(Channel channel,String message,@Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException { System.out.print(message); channel.basicAck(tag,false); } }
channel.basicAck(deliveryTag, false);
deliveryTag:该消息的index
multiple:是否批量.true:将一次性ack所有小于deliveryTag的消息。
channel.basicNack(deliveryTag, false, true);
deliveryTag:该消息的index
multiple:是否批量.true:将一次性拒绝所有小于deliveryTag的消息。
requeue:被拒绝的是否重新入队列
channel.basicReject(deliveryTag:, false);
deliveryTag:该消息的index
requeue:被拒绝的是否重新入队列
相关文章推荐
- Spring Boot RabbitMQ 延迟消息实现完整版示例
- spring boot Rabbitmq集成,延时消息队列实现
- 第四十六章:SpringBoot & RabbitMQ完成消息延迟消费
- Spring Boot + RabbitMQ 实现消息队列场景
- RabbitMQ ACK 消息确认机制
- spring boot Rabbitmq集成,延时消息队列实现
- Spring ActiveMQ 整合(三): 确认机制ACK(收到消息后,应该有一个回应也就是确认答复)
- Spring Boot RabbitMQ 延迟消息实现完整版
- 集群与负载均衡系列(6)——消息队列之rabbitMQ+spring-boot+spring amqp发送可靠的消息
- SpringBoot + RabbitMQ 使用Demo
- Spring boot+RabbitMQ环境
- spring boot rabbitmq 多MQ配置 自动 创建 队列 RPC
- Springboot + rabbitMQ实现延迟消费以及spring与策略模式联合处理不同的业务(二)
- 基于dubbo的分布式项目框架搭建 开发工具idea (springboot+dubbo+zookeeper+redis+rabbitmq+基于Swagger2的restful api) --(一)
- 详细介绍Spring Boot + RabbitMQ实现延迟队列
- spring boot rabbitmq学习
- spring boot+RabbitMQ
- springboot+rabbitmq整合示例程
- spring activeMQ 整合(三): 确认机制ACK(收到消息后,应该有一个回应也就是确认答复)
- springboot+RabbitMq之topic和fanout