RabbitMQ系列教程 高級篇六 消費端自定義監聽

本文是《RabbitMQ系列教程》中的十三篇：RabbitMQ消息中間件技術精講13 高級篇六 消費端自定義監聽。如果對RabbitMQ感興趣的同學，建議從第一篇開始

在之前的代碼中我們一般就是在代碼中寫while循環，進行consumer.nexDelivery方法進行獲取下一條消息，然後進行消費處理。

但是在工作中，我們一般使用自定義的Consumer更加的方便，解耦性更加的強。

代碼如下：

自定義消費監聽類完整代碼：

使用：

在消費者端代碼修改如下：

將原來的while循環替換成了自定義的消費監聽類。

啟動代碼查看運行：查看消費者端的運行結果，入下圖：

我們看到在envelope對象中有個deliveryTag屬性。大家還記著這個屬性碼？在前面的課程中，我們講過這個屬性了。在confirm消息確認的那一篇文章中，我們知道了deliveryTag是消息的唯一標籤。在消息確認監聽的時候會使用到。

我們發現，唯一標籤默認情況下是自增長的。

本節總結：

相關代碼已經推送到git上面了。歡迎大家下載.歡迎關注凱哥(凱哥Java【凱哥Java】)

在下一節課中，我們將講解一個重要的知識點：消費端怎麼進行限流。

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！