[發明專利]一種消息處理的方法、裝置、電子設備和存儲介質

在審

• 申請號: 202011482873.2
• 申請日: 2020-12-15
• 公開（公告）號: CN112596920A
• 公開（公告）日: 2021-04-02
• 發明（設計）人: 徐志軒;朱可;張元;陳治宇;何城;方赤;尹傳威;吳宇光;張榮宸;吳思;李洋瑩;秦雯婧
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張春曉;張效榮

本發明公開了消息處理的方法、裝置、電子設備和存儲介質，涉及計算機技術領域。該方法的一具體實施方式包括：接收待處理消息，并確定待處理信息的消息處理時間，待處理消息包括消息標識；將待處理信息添加至第一隊列，并存儲待處理消息的消息處理時間；根據消息處理時間判斷待處理消息是否超時未處理；若是，則將待處理消息轉存至第二隊列，并按照預設處理方式處理待處理消息。該實施方式能夠解決消息數據量巨大、且消息處理的實時性要求很高時，不能保證消息處理的實時性，還會使系統性能降低的問題。

技術領域

本發明涉及計算機技術領域，尤其涉及一種消息處理的方法、裝置、電子設備和存儲介質。

背景技術

隨著移動互聯網以及物聯網技術的快速發展，消息傳輸迅速，對于告警系統，各告警信息可以從消息生產者一端以消息的形式匯總至信息處理中心，以便于信息處理中心對這些消息進行處理，對告警狀態進行監控。現有技術中，在信息處理中心中消息生產者生產可以將接收的各消息均會存入對應的共享哈希槽中，然后消息消費者可以按照一定時間間隔輪訓共享哈希槽，取出共享哈希槽中的消息進行處理。

在實現本發明過程中，發明人發現現有技術中至少存在如下問題：

消息生產者會將消息放入共享哈希槽，消息消費者會從共享哈希槽中讀取消息，如此消息生產者和消息消費者均會對共享哈希槽進行操作，當存在海量消息需要處理時，由于消息數據量巨大、且消息處理的實時性要求很高，消息生產者和消息消費者均需要頻繁操作共享哈希槽，如此不僅不能保證消息處理的實時性，還會使系統性能降低。

發明內容

有鑒于此，本發明實施例提供一種消息處理的方法、裝置、電子設備和存儲介質，能夠解決消息數據量巨大、且消息處理的實時性要求很高時，消息生產者和消息消費者均需要頻繁操作共享哈希槽，不能保證消息處理的實時性，還會使系統性能降低的問題。

為實現上述目的，根據本發明實施例的一個方面，提供了一種消息處理的方法。

本發明實施例的一種消息處理的方法包括：接收待處理消息，并確定所述待處理信息的消息處理時間，所述待處理消息包括消息標識；

將所述待處理信息添加至第一隊列，并存儲所述待處理消息的消息處理時間；

根據所述消息處理時間判斷所述待處理消息是否超時未處理；

若是，則將所述待處理消息轉存至第二隊列，并按照預設處理方式處理所述待處理消息。

在一個實施例中，所述根據所述消息處理時間判斷所述待處理消息是否超時未處理，包括：

判斷當前時間是否為所述待處理消息的消息處理時間；

若是，則確定所述待處理消息為超時未處理；

若否，則繼續判斷當前時間是否為所述待處理消息的消息處理時間。

在又一個實施例中，所述根據所述消息處理時間判斷所述待處理消息是否超時未處理，包括：

記錄所述待處理消息在所述第一隊列的存儲時長；

判斷所述待處理消息在所述第一隊列的存儲時長是否達到所述消息處理時間；

若是，則確定所述待處理消息為超時未處理；

若否，則繼續判斷所述待處理消息在所述第一隊列的存儲時間是否達到所述消息處理時間。

在又一個實施例中，所述將所述待處理消息轉存至第二隊列之后，還包括：

將所述待處理消息存儲至數據庫，并為所述待處理消息添加超時標識。

在又一個實施例中，所述將所述待處理消息存儲至數據庫，包括：

將所述待處理消息存儲至所述數據量中的持久化隊列。