溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
消息隊列在執行過程中, 如何統計消息隊列執行一輪的時間以及效率呢? 如果消息隊列中的任務變多, 則需要對應增加消費進程, 保證隊列不被堆積。
從某個地方一次性寫入多個任務到隊列, 消費完成后就算完成
一般是判斷隊列任務少了, 就開始寫入任務, 隊列任務足夠則不寫入任務。對應的消費進程也是持久性進程。
隨時可能有任務產生, 之后不斷消費。任務寫入時間不可控, 所以消費進程一般也得是持久性進程。
當時最早想到的就是這種方式, 這種方式的優點:
缺點:
根據兩次讀取的任務數, 得到固定時間內的消耗掉的任務數, 計算出來執行的任務。
之后根據運行進程數, 以及任務總數, 來獲取到一輪的更新時間。 或者一段時間內取樣, 來計算需要的機器和進程數。
如果有其他更好的辦法, 希望可以一起交流下。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
