這是一種簡單的確認方式，它是一種同步確認發布的方式，也就是發布一個消息之后只有它被確認發布，后續的消息才能繼續發布, waitForConfirmsOrDie(long)這個方法只有在消息被確認的時候才返回，如果在指定時間范圍內這個消息沒有被確認那么它將拋出異常。

這種確認方式有一個最大的缺點就是：發布速度特別的慢，因為如果沒有確認發布的消息潁會阻塞所有后續消息的發布，這種方式最多提供每秒不超過數百條發布消息的吞吐量。當然對于某些應用程序來說這可能已經足夠了。

/** 發布確認模式，* 1、單個確認* 2、批量確認* 3、異步批量確認* */public class ComfirmMessage {// 批量發消息的個數public static final int MESSAGE_COUNT = 1000;public static void main(String[] args) throws Exception {// 1、單個確認// 發布1000個單獨確認消息，耗時567msComfirmMessage.publishMessageIndividually();}public static void publishMessageIndividually() throws Exception {Channel channel = RabbitMqUtils.getChannel();String queueName = UUID.randomUUID().toString();channel.queueDeclare(queueName,false,false,false,null);// 開啟發布確認channel.confirmSelect();// 開始時間long begin = System.currentTimeMillis();// 批量發消息for (int i = 0; i < MESSAGE_COUNT; i++) {String message = i + "";channel.basicPublish("",queueName,null,message.getBytes(StandardCharsets.UTF_8));// 單個消息馬上進行發布確認boolean flag = channel.waitForConfirms();if (flag){System.out.println("消息發送成功");}}// 結束時間long end = System.currentTimeMillis();System.out.println("發布"+MESSAGE_COUNT+"個單獨確認消息，耗時"+ (end - begin) + "ms");} }

超強干貨來襲 云風專訪：近40年碼齡，通宵達旦的技術人生

總結

以上是生活随笔為你收集整理的RabbitMQ单个发布确认的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。