《英雄聯盟》夏季賽總決賽今日開打！JDG對陣LNG首發名單來了 Knight：準備三連冠
8月5日消息，今日17:00，《英雄聯盟》2023LPL夏季賽總決賽將正式開打，由JDG對陣LNG。對兩支隊伍來說，這場比賽不僅要爭奪夏季賽冠軍，更要決定誰才是LPL賽區一
延遲隊列：簡單說就是發送出去的消息經過給定的時間后，消費者才能看見消息（消費消息）。
這里簡單說下步驟：
優先級隊列是在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" })@RabbitHandlerpublic 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消費消息：
圖片
同樣是按照順序輸出的。
本文鏈接：http://www.tebozhan.com/showinfo-26-5153-0.htmlSpringBoot整合RabbitMQ延遲隊列&優先級隊列詳解
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號