2. 程式人生 > >RabbitMQ學習筆記五：RabbitMQ之優先級消息隊列

RabbitMQ學習筆記五：RabbitMQ之優先級消息隊列

阿新 • • 發佈：2017-05-16
-c virtual 調用 itl 3.5 rri color images 執行順序

RabbitMQ優先級隊列註意點：

1、只有當消費者不足，不能及時進行消費的情況下，優先級隊列才會生效

2、RabbitMQ3.5以後才支持優先級隊列

代碼在博客：RabbitMQ學習筆記三：Java實現RabbitMQ之與Spring集成 最後面有下載地址，只是做了少許改變，改變的代碼如下：

消費者 spring-config.xml（還需要增加一個QueueListener監聽器，代碼就不復制到這裏了，可以參考項目中的其他監聽器）

<!-- ========================================RabbitMQ========================================= -->
    <!-- 連接工廠 -->
    <rabbit:connection-factory id="
 
connectionFactory" host="localhost" publisher-confirms="true" virtual-host="/" username="guest" password="guest" />
    <!-- 監聽器 -->
    <rabbit:listener-container connection-factory="connectionFactory">
        <!-- queues是隊列名稱，可填多個，用逗號隔開， method是ref指定的Bean調用Invoke方法執行的方法名稱 -->
        <rabbit:listener queues="
 
red" method="onMessage" ref="redQueueListener" />
        <rabbit:listener queues="blue" method="onMessage" ref="blueQueueListener" />
        <rabbit:listener queues="queue" method="queueList" ref="queueListener" />
    </rabbit:listener-container>
    <!-- 隊列聲明 -->
    <rabbit:queue name="
 
red" durable="true" />
    <rabbit:queue name="blue" durable="true" />
    <rabbit:queue name="queue" durable="true" />
    <!-- 紅色監聽處理器 -->
    <bean id="redQueueListener" class="com.aitongyi.customer.RedQueueListener" />
    <!-- 顏色監聽處理器 -->
    <bean id="blueQueueListener" class="com.aitongyi.customer.BlueQueueListener" />
    <!-- 優先級隊列監聽處理器 -->
    <bean id="queueListener" class="com.aitongyi.customer.QueueListener" />

生產者增加一個主方法：

public static void main(String[] args)
    {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses("127.0.0.1:5672");
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        connectionFactory.setVirtualHost("/");
        connectionFactory.setPublisherConfirms(true); // 必須要設置

        RabbitTemplate template = new RabbitTemplate(connectionFactory);

        for (final int i : priority)
        {
            template.convertAndSend("queue", (Object) ("queue" + i), new MessagePostProcessor() {

                @Override
                public Message postProcessMessage(Message arg0) throws AmqpException
                {
                    arg0.getMessageProperties().setPriority(i);
                    return arg0;
                }
            });
        }
    }

當然，還需要在客戶端創建一個優先級隊列：

技術分享

註意，x-max-length = 9999，這個值最後不要寫太大了，否則你電腦的內存會一直處於100%的使用狀態（至於出現這種狀況怎麽解決，請點擊：RabbitMQ學習筆記四：RabbitMQ命令（附疑難問題解決）），並且這個取值範圍在0~255之間，超過了可能會出現問題，我測試了設置9999時，部分有問題，後面會把有問題的地方貼上來。

好了，所有的事情準備完畢了，我們先啟動消費者，然後再運行主方法，此時的隊列優先級設置為，private static final int[] priority = { 1, 5, 1, 2, 3, 4, 5, 5, 0, 3, 6, 10, 4, 100, 99, 98 };執行結果如下：

