阅读量:3
RabbitMQ消息确认机制分为生产者和消费者确认,设置方式如下:
- 生产者确认:
- 开启确认模式:在配置文件中设置
spring.rabbitmq.publisher-confirm-type=correlated。 - 添加回调:通过
rabbitTemplate.setConfirmCallback()方法设置ConfirmCallback回调函数,处理消息是否成功到达交换机的确认逻辑。
- 开启确认模式:在配置文件中设置
- 消费者确认:
- 配置确认模式:在配置文件中设置
spring.rabbitmq.listener.simple.acknowledge-mode=manual来开启手动确认模式。 - 手动确认消息:在消费者代码中,通过
channel.basicAck(deliveryTag, multiple)方法确认消息,deliveryTag是消息唯一标识,multiple表示是否批量确认。若要拒绝消息,可使用channel.basicNack(deliveryTag, multiple, requeue)或channel.basicReject(deliveryTag, requeue)方法,requeue参数决定是否将消息重新入队。
- 配置确认模式:在配置文件中设置
以上就是关于“rabbitmq消息确认机制怎么设置”的相关介绍,筋斗云是国内较早的云主机应用的服务商,拥有10余年行业经验,提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩,主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复;电子化备案,提交快速,专业团队7×24小时服务支持!
简单好用、高性价比云服务器租用链接:https://www.jindouyun.cn/product/cvm