[發(fā)明專利]基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法和裝置

在審

• 申請?zhí)枺?/td>: 202011609304.X
• 申請日: 2020-12-30
• 公開（公告）號: CN114691310A
• 公開（公告）日: 2022-07-01
• 發(fā)明（設(shè)計）人: 吳茂昌;徐正禮
• 申請（專利權(quán)）人: 北京易掌云峰科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/54
• 代理公司: 北京戈程知識產(chǎn)權(quán)代理有限公司 11314
• 代理人: 程偉;甄雁翔

本發(fā)明涉及基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法和裝置。基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法包括：當接收到需要計時的業(yè)務(wù)服務(wù)請求時，創(chuàng)建需要計時的任務(wù)；創(chuàng)建延遲隊列，將需要計時的任務(wù)放入創(chuàng)建的延遲隊列中，通過所述延遲隊列來維護需要計時的任務(wù)的列表；創(chuàng)建守護線程來監(jiān)聽延遲隊列中到期的需要計時的任務(wù)，以獲取要處理的需要計時的任務(wù)；創(chuàng)建任務(wù)執(zhí)行線程池，以將要處理的需要計時的任務(wù)放入所述任務(wù)執(zhí)行線程池中；通知相應的業(yè)務(wù)邏輯處理的服務(wù)，以進行后續(xù)的業(yè)務(wù)邏輯處理。基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法和裝置具有計時與過期邏輯的較強實時性。

技術(shù)領(lǐng)域

本發(fā)明涉及計算機技術(shù)領(lǐng)域，具體地說是基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法和裝置。

背景技術(shù)

在客服系統(tǒng)對會話聊天處理過程中，需要在會話處理過程中實現(xiàn)幾種超時場景，用于在計時完畢后的相應場景下進行相應的業(yè)務(wù)邏輯處理，例如發(fā)送通知消息給客服、發(fā)送通知消息給訪客等等。但是，在會話處理過程中，計時有時會出現(xiàn)偏差，因此依據(jù)出現(xiàn)的計時偏差而進行的后續(xù)業(yè)務(wù)處理邏輯也會出現(xiàn)問題。所以在會話處理邏輯后，需要減少或去除計時中出現(xiàn)的偏差。

目前，可以采用基于Redis的時間輪(time wheel)實現(xiàn)的處理方式。其中，以在Redis中設(shè)置關(guān)鍵(key)值(即，過期時間)來進行計時，通過Redis中的輪詢機制來實現(xiàn)到期通知。然而，Redis中的輪詢機制會受到Redis中的key值的數(shù)量影響，實時性較差。因此，亟需一種能夠提高計時與過期邏輯的實時性的計時方法。

上述對背景技術(shù)的陳述僅是為了方便對本發(fā)明技術(shù)方案(使用的技術(shù)手段、解決的技術(shù)問題以及產(chǎn)生的技術(shù)效果等方面)的深入理解，而不應當被視為承認或以任何形式暗示該消息構(gòu)成已為本領(lǐng)域技術(shù)人員所公知的現(xiàn)有技術(shù)。

發(fā)明內(nèi)容

針對現(xiàn)有技術(shù)中存在的缺陷，本發(fā)明提出了基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法和裝置，以解決現(xiàn)有技術(shù)中計時與過期邏輯的實時性較差的問題。

根據(jù)本發(fā)明的實施方案，提供了一種基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法，所述統(tǒng)一計時服務(wù)方法包括：當接收到需要計時的業(yè)務(wù)服務(wù)請求時，創(chuàng)建需要計時的任務(wù)；創(chuàng)建延遲隊列，將需要計時的任務(wù)放入創(chuàng)建的延遲隊列中，通過所述延遲隊列來維護需要計時的任務(wù)的列表；創(chuàng)建守護線程來監(jiān)聽延遲隊列中到期的需要計時的任務(wù)，以獲取要處理的需要計時的任務(wù)；創(chuàng)建任務(wù)執(zhí)行線程池，以將要處理的需要計時的任務(wù)放入所述任務(wù)執(zhí)行線程池中；通知相應的業(yè)務(wù)邏輯處理的服務(wù)，以進行后續(xù)的業(yè)務(wù)邏輯處理。

優(yōu)選地，放入創(chuàng)建的延遲隊列中的需要計時的任務(wù)包括：需要計時的任務(wù)的唯一標識符、需要計時的任務(wù)的執(zhí)行時間戳和需要計時的任務(wù)與后續(xù)的業(yè)務(wù)邏輯處理相關(guān)的信息。

優(yōu)選地，在通過所述延遲隊列來維護需要計時的任務(wù)的列表時，需要計時的任務(wù)按需要計時的任務(wù)的執(zhí)行時間戳自動排序，最先執(zhí)行的任務(wù)優(yōu)先排序到延遲隊列的起始；每當新的需要計時的任務(wù)放入延遲隊列時，需要計時的任務(wù)的列表按照需要計時的任務(wù)的執(zhí)行時間戳進行重新自動排序。

優(yōu)選地，所述任務(wù)執(zhí)行線程池以多線程并發(fā)地處理要處理的需要計時的任務(wù)。

優(yōu)選地，在通知相應的業(yè)務(wù)邏輯處理的服務(wù)時，將需要計時的任務(wù)與后續(xù)的業(yè)務(wù)邏輯處理相關(guān)的信息傳遞給業(yè)務(wù)邏輯處理的服務(wù)。

優(yōu)選地，在將需要計時的任務(wù)放入創(chuàng)建的延遲隊列中時，將創(chuàng)建的需要計時的任務(wù)進行保存；當計時服務(wù)出現(xiàn)異常時，讀取保存的需要計時的任務(wù)，判斷保存的需要計時的任務(wù)在當前時間點是否到期；如果保存的需要計時的任務(wù)在當前時間點沒有到達執(zhí)行時間戳，則將保存的需要計時的任務(wù)放入延遲隊列中；如果保存的需要計時的任務(wù)在當前時間點已超過執(zhí)行時間戳，則將保存的需要計時的任務(wù)刪除。

根據(jù)本發(fā)明的實施方案，提供給了一種計算機可讀存儲介質(zhì)，其上存儲有計算機程序，當所述計算機程序被處理器執(zhí)行時實現(xiàn)根據(jù)本發(fā)明的實施方案的基于延遲隊列實現(xiàn)的統(tǒng)一計時服務(wù)方法。