日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

RabbitMQ消息的确认模式

發布時間:2025/3/20 编程问答 21 豆豆
生活随笔 收集整理的這篇文章主要介紹了 RabbitMQ消息的确认模式 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

確認模式

包括兩種自動確認、手動確認

自動確認
只要消息從隊列中獲取,無論消費者獲取到消息后,
是否執行成功,都認為是消息已經成功消費。

手動確認
消費者從隊列中獲取消息后,服務器會將該消息標記為不可用狀態
等待消費者的反饋,如果消費者一直沒有反饋
那么該消息將一直處于不可用狀態。

自動確認

// 監聽隊列 channel.basicConsume(QUEUE_NAME, true, consumer);// 獲取消息 while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'"); }

true
表示自動確認
不需要返回,只需要獲取消息
此時,就認為消息已經成功消費

手動確認

// 監聽隊列,手動返回完成 channel.basicConsume(QUEUE_NAME, false, consumer);// 獲取消息 while (true) {QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println(" [x] Received '" + message + "'");//休眠Thread.sleep(10);// 返回確認狀態channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); }

False
表示手動確認
手動,消息執行完成之后
需要向服務端,返回一個消息的狀態

《新程序員》:云原生和全面數字化實踐50位技術專家共同創作,文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的RabbitMQ消息的确认模式的全部內容,希望文章能夠幫你解決所遇到的問題。

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