1.yml配置
2.監(jiān)聽者
@RabbitListener(queues = "ack.test")
public void handleMessage5(String data,Channel channel, Message message) {
System.out.println("ack.test接收到的消息 : " + data);
try {
Thread.sleep(5000L);
// channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); // 消息的標(biāo)識(shí)，false只確認(rèn)當(dāng)前一個(gè)消息收到，true確認(rèn)所有consumer獲得的消息
// channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true); // ack返回false，并重新回到隊(duì)列，api里面解釋得很清楚
// channel.basicReject(message.getMessageProperties().getDeliveryTag(), true); // 拒絕消息
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true); // ack返回false，并重新回到隊(duì)列，api里面解釋得很清楚
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
3.好處
消費(fèi)者掛掉后，消息還可以再次消費(fèi)
消費(fèi)出現(xiàn)問題時(shí)，可以再次消費(fèi)，或分發(fā)給別的消費(fèi)者
