消息隊(duì)列在執(zhí)行過程中, 如何統(tǒng)計(jì)消息隊(duì)列執(zhí)行一輪的時(shí)間以及效率呢? 如果消息隊(duì)列中的任務(wù)變多, 則需要對應(yīng)增加消費(fèi)進(jìn)程, 保證隊(duì)列不被堆積。

創(chuàng)新互聯(lián)公司是一家專業(yè)提供禪城企業(yè)網(wǎng)站建設(shè),專注與成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、H5網(wǎng)站設(shè)計(jì)、小程序制作等業(yè)務(wù)。10年已為禪城眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站制作公司優(yōu)惠進(jìn)行中。

一、一般消息隊(duì)列生產(chǎn)和消費(fèi)類型

1. 一次性任務(wù)消費(fèi)

從某個(gè)地方一次性寫入多個(gè)任務(wù)到隊(duì)列, 消費(fèi)完成后就算完成

2. 不斷寫入的任務(wù)消費(fèi)

一般是判斷隊(duì)列任務(wù)少了, 就開始寫入任務(wù), 隊(duì)列任務(wù)足夠則不寫入任務(wù)。對應(yīng)的消費(fèi)進(jìn)程也是持久性進(jìn)程。

3. 有任務(wù)則寫入, 然后持續(xù)消費(fèi)

隨時(shí)可能有任務(wù)產(chǎn)生, 之后不斷消費(fèi)。任務(wù)寫入時(shí)間不可控, 所以消費(fèi)進(jìn)程一般也得是持久性進(jìn)程。

二、如何計(jì)算出來消費(fèi)一輪的時(shí)間以及消費(fèi)速率

1. 通過統(tǒng)計(jì)任務(wù)開始和結(jié)束, 計(jì)算消費(fèi)總時(shí)間

當(dāng)時(shí)最早想到的就是這種方式, 這種方式的優(yōu)點(diǎn):

1. 統(tǒng)計(jì)相對準(zhǔn)確

缺點(diǎn):

1. 流程復(fù)雜且耦合性高
2. 如果中間有隊(duì)列暫停之類的時(shí)間, 也會被包含進(jìn)時(shí)間內(nèi)。

2. 通過讀取隊(duì)列狀態(tài), 獲取到一定時(shí)間內(nèi)消耗數(shù)量

根據(jù)兩次讀取的任務(wù)數(shù), 得到固定時(shí)間內(nèi)的消耗掉的任務(wù)數(shù), 計(jì)算出來執(zhí)行的任務(wù)。

3. 通過計(jì)算單個(gè)任務(wù)的執(zhí)行時(shí)間, 然后根據(jù)運(yùn)行的進(jìn)程數(shù), 來計(jì)算一輪的時(shí)間。

之后根據(jù)運(yùn)行進(jìn)程數(shù), 以及任務(wù)總數(shù), 來獲取到一輪的更新時(shí)間。 或者一段時(shí)間內(nèi)取樣, 來計(jì)算需要的機(jī)器和進(jìn)程數(shù)。

如果有其他更好的辦法, 希望可以一起交流下。

---

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國云服務(wù)器，動(dòng)態(tài)BGP最優(yōu)骨干路由自動(dòng)選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機(jī)房獨(dú)有T級流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進(jìn)行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動(dòng)現(xiàn)已開啟，新人活動(dòng)云服務(wù)器買多久送多久。

網(wǎng)頁題目：關(guān)于消息隊(duì)列速率的解決方案-創(chuàng)新互聯(lián)
本文網(wǎng)址：http://vcdvsql.cn/article26/ccidjg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站導(dǎo)航、App開發(fā)、微信小程序、網(wǎng)頁設(shè)計(jì)公司、ChatGPT、網(wǎng)站維護(hù)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)