[發(fā)明專利]消息處理方法、裝置、非易失性存儲介質(zhì)及處理器

在審

• 申請?zhí)枺?/td>: 202110486275.0
• 申請日: 2021-04-30
• 公開（公告）號: CN113177178A
• 公開（公告）日: 2021-07-27
• 發(fā)明（設(shè)計(jì)）人: 初旭;丁若谷
• 申請（專利權(quán)）人: 北京深演智能科技股份有限公司
• 主分類號: G06F16/958
• 分類號: G06F16/958;G06F9/54
• 代理公司: 北京康信知識產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 江舟

本發(fā)明公開了一種消息處理方法、裝置、非易失性存儲介質(zhì)及處理器。其中，該方法包括：確定第一數(shù)量，其中，第一數(shù)量為第一隊(duì)列中存儲的待發(fā)送消息的數(shù)量；確定第二數(shù)量，其中，第二數(shù)量為第二隊(duì)列中存儲的觸達(dá)反饋消息的數(shù)量，觸達(dá)反饋消息為第一隊(duì)列中的待發(fā)送消息觸達(dá)目標(biāo)對象后反饋的消息；根據(jù)第一數(shù)量以及第二數(shù)量，確定消息分發(fā)任務(wù)的執(zhí)行狀態(tài)。本發(fā)明解決了難以確定消息分發(fā)任務(wù)的執(zhí)行狀態(tài)的技術(shù)問題。

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

本發(fā)明涉及信息處理領(lǐng)域，具體而言，涉及一種消息處理方法、裝置、非易失性存儲介質(zhì)及處理器。

背景技術(shù)

在需要對海量的消息進(jìn)行分發(fā)的場景中，消息分發(fā)任務(wù)的執(zhí)行狀態(tài)并不容易判斷。例如，在自動化營銷領(lǐng)域中，會出現(xiàn)需要給百萬級的目標(biāo)人群推送消息的場景，在這一過程中，難以掌握消息分發(fā)任務(wù)的執(zhí)行狀態(tài)。為了結(jié)束消息分發(fā)任務(wù)，相關(guān)技術(shù)通常設(shè)置固定的任務(wù)結(jié)束時(shí)間，讓任務(wù)到了時(shí)間后自動結(jié)束。然而，上述方法無法保證任務(wù)已經(jīng)執(zhí)行完成，也無法確定任務(wù)的執(zhí)行狀態(tài)，容易出現(xiàn)消息分發(fā)任務(wù)的執(zhí)行異常。

針對上述的問題，目前尚未提出有效的解決方案。

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

本發(fā)明實(shí)施例提供了一種消息處理方法、裝置、非易失性存儲介質(zhì)及處理器，以至少解決難以確定消息分發(fā)任務(wù)的執(zhí)行狀態(tài)的技術(shù)問題。

根據(jù)本發(fā)明實(shí)施例的一個(gè)方面，提供了一種消息處理方法，包括：確定第一數(shù)量，其中，所述第一數(shù)量為第一隊(duì)列中存儲的待發(fā)送消息的數(shù)量；確定第二數(shù)量，其中，所述第二數(shù)量為第二隊(duì)列中存儲的觸達(dá)反饋消息的數(shù)量，所述觸達(dá)反饋消息為所述第一隊(duì)列中的待發(fā)送消息觸達(dá)目標(biāo)對象后反饋的消息；根據(jù)所述第一數(shù)量以及所述第二數(shù)量，確定消息分發(fā)任務(wù)的執(zhí)行狀態(tài)。

可選地，根據(jù)所述第一數(shù)量以及所述第二數(shù)量，確定消息分發(fā)任務(wù)的執(zhí)行狀態(tài)，包括：在所述第一數(shù)量與所述第二數(shù)量相等的情況下，確定所述消息分發(fā)任務(wù)的執(zhí)行狀態(tài)為已完成；或者，在所述第一數(shù)量與所述第二數(shù)量不相等的情況下，確定所述消息分發(fā)任務(wù)的執(zhí)行狀態(tài)為未完成。

可選地，在確定第二數(shù)量之前，還包括：將所述第一隊(duì)列中存儲的第一消息發(fā)送至第一對象，其中，所述第一消息為所述第一隊(duì)列中存儲的所述待發(fā)送消息中的任意之一，所述第一對象為所述目標(biāo)對象中與所述第一消息對應(yīng)的對象。

可選地，確定第一數(shù)量，包括：在預(yù)定時(shí)間內(nèi)，將所述待發(fā)送消息存入所述第一隊(duì)列；獲取所述預(yù)定時(shí)間內(nèi)，所述第一隊(duì)列中存儲的所述待發(fā)送消息的數(shù)量，得到所述第一數(shù)量。

可選地，在確定第一數(shù)量之前，還包括：獲取所述消息分發(fā)任務(wù)，其中，所述消息分發(fā)任務(wù)包括如下信息：目標(biāo)對象，目標(biāo)消息數(shù)量，消息文本；根據(jù)所述目標(biāo)對象、所述目標(biāo)消息數(shù)量以及所述消息文本，生成所述待發(fā)送消息。

可選地，上述方法還包括：將所述待發(fā)送消息存入所述第一隊(duì)列；比較所述目標(biāo)消息數(shù)量與所述第一數(shù)量的大小；在所述目標(biāo)消息數(shù)量與所述第一數(shù)量相等的情況下，將所述第一隊(duì)列中存儲的消息發(fā)送給所述目標(biāo)對象。

可選地，上述方法還包括：在所述目標(biāo)消息數(shù)量與所述第一數(shù)量不相等的情況下，清空所述第一隊(duì)列；根據(jù)所述目標(biāo)對象、所述目標(biāo)消息數(shù)量以及所述消息文本，重新生成所述待發(fā)送消息；將所述重新生成的待發(fā)送消息存入所述第一隊(duì)列；確定第三數(shù)量，其中，所述第三數(shù)量為所述第一隊(duì)列中存儲的所述重新生成的待發(fā)送消息的數(shù)量；比較所述目標(biāo)消息數(shù)量與所述第三數(shù)量的大小；在所述目標(biāo)消息數(shù)量與所述第三數(shù)量相等的情況下，將所述第一隊(duì)列中存儲的消息發(fā)送給所述目標(biāo)對象。

根據(jù)本發(fā)明實(shí)施例的另一方面，還提供了一種消息處理裝置，包括：第一確定模塊，用于確定第一數(shù)量，其中，所述第一數(shù)量為第一隊(duì)列中存儲的待發(fā)送消息的數(shù)量；第二確定模塊，用于確定第二數(shù)量，其中，所述第二數(shù)量為第二隊(duì)列中存儲的觸達(dá)反饋消息的數(shù)量，所述觸達(dá)反饋消息為所述第一隊(duì)列中的待發(fā)送消息觸達(dá)目標(biāo)對象后反饋的消息；第三確定模塊，用于根據(jù)所述第一數(shù)量以及所述第二數(shù)量，確定消息分發(fā)任務(wù)的執(zhí)行狀態(tài)。