[發(fā)明專利]消息處理方法、裝置、電子設(shè)備和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202210400029.3
• 申請日: 2022-04-15
• 公開（公告）號: CN114896082A
• 公開（公告）日: 2022-08-12
• 發(fā)明（設(shè)計）人: 趙劍
• 申請（專利權(quán)）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/25
• 代理公司: 北京華夏泰和知識產(chǎn)權(quán)代理有限公司 11662
• 代理人: 唐會娜

本申請涉及一種消息處理方法、裝置、電子設(shè)備和存儲介質(zhì)，應用于計算機技術(shù)領(lǐng)域，其中，方法包括：在監(jiān)測到數(shù)據(jù)平臺寫入待處理消息數(shù)據(jù)后，獲取所述待處理消息數(shù)據(jù)中的消息身份標識號和消息時間字段；確定所述使用端中與所述消息身份標識號對應的處理時間字段；判斷消息時間字段中是否存在消息時間戳，以及所述處理時間字段中是否存在處理時間戳；若存在所述消息時間戳且存在所述處理時間戳，根據(jù)所述消息時間戳與所述處理時間戳的大小關(guān)系，對所述待處理消息數(shù)據(jù)進行丟棄或消費處理。以解決現(xiàn)有技術(shù)中，消息處理速度過慢引發(fā)消息的大量積壓，造成業(yè)務(wù)處理效率降低，嚴重影響業(yè)務(wù)的正常服務(wù)的問題。

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

本申請涉及計算機技術(shù)領(lǐng)域，尤其涉及一種消息處理方法、裝置、電子設(shè)備和存儲介質(zhì)。

背景技術(shù)

對于一些實時數(shù)據(jù)分發(fā)、數(shù)據(jù)共享的業(yè)務(wù)場景中，通常由寫入方、數(shù)據(jù)平臺和使用方3個角色共同完成。數(shù)據(jù)平臺提供數(shù)據(jù)的存儲，提供數(shù)據(jù)讀取接口、寫入接口、寫入消息(通過消息中間件實現(xiàn))通知。寫入方將自身業(yè)務(wù)數(shù)據(jù)整合調(diào)用數(shù)據(jù)平臺寫入接口，入庫到平臺。使用方通過監(jiān)聽寫入消息，觸發(fā)調(diào)用平臺讀取接口獲取最新數(shù)據(jù)。

在一些異常情況下，比如使用方服務(wù)問題或者因為數(shù)據(jù)平臺服務(wù)問題導致處理速度過慢，引發(fā)消息的大量積壓，造成業(yè)務(wù)處理效率降低，嚴重影響業(yè)務(wù)的正常服務(wù)。

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

本申請?zhí)峁┝艘环N消息處理方法、裝置、電子設(shè)備和存儲介質(zhì)，用以解決現(xiàn)有技術(shù)中，消息處理速度過慢引發(fā)消息的大量積壓，造成業(yè)務(wù)處理效率降低，嚴重影響業(yè)務(wù)的正常服務(wù)的問題。

第一方面，本申請實施例提供了一種消息處理方法，應用于待處理消息數(shù)據(jù)的使用端，包括：

在監(jiān)測到數(shù)據(jù)平臺寫入所述待處理消息數(shù)據(jù)后，獲取所述待處理消息數(shù)據(jù)中的消息身份標識號和消息時間字段；

確定所述使用端中與所述消息身份標識號對應的處理時間字段；

判斷消息時間字段中是否存在消息時間戳，以及所述處理時間字段中是否存在處理時間戳；

若存在所述消息時間戳且存在所述處理時間戳，根據(jù)所述消息時間戳與所述處理時間戳的大小關(guān)系，對所述待處理消息數(shù)據(jù)進行丟棄或消費處理。

可選的，所述判斷消息時間字段中是否存在消息時間戳，以及所述處理時間字段中是否存在處理時間戳之后，還包括：

若不存在所述消息時間戳和/或不存在所述處理時間戳，從所述數(shù)據(jù)平臺獲取與所述消息身份標識號對應的待處理消息內(nèi)容，并對所述待處理消息內(nèi)容進行消費處理。

可選的，所述根據(jù)所述消息時間戳與所述處理時間戳的大小關(guān)系，對所述待處理消息數(shù)據(jù)進行丟棄或消費處理，包括：

若所述消息時間戳小于所述處理時間戳，將所述待處理消息數(shù)據(jù)丟棄；

若所述消息時間戳大于或等于所述處理時間戳，從所述數(shù)據(jù)平臺獲取與所述消息身份標識號對應的待處理消息內(nèi)容，并對所述待處理消息內(nèi)容進行消費處理。

可選的，所述對所述待處理消息內(nèi)容進行消費處理之后，還包括：

在所述待處理消息內(nèi)容消費處理完成后，獲取更新時間戳，所述更新時間戳是在所述數(shù)據(jù)平臺確定所述待處理消息內(nèi)容消費處理完成后生成的；

將所述更新時間戳更新所述處理時間字段。

可選的，所述對所述待處理消息內(nèi)容進行消費處理之后，還包括：

將所述消息身份標識號與所述處理時間字段對應存儲。

可選的，所述將所述消息身份標識號與所述處理時間字段對應存儲之后，還包括：

判斷存儲的消息身份標識號的存儲參數(shù)是否滿足預設(shè)存儲條件；