RabbitMQ消息可靠性（二）

#RabbitMQ消息可靠性（二）
上一篇文章我们介绍了如何确保RabbitMQ消息发送的可靠性。本节介绍消息消费的可靠性。

一、推模式手动确认二、拉模式手动确认

spring: rabbitmq: virtual-host: / host: 127.0.0.1 port: 5672 username: guest password: guest listener: simple: ## 消息手动确认 acknowledge-mode: manual

@RabbitListener(queues = RabbitConfig.QUEUE_NAME) public void listenMessage(Message message, Channel channel){ long deliveryTag = message.getMessageProperties().getDeliveryTag(); try { byte[] body = message.getBody(); String s = new String(body); logger.info("message=====> {}",s); int i = 1/0; // 仅确认当前消息 channel.basicAck(deliveryTag,false); } catch (Exception e) { try { // 重新放入队列中 channel.basicNack(deliveryTag,false,true); } catch (IOException ioException) { ioException.printStackTrace(); } } }

@Testvoid contextLoads() {long deliveryTag = 0;Channel channel = rabbitTemplate.getConnectionFactory().createConnection().createChannel(false);try {GetResponse response = channel.basicGet(RabbitConfig.QUEUE_NAME, false);deliveryTag = response.getEnvelope().getDeliveryTag();byte[] body = response.getBody();String s = new String(body);System.out.println(s);channel.basicAck(deliveryTag,false);} catch (Exception e) {try {channel.basicNack(deliveryTag,false,true);} catch (IOException ioException) {ioException.printStackTrace();}}}