[發明專利]消息處理方法及裝置

有效

• 申請號: 201710503210.6
• 申請日: 2017-06-27
• 公開（公告）號: CN107222555B
• 公開（公告）日: 2020-08-25
• 發明（設計）人: 展向前
• 申請（專利權）人: 聚好看科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 張洋;黃健

本發明實施例提供一種消息處理方法及裝置，該方法包括：確定當前時刻對應的第一索引信息集合，第一索引信息集合中包括至少一個索引信息，每個索引信息對應一個消息集合，每個消息集合中包括至少一個待處理消息；根據第一索引信息集合中包括的索引信息，確定第一消息集合；在第一消息集合中獲取待處理消息，并處理第一消息集合中的待處理消息；其中，第一索引信息集合中每一個索引信息對應的消息集合中的待處理消息的處理時刻在當前時刻對應的第一時段之內，第一時段的時長與消息處理器的處理周期的時長相同；一個消息集合中的待處理消息的處理時刻在第一時段的一個子時段內。用于提高業務服務器的工作效率。

技術領域

本發明實施例涉及計算機技術領域，尤其涉及一種消息處理方法及裝置。

背景技術

在互聯網領域，客戶端可以定制業務、及業務的處理時刻，以使業務服務器在業務的處理時刻到達時，自動處理用戶定制的業務。

目前，在客戶端定制業務之后，客戶端向業務服務器發送業務消息，業務消息中包括了該業務的處理時刻，業務服務器將未處理的業務消息存儲在消息隊列中，并周期性的輪詢每一個業務消息，并判斷業務消息中的處理時刻是否到達，若是，則對該業務消息對應的業務進行處理，并將該業務消息移出消息隊列，若否，則業務服務器在下一個周期繼續輪詢該消息隊列。

然而，在上述過程中，在業務服務器的每一個工作周期內，均需要輪詢消息隊列中的每一個消息，導致業務服務器的工作效率較低。

發明內容

本發明實施例提供一種消息處理方法及裝置，提高了業務服務器的工作效率。

第一方面，本發明實施例提供一種消息處理方法，應用于消息處理器，所述方法包括：

確定當前時刻對應的第一索引信息集合，所述第一索引信息集合中包括至少一個索引信息，每個索引信息對應一個消息集合，每個消息集合中包括至少一個待處理消息；

根據所述第一索引信息集合中包括的索引信息，確定第一消息集合；

在所述第一消息集合中獲取待處理消息，并處理所述待處理消息；

其中，所述第一索引信息集合中每一個索引信息對應的消息集合中的待處理消息的處理時刻在所述當前時刻對應的第一時段之內，所述第一時段的時長與所述消息處理器的處理周期的時長相同；一個消息集合中的待處理消息的處理時刻在所述第一時段的一個子時段內。

在一種可能的實施方式中，確定當前時刻對應的第一索引信息集合，包括：

獲取所述消息處理器對應的第一消息類型標識；

根據所述消息處理器的處理周期，生成所述當前時刻對應的第一時間戳；

根據所述第一消息類型標識、預設索引信息集合指示符和所述第一時間戳，確定所述第一索引信息集合的標識；

根據所述第一索引信息集合的標識，確定所述第一索引信息集合。

在另一種可能的實施方式中，所述消息處理器對應有并行消息處理器，相應的，根據所述索引信息集合中包括的索引信息，確定第一消息集合，包括：

根據所述并行消息處理器的個數，在所述至少一個索引信息中確定所述消息處理器對應的第一索引信息；

根據所述第一索引信息，確定所述第一消息集合。

在另一種可能的實施方式中，所述方法還包括：

獲取待存儲消息、及所述待存儲消息的第一處理時刻；

根據所述第一處理時刻，確定所述待存儲消息對應的第二索引信息；

將所述待存儲消息存儲至所述第二索引信息對應的第二消息集合。