2017-05-16 09:51:48 399 [INFO] c.a.c.QueueListener - queueList Receved:queue1
2017-05-16 09:51:48 417 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:51:48 435 [INFO] c.a.c.QueueListener - queueList Receved:queue1
2017-05-16 09:51:48 493 [INFO] c.a.c.QueueListener - queueList Receved:queue2
2017-05-16 09:51:48 514 [INFO] c.a.c.QueueListener - queueList Receved:queue3
2017-05-16 09:51:48 596 [INFO] c.a.c.QueueListener - queueList Receved:queue4
2017-05-16 09:51:48 950 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:51:48 975 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:51:49 015 [INFO] c.a.c.QueueListener - queueList Receved:queue0
2017-05-16 09:51:49 039 [INFO] c.a.c.QueueListener - queueList Receved:queue3
2017-05-16 09:51:49 058 [INFO] c.a.c.QueueListener - queueList Receved:queue6
2017-05-16 09:51:49 084 [INFO] c.a.c.QueueListener - queueList Receved:queue10
2017-05-16 09:51:49 102 [INFO] c.a.c.QueueListener - queueList Receved:queue4
2017-05-16 09:51:49 140 [INFO] c.a.c.QueueListener - queueList Receved:queue100
2017-05-16 09:51:49 561 [INFO] c.a.c.QueueListener - queueList Receved:queue99
2017-05-16 09:51:49 595 [INFO] c.a.c.QueueListener - queueList Receved:queue98

很奇怪，沒有按照優先級執行？文章前面已經提到，只有當消費者不足，不能及時進行消費的情況下，優先級隊列才會生效。所以，我們需要先將所有的消息隊列發送至服務器，然後再啟動消費者處理消息，這樣，就可以看到效果了。為了達到這個目的，則需要先運行主方法，然後再啟動消費者，隊列優先級設置和上方一樣，執行結果如下：

2017-05-16 09:56:23 296 [INFO] c.a.c.QueueListener - queueList Receved:queue100
2017-05-16 09:56:23 359 [INFO] c.a.c.QueueListener - queueList Receved:queue99
2017-05-16 09:56:23 438 [INFO] c.a.c.QueueListener - queueList Receved:queue98
2017-05-16 09:56:23 500 [INFO] c.a.c.QueueListener - queueList Receved:queue10
2017-05-16 09:56:23 594 [INFO] c.a.c.QueueListener - queueList Receved:queue6
2017-05-16 09:56:23 656 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:56:23 765 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:56:23 874 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:56:24 077 [INFO] c.a.c.QueueListener - queueList Receved:queue4
2017-05-16 09:56:24 202 [INFO] c.a.c.QueueListener - queueList Receved:queue4
2017-05-16 09:56:24 262 [INFO] c.a.c.QueueListener - queueList Receved:queue3
2017-05-16 09:56:24 311 [INFO] c.a.c.QueueListener - queueList Receved:queue3
2017-05-16 09:56:24 389 [INFO] c.a.c.QueueListener - queueList Receved:queue2
2017-05-16 09:56:24 422 [INFO] c.a.c.QueueListener - queueList Receved:queue1
2017-05-16 09:56:24 500 [INFO] c.a.c.QueueListener - queueList Receved:queue1
2017-05-16 09:56:24 547 [INFO] c.a.c.QueueListener - queueList Receved:queue0

這樣，優先級隊列就實現了，至於相同優先級的隊列，執行順序應該是隨機的吧，我也沒有測試，有興趣的同學可以自己研究。

附：隊列優先級設置為：private static final int[] priority = { 1, 5, 1, 2, 9998, 3, 4, 5, 999, 5, 0, 3, 6, 10, 4, 1000, 9999, 100, 99, 98, 899 };運行結果為：

2017-05-16 09:59:29 839 [INFO] c.a.c.QueueListener - queueList Receved:queue1000
2017-05-16 09:59:29 917 [INFO] c.a.c.QueueListener - queueList Receved:queue999
2017-05-16 09:59:29 995 [INFO] c.a.c.QueueListener - queueList Receved:queue899
2017-05-16 09:59:30 073 [INFO] c.a.c.QueueListener - queueList Receved:queue100
2017-05-16 09:59:30 182 [INFO] c.a.c.QueueListener - queueList Receved:queue99
2017-05-16 09:59:30 275 [INFO] c.a.c.QueueListener - queueList Receved:queue98
2017-05-16 09:59:30 353 [INFO] c.a.c.QueueListener - queueList Receved:queue9999
2017-05-16 09:59:30 431 [INFO] c.a.c.QueueListener - queueList Receved:queue9998
2017-05-16 09:59:30 509 [INFO] c.a.c.QueueListener - queueList Receved:queue10
2017-05-16 09:59:30 619 [INFO] c.a.c.QueueListener - queueList Receved:queue6
2017-05-16 09:59:30 670 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:59:30 733 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:59:30 826 [INFO] c.a.c.QueueListener - queueList Receved:queue5
2017-05-16 09:59:31 138 [INFO] c.a.c.QueueListener - queueList Receved:queue4
2017-05-16 09:59:31 282 [INFO] c.a.c.QueueListener - queueList Receved:queue4
2017-05-16 09:59:31 316 [INFO] c.a.c.QueueListener - queueList Receved:queue3
2017-05-16 09:59:31 379 [INFO] c.a.c.QueueListener - queueList Receved:queue3
2017-05-16 09:59:31 410 [INFO] c.a.c.QueueListener - queueList Receved:queue2
2017-05-16 09:59:31 472 [INFO] c.a.c.QueueListener - queueList Receved:queue1
2017-05-16 09:59:31 712 [INFO] c.a.c.QueueListener - queueList Receved:queue1
2017-05-16 09:59:31 745 [INFO] c.a.c.QueueListener - queueList Receved:queue0

