[發(fā)明專利]消息處理方法及裝置

有效

• 申請?zhí)枺?/td>: 201710503210.6
• 申請日: 2017-06-27
• 公開（公告）號: CN107222555B
• 公開（公告）日: 2020-08-25
• 發(fā)明（設(shè)計）人: 展向前
• 申請（專利權(quán)）人: 聚好看科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京同立鈞成知識產(chǎn)權(quán)代理有限公司 11205
• 代理人: 張洋;黃健

1.一種消息處理方法，其特征在于，應(yīng)用于消息處理器，所述方法包括：

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

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

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

其中，所述第一索引信息集合中每一個索引信息對應(yīng)的消息集合中的待處理消息的處理時刻在所述當(dāng)前時刻對應(yīng)的第一時段之內(nèi)，所述第一時段的時長與所述消息處理器的處理周期的時長相同；一個消息集合中的待處理消息的處理時刻在所述第一時段的一個子時段內(nèi)；當(dāng)完成處理所述消息集合中的所述待處理消息后，刪除所述消息集合，當(dāng)刪除所述第一索引信息集合對應(yīng)的所述消息集合后，對應(yīng)刪除所述第一索引信息集合；

確定當(dāng)前時刻對應(yīng)的第一索引信息集合，包括：

獲取所述消息處理器對應(yīng)的第一消息類型標(biāo)識；

根據(jù)所述消息處理器的處理周期，生成所述當(dāng)前時刻對應(yīng)的第一時間戳；

根據(jù)所述第一消息類型標(biāo)識、預(yù)設(shè)索引信息集合指示符和所述第一時間戳，確定所述第一索引信息集合的標(biāo)識；

根據(jù)所述第一索引信息集合的標(biāo)識，確定所述第一索引信息集合。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述消息處理器對應(yīng)有并行消息處理器，相應(yīng)的，根據(jù)所述第一索引信息集合中包括的索引信息，確定第一消息集合，包括：

根據(jù)所述并行消息處理器的個數(shù)，在所述至少一個索引信息中確定所述消息處理器對應(yīng)的第一索引信息；

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

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

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

根據(jù)所述第一處理時刻，確定所述待存儲消息對應(yīng)的第二索引信息；

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

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，將所述待存儲消息存儲至所述第二索引信息對應(yīng)的第二消息集合，包括：

根據(jù)所述第二索引信息，判斷存儲介質(zhì)中是否存在所述第二消息集合；

若是，則將所述待存儲消息存儲至所述第二消息集合；

若否，則根據(jù)所述第二索引信息在所述存儲介質(zhì)中創(chuàng)建所述第二消息集合，并將所述待存儲消息存儲至所述第二消息集合中。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，根據(jù)所述第二索引信息創(chuàng)建所述第二消息集合之后，還包括：

確定所述第二索引信息對應(yīng)的第二索引信息集合；

將所述第二索引信息存儲至所述第二索引信息集合。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，根據(jù)所述第一處理時刻，確定所述待存儲消息對應(yīng)的第二索引信息，包括：

獲取所述待存儲消息的消息類型；

在所述待存儲消息的消息類型對應(yīng)的至少一個消息類型標(biāo)識中，確定第二消息類型標(biāo)識；

根據(jù)所述待存儲消息的消息類型對應(yīng)的時間粒度，生成所述第一處理時刻對應(yīng)的第二時間戳；

根據(jù)所述第二消息類型標(biāo)識和所述第二時間戳，確定所述第二索引信息。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，確定所述第二索引信息對應(yīng)的第二索引信息集合，包括：

根據(jù)所述待存儲消息的消息類型對應(yīng)的時間精度，生成所述第一處理時刻對應(yīng)的第三時間戳；所述時間精度為所述時間粒度的N倍，所述N為大于1的整數(shù)，所述時間精度對應(yīng)的時長與所述消息處理器的處理周期的時長相同；

根據(jù)所述第二消息類型標(biāo)識、預(yù)設(shè)索引信息集合指示符和所述第三時間戳，確定所述第二索引信息集合的標(biāo)識；

根據(jù)所述第二索引信息集合的標(biāo)識，判斷所述存儲介質(zhì)中是否存在所述第二索引信息集合；

若是，則根據(jù)所述第二索引信息集合的標(biāo)識，在所述存儲介質(zhì)中確定所述第二索引信息集合；

若否，則在所述存儲介質(zhì)中創(chuàng)建第二索引信息集合。