[發明專利]消息的處理方法、裝置及電子設備

在審

• 申請號: 201810295468.6
• 申請日: 2018-03-30
• 公開（公告）號: CN110321232A
• 公開（公告）日: 2019-10-11
• 發明（設計）人: 劉振東;王小瑞;馮嘉
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京市惠誠律師事務所 11353
• 代理人: 逯博

本發明實施例提供一種消息的處理方法、裝置及電子設備，其中，消息的處理方法包括：當有新消息產生并添加到所述消息隊列時，根據所述時間刻度表查找該新消息的處理時刻對應的所述第一地址指向的根消息，并與所述新消息之間形成指向關系，以將所述新消息添加到根消息所在的消息樹中；當所述時間刻度表指向當前時刻時，根據當前時刻對應的所述第一地址以及消息樹中各消息之間的指向關系讀取當前時刻需處理的所有消息。本發明實施例的方案能夠提高消息處理效率，且簡便易行。

技術領域

本申請涉及計算機技術領域，尤其涉及一種消息的處理方法、裝置及電子設備。

背景技術

目前，在很多業務場景中，消息常需要延后處理，即消息當前產生，但在隨后一定時間內(如10秒、1分鐘之后)才處理，由這種消息組成的隊列即定時隊列。在高并發場景中，由于消息很多，內存不足，因此需要在磁盤上存儲該定時隊列。

現有技術中，定時隊列的實現方案主要有兩種：一是基于數據庫的排序方案，即首先將消息逐條存入數據庫，每一條消息都帶有時間戳標記，定時查詢時間戳并按照時間戳對消息進行排序，然后根據需要按序讀取；二是特定延遲的隊列方案，即對存儲消息的定時隊列按照定時時間的不同建立子隊列，每一個子隊列存儲相同時刻的消息，并按生產順序依次向后排列，然后順序讀取每一個子隊列。

如上所述，現有技術中的方案均存在操作復雜、性能低下等弊端。

發明內容

本發明提供了一種消息的處理方法、裝置及電子設備，能夠提高消息處理效率，且簡便易行。

為達到上述目的，本發明的實施例采用如下技術方案：

第一方面，提供了一種消息的處理方法，所述方法涉及消息隊列以及時間刻度表，所述消息隊列中存儲有多條待處理的消息，且在同一時刻需處理的消息之間通過指向關系形成一個消息樹，所述消息樹中的根消息的第一地址與所述時間刻度表中的相應時刻關聯存儲，所述方法包括：

當有新消息產生并添加到所述消息隊列時，根據所述時間刻度表查找該新消息的處理時刻對應的所述第一地址指向的根消息，并與所述新消息之間形成指向關系，以將所述新消息添加到根消息所在的消息樹中。

第二方面，提供了另一種消息的處理方法，所述方法涉及消息隊列以及時間刻度表，所述消息隊列中存儲有多條待處理的消息，且在同一時刻需處理的消息之間通過指向關系形成一個消息樹，所述消息樹中的根消息的第一地址與所述時間刻度表中的相應時刻關聯存儲，所述方法包括：

當所述時間刻度表指向當前時刻時，根據當前時刻對應的所述第一地址以及消息樹中各消息之間的指向關系讀取當前時刻需處理的所有消息。

第三方面，提供了一種消息的處理裝置，所述處理裝置涉及消息隊列以及時間刻度表，所述消息隊列中存儲有多條待處理的消息，且在同一時刻需處理的消息之間通過指向關系形成一個消息樹，所述消息樹中的根消息的第一地址與所述時間刻度表中的相應時刻關聯存儲，所述處理裝置包括：

消息添加模塊，用于當有新消息產生并添加到所述消息隊列時，根據所述時間刻度表查找該新消息的處理時刻對應的所述第一地址指向的根消息，并與所述新消息之間形成指向關系，以將所述新消息添加到根消息所在的消息樹中。

第四方面，提供了另一種消息的處理裝置，所述處理裝置涉及消息隊列以及時間刻度表，所述消息隊列中存儲有多條待處理的消息，且在同一時刻需處理的消息之間通過指向關系形成一個消息樹，所述消息樹中的根消息的第一地址與所述時間刻度表中的相應時刻關聯存儲，所述處理裝置包括：

消息讀取模塊，用于當所述時間刻度表指向當前時刻時，根據當前時刻對應的所述第一地址以及消息樹中各消息之間的指向關系讀取當前時刻需處理的所有消息。

第五方面，提供了一種電子設備，包括：

存儲器，用于存儲程序；