SpringBoot整合RabbitMQ延遲隊列&優先級隊列詳解
作者：Springboot實戰案例錦集
發送消息發送到bs-queue上。由于消息消費端監聽的是死信隊列，所以只需要等待指定的時間后消息會自動被轉發到死信隊列上（dead-queue）。
延遲隊列
延遲隊列：簡單說就是發送出去的消息經過給定的時間后，消費者才能看見消息（消費消息）。
這里簡單說下步驟：
- 創建一個隊列，如：bs-queue, 設置死信交換機（死信交換機路由key（這是可選的））及隊列，如：dead-exchange; 消息的消費端監聽該dead-queue隊列。設置消息有效期參數x-message-ttl參數（值為自己需要延遲的時間，單位：毫秒）。
- 發送消息發送到bs-queue上。由于消息消費端監聽的是死信隊列，所以只需要等待指定的時間后消息會自動被轉發到死信隊列上（dead-queue）。
- 消息的消費端監聽dead-queu隊列即可。
優先級隊列
優先級隊列是在RabbitMQ3.5.0之后的版本才支持的。
具有高優先級的隊列具有高的優先權，優先級高的消息具備優先被消費的特權。
隊列的優先級通過x-max-priority參數設置。
建立一個priority-exchange交換機，類型：direct。
圖片
建立一個priority-queue隊列，并與priority-exchange綁定。
圖片
設置x-max-priority參數的值為100，表示最大優先級為100。
注意：x-max-priority參數的值應該介于1到255。建議使用1到10之間的隊列。如果設置的優先級更大將使用更多的Erlang進程消耗更多的CPU資源。運行時調度也會受到影響。
接下來演示優先級隊列
我們先只發送消息，然后再把消息的消費功能打開。
發送消息接口：
@GetMapping("/sendPriority")
public Object sendPriority(String msg, Integer priority) {
ms.sendPriorityQueue(msg, priority) ;
return "success" ;
}
public void sendPriorityQueue(String msg, Integer priority) {
logger.info("準備發送消息：{}", msg);
Message message = MessageBuilder.withBody(msg.getBytes()).setPriority(priority).build() ;
rabbitTemplate.convertAndSend("priority-exchange", "pe.msg", message) ;
}發送4條消息：
// 第一條消息
msg=第一條消息&priority=2
// 第二條消息
msg=第二條消息&priority=10
// 第三條消息
msg=第三條消息&priority=1
// 第四條消息
msg=第四條消息&priority=7查看消息隊列：
圖片
消息消費端：
@RabbitListener(queues = { "priority-queue" })
@RabbitHandler
public void listenerPriority(Message message, Channel channel) {
System.out.println("接受到消息.....income");
byte[] body = message.getBody();
MessageProperties mps = message.getMessageProperties();
String content = new String(body, Charset.forName("UTF-8"));
try {
System.out.println("接受到消息來自交換機: 【" + mps.getReceivedExchange() + "】, 隊列：【" + mps.getConsumerQueue()+ "】：\n內容: " + content);
channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
} catch (Exception e) {
e.printStackTrace();
try {
channel.basicReject(mps.getDeliveryTag(), false);
} catch (IOException e1) {
e1.printStackTrace() ;
}
}
}啟動服務
圖片
根據打印出的結果，正好是我們設置優先級的順序輸出。
上面設置的消息優先級都是在指定的范圍<100，如果消息的優先級超過這個值會怎么樣呢？
發送8條消息：
// 第一條消息
msg=第一條消息&priority=2
// 第二條消息
msg=第二條消息&priority=10
// 第三條消息
msg=第三條消息&priority=1
// 第四條消息
msg=第四條消息&priority=7
// 第五條消息
msg=第五條消息&priority=101消費消息：
圖片
同樣是按照順序輸出的。
責任編輯：武曉燕
來源：
Spring全家桶實戰案例源碼
