一加Ace2 Pro官宣：普及16G內(nèi)存 引領(lǐng)24G
一加官方今天繼續(xù)為本月發(fā)布的新機(jī)一加Ace2 Pro帶來預(yù)熱，公布了內(nèi)存方面的信息。“淘汰 8GB ，12GB 起步，16GB 普及，24GB 引領(lǐng)，還有呢？#一加Ace2Pro#，2023 年 8 月，敬請期待。”同時(shí)
延遲隊(duì)列：簡單說就是發(fā)送出去的消息經(jīng)過給定的時(shí)間后，消費(fèi)者才能看見消息（消費(fèi)消息）。
這里簡單說下步驟：
優(yōu)先級隊(duì)列是在RabbitMQ3.5.0之后的版本才支持的。
具有高優(yōu)先級的隊(duì)列具有高的優(yōu)先權(quán)，優(yōu)先級高的消息具備優(yōu)先被消費(fèi)的特權(quán)。
隊(duì)列的優(yōu)先級通過x-max-priority參數(shù)設(shè)置。
建立一個(gè)priority-exchange交換機(jī)，類型：direct。
圖片
建立一個(gè)priority-queue隊(duì)列，并與priority-exchange綁定。
圖片
設(shè)置x-max-priority參數(shù)的值為100，表示最大優(yōu)先級為100。
注意：x-max-priority參數(shù)的值應(yīng)該介于1到255。建議使用1到10之間的隊(duì)列。如果設(shè)置的優(yōu)先級更大將使用更多的Erlang進(jìn)程消耗更多的CPU資源。運(yùn)行時(shí)調(diào)度也會受到影響。
接下來演示優(yōu)先級隊(duì)列
我們先只發(fā)送消息，然后再把消息的消費(fèi)功能打開。
發(fā)送消息接口：
@GetMapping("/sendPriority")public Object sendPriority(String msg, Integer priority) { ms.sendPriorityQueue(msg, priority) ; return "success" ;}public void sendPriorityQueue(String msg, Integer priority) { logger.info("準(zhǔn)備發(fā)送消息：{}", msg); Message message = MessageBuilder.withBody(msg.getBytes()).setPriority(priority).build() ; rabbitTemplate.convertAndSend("priority-exchange", "pe.msg", message) ;}發(fā)送4條消息：
// 第一條消息msg=第一條消息&priority=2 // 第二條消息msg=第二條消息&priority=10// 第三條消息msg=第三條消息&priority=1// 第四條消息msg=第四條消息&priority=7查看消息隊(duì)列：
圖片
消息消費(fèi)端：
@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("接受到消息來自交換機(jī): 【" + mps.getReceivedExchange() + "】, 隊(duì)列：【" + mps.getConsumerQueue()+ "】：/n內(nèi)容: " + content); channel.basicAck(message.getMessageProperties().getDeliveryTag(), true); } catch (Exception e) { e.printStackTrace(); try { channel.basicReject(mps.getDeliveryTag(), false); } catch (IOException e1) { e1.printStackTrace() ; } }}啟動(dòng)服務(wù)
圖片
根據(jù)打印出的結(jié)果，正好是我們設(shè)置優(yōu)先級的順序輸出。
上面設(shè)置的消息優(yōu)先級都是在指定的范圍<100，如果消息的優(yōu)先級超過這個(gè)值會怎么樣呢？
發(fā)送8條消息：
// 第一條消息msg=第一條消息&priority=2 // 第二條消息msg=第二條消息&priority=10// 第三條消息msg=第三條消息&priority=1// 第四條消息msg=第四條消息&priority=7// 第五條消息msg=第五條消息&priority=101消費(fèi)消息：
圖片
同樣是按照順序輸出的。
本文鏈接：http://m.rrqrq.com/showinfo-26-5153-0.htmlSpringBoot整合RabbitMQ延遲隊(duì)列&優(yōu)先級隊(duì)列詳解
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
上一篇： 如何使用Asp.net Core實(shí)現(xiàn)定時(shí)任務(wù)，輕松解決任務(wù)調(diào)度問題！
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號