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

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

一、一般消息隊列生產(chǎn)和消費類型

1. 一次性任務消費

從某個地方一次性寫入多個任務到隊列, 消費完成后就算完成

2. 不斷寫入的任務消費

一般是判斷隊列任務少了, 就開始寫入任務, 隊列任務足夠則不寫入任務。對應的消費進程也是持久性進程。

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

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

二、如何計算出來消費一輪的時間以及消費速率

1. 通過統(tǒng)計任務開始和結束, 計算消費總時間

當時最早想到的就是這種方式, 這種方式的優(yōu)點:

1. 統(tǒng)計相對準確

缺點:

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

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

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

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

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

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

---

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

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

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

廣告

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