恩，排序結果是有點亂。。。

RabbitMQ學習筆記五：RabbitMQ之優先級消息隊列

相關推薦

RabbitMQ學習筆記五：RabbitMQ之優先級消息隊列

-c virtual 調用 itl 3.5 rri color images 執行順序 RabbitMQ優先級隊列註意點： 1、只有當消費者不足，不能及時進行消費的情況下，優先級隊列才會生效 2、RabbitMQ3.5以後才支持優先級隊列 代碼在博客：RabbitMQ學習筆

RabbitMQ學習筆記八：RabbitMQ的訊息確認

來源： https://blog.csdn.net/chenxyt/article/details/79259838 一、概述     前文說到RabbitMQ的交換機、佇列、訊息的持久化並不能100%的保證訊息不會丟失。首先從生產者端，持久化的訊息在

RabbitMQ學習筆記二：rabbitmq傳送接收訊息Helloworld（Java版）

一 引入rabbitmq java client 前面我們已經在本地（windows下）安裝配置好了RabbitMQ server。現在我們引入rabbitmq Java client。 在eclipse中建立一個maven專案，在pom.xml檔案中加

阿裏Java面試題剖析：為什麽使用消息隊列？消息隊列有什麽優點和缺點？

最終 支持 F12 消費 ... 好處 社區 公司 ces 面試題 為什麽使用消息隊列？消息隊列有什麽優點和缺點？Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什麽區別，以及適合哪些場景？ 面試官心理分析其實面試官主要是想看看： 第一，你知不知道你們

RabbitMQ學習筆記一：本地Windows環境安裝RabbitMQ Server

一：安裝RabbitMQ需要先安裝Erlang語言開發包，百度網盤地址：http://pan.baidu.com/s/1jH8S2u6。直接下載地址：http://erlang.org/download/otp_win64_18.3.exe。 安裝完成後需要配置環境變數： 新建系統變數：變數名 ERLAN

rabbitmq學習（二）：rabbitmq（消息隊列）的作用以及rabbitmq之直連交換機

tde pub 假設 代碼 持久化 tor 安裝 live 服務 前言 　　上篇介紹了AMQP的基本概念，組成及其與rabbitmq的關系。了解了這些東西後，下面我們開始學習rabbitmq（消息隊列）的作用以及用java代碼和rabbitmq通訊進行消息發布和接收。因為消

RabbitMQ學習筆記七：交換機、佇列、訊息的持久化

一、概述     在生產過程中，難免會發生伺服器宕機的事情，RabbitMQ也不例外，可能由於某種特殊情況下的異常而導致RabbitMQ宕機從而重啟，那麼這個時候對於訊息佇列裡的資料，包括交換機、佇列以及佇列中存在訊息恢復就顯得尤為重要了。RabbitMQ本身帶有持久化機制

rabbitmq學習筆記9 ： spring整合rabbitmq

一、準備工作 maven依賴 <dependency>   <groupId>com.rabbitmq</groupId>   <artifactId>amqp-client</artifactId>   <

RabbitMQ學習筆記三：Exchange的學習（1）

一、概述     上一篇文章中講述了一個簡單的訊息傳遞模型，訊息從生產者傳送到消費者再發送到佇列，實際的工作中生產者不知道要把訊息傳送給哪個佇列，可能有多個消費者要生產者的訊息，也可能有的消費者不需要生產者的全部訊息，比如日誌系統，一個消費者需要info級別的資訊，另一個消

RabbitMQ學習筆記一：基本概念與環境搭建

一、定義     MQ（Message Queue，訊息佇列）是基於應用程式之間的一種通訊方式，應用程式通過讀寫出入佇列的訊息進行通訊，而不需要用專用的連線來連線它們。訊息通訊指的是程式之間在訊息中傳遞資訊進行通訊，而不是傳統的通過直接呼叫（如RPC）的方式進行通訊。MQ的

ODOO學習筆記五：Odoo模塊標準組成

實體對象 開發 請求 建模 mode default 測試 odoo 兩個 一：新建一個模塊 一個模塊放在一個文件夾中，我們在odoo項目源碼中新建一個文件夾 car，用於存放模塊car。（一般用一個文件夾專門用來管理我們自定義的模塊） 然後在car目錄下新建兩個文件：__

ES6學習筆記五：Promise異步任務

任務 ted 構造函數 才會 數組 接受 異步操作 異步任務 進行 一：Promise對象 Promise對象代表一個異步操作，有三種狀態：Pending（進行中）、Resolved（已完成，又稱 Fulfilled）和Rejected（已失敗）。 二：創建與使用 v

Python學習筆記五：字符串常用操作，字典，三級菜單實例

rip .get isalnum 變量名 cde tro 分割 字母 isdigit 字符串常用操作 7月19日，7月20日 ，7月22日，7月29日，8月29日，2月29日 首字母大寫：a_str.capitalize() 統計字符串個數：a_str.count(“x”)

linux初級學習筆記五：bash特性詳解！(視頻序號：03_2，3)

可執行文件 文件名通配符 內核 引用 完成 -c family man 文件 本節學習的命令：history，alias，ualias，\CMD 本節學習的技能： 　　　　　　 bash的特性　　　　　　光標跳轉　　　　　　查看命令歷史　　　　　　命令歷史的使用技巧　　

Web安全學習筆記(五)：HTML基礎

class win pic 多少 自己 一是 按鍵 存儲 body ------------------開始------------------ 0x01：前言 今天決定要將《sql註入攻擊與防禦》這本書吃完。今天開了個頭，看了一些，然後還是繼續看大佬們寫的

Linux學習筆記五：Shell基礎

1.shell概述 1.echo 2.第一個bash指令碼 3.dos2unix將在windows下編寫的shell指令碼轉化成linux格式，防止有字元不一樣 1.history命令 2.Tab補全 1.命令別名alinas 2.命令執行順序 3.快捷鍵

分散式學習筆記五：redis分步式鎖

前言 分散式鎖一般有三種實現方式：1. 資料庫樂觀鎖；2. 基於Redis的分散式鎖；3. 基於ZooKeeper的分散式鎖。本篇部落格將介紹第二種方式，基於Redis實現分散式鎖。雖然網上已經有各種介紹Redis分散式鎖實現的部落格，然而他們的實現卻有著各種各樣的問題，本篇部落格將詳細介紹如何

python爬蟲學習筆記五：Re庫的介紹和使用

Re庫介紹 Re庫是Python的標準庫，主要用於字串匹配。 呼叫方式： import re 正則表示式的表示型別 *raw string 型別（原生字串型別）： re庫採用raw string型別表示正則表示式，表示為：r'text' 例如：r'[1-9]\d{5}

Esper學習筆記五：EPL語法（3）

1.Aggregation 類似於SQL中的聚合函式，EPL中聚合函式格式如下： aggregate_function([all|distinct] expression) aggregate_function就是聚合函式的名字，比如avg，sum等。expression通常是事件

LTE學習筆記五：LTE兩種幀結構

上、下行資訊如何複用有限的無線資源，這是所有無線制式必須考慮的雙工技術問題。以往的無線制式要麼支援時分雙工（TDD）要麼支援頻分雙工（FDD），而LTE標準即支援TDD，又支援FDD，分別對應著不同的幀結構設計。 1.兩種雙工模式 LTE支援兩種雙工模式：TDD和FDD，