上面那種方式非常慢，與單個等待確認消息相比，先發布一批消息然后一起確認可以極大地提高吞吐量，當然這種方式的缺點就是:當發生故障導致發布出現問題時，不知道是哪個消息出現問題了，我們必須將整個批處理保存在內存中，以記錄重要的信息而后重新發布消息。當然這種方案仍然是同步的，也一樣阻塞消息的發布。

/* * 發布確認模式， * 1、單個確認 * 2、批量確認 * 3、異步批量確認 * */ public class ComfirmMessage {// 批量發消息的個數public static final int MESSAGE_COUNT = 1000;public static void main(String[] args) throws Exception {//2、批量確認// 發布1000個批量確認消息，耗時37msComfirmMessage.publishMessageBatch();}public static void publishMessageBatch() throws Exception{Channel channel = RabbitMqUtils.getChannel();String queueName = UUID.randomUUID().toString();channel.queueDeclare(queueName,false,false,false,null);// 開啟發布確認channel.confirmSelect();// 開始時間long begin = System.currentTimeMillis();// 批量確認消息大小int batchSize = 1000;// 批量發送 批量確認for (int i = 0; i < MESSAGE_COUNT; i++) {String message = i + "";channel.basicPublish("",queueName,null,message.getBytes(StandardCharsets.UTF_8));// 判斷達到100條消息的時候，批量確認一次if (i%batchSize == 0){// 確認發布channel.waitForConfirms();}}// 結束時間long end = System.currentTimeMillis();System.out.println("發布"+MESSAGE_COUNT+"個批量確認消息，耗時"+ (end - begin) + "ms");} }

總結

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

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