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); // 消息的標識佃延，false只確認當前一個消息收到，true確認所有consumer獲得的消息
// channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true); // ack返回false竹祷，并重新回到隊列儿捧，api里面解釋得很清楚
// channel.basicReject(message.getMessageProperties().getDeliveryTag(), true); // 拒絕消息
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true); // ack返回false，并重新回到隊列夯尽，api里面解釋得很清楚
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
3.好處
消費者掛掉后褥赊，消息還可以再次消費
消費出現(xiàn)問題時蝌麸，可以再次消費，或分發(fā)給別的消費者
