rabbitmq消息确认机制怎么设置

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参数决定是否将消息重新入队。