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

在審

• 申請?zhí)枺?/td>: 202110667472.2
• 申請日: 2021-06-16
• 公開（公告）號: CN113296985A
• 公開（公告）日: 2021-08-24
• 發(fā)明（設(shè)計(jì)）人: 王博
• 申請（專利權(quán)）人: 北京有竹居網(wǎng)絡(luò)技術(shù)有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F40/30
• 代理公司: 北京中知法苑知識產(chǎn)權(quán)代理有限公司 11226
• 代理人: 李明

1.一種消息處理方法，其特征在于，包括：

接收服務(wù)器發(fā)送的至少一條待處理數(shù)據(jù)；所述待處理數(shù)據(jù)中包括待處理消息、所述待處理消息對應(yīng)的消息標(biāo)識、以及基準(zhǔn)消息標(biāo)識；所述基準(zhǔn)消息標(biāo)識為所述服務(wù)器發(fā)送的時序上位于所述待處理消息之前的消息的標(biāo)識；

基于接收到的待處理數(shù)據(jù)中的消息標(biāo)識，以及消息隊(duì)列中各個消息標(biāo)識，確定接收到的待處理數(shù)據(jù)在所述消息隊(duì)列中的插入位置，并按照所述插入位置將接收到的待處理數(shù)據(jù)插入至所述消息隊(duì)列中；

基于所述消息隊(duì)列中的待處理數(shù)據(jù)中的消息標(biāo)識及基準(zhǔn)消息標(biāo)識，對所述消息隊(duì)列中的待處理數(shù)據(jù)進(jìn)行連續(xù)性檢測，并按照隊(duì)列順序依次展示通過連續(xù)性檢測的待處理數(shù)據(jù)中的待處理消息。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于接收到的待處理數(shù)據(jù)中的消息標(biāo)識，以及消息隊(duì)列中各個待處理數(shù)據(jù)的消息標(biāo)識，確定接收到的待處理數(shù)據(jù)在所述消息隊(duì)列中的插入位置，包括：

基于所述消息隊(duì)列中已存在的待處理數(shù)據(jù)，對接收的待處理數(shù)據(jù)進(jìn)行去重處理，得到去重后的待處理數(shù)據(jù)；

基于去重后的待處理數(shù)據(jù)的消息標(biāo)識及所述消息隊(duì)列中已存在的待處理數(shù)據(jù)的消息標(biāo)識，對去重后的待處理數(shù)據(jù)及所述消息隊(duì)列中已存在的待處理數(shù)據(jù)進(jìn)行排序，并基于排序結(jié)果確定去重后的待處理數(shù)據(jù)在所述消息隊(duì)列中的插入位置。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述基于所述消息隊(duì)列中的待處理數(shù)據(jù)中的消息標(biāo)識及基準(zhǔn)消息標(biāo)識，對所述消息隊(duì)列中的待處理數(shù)據(jù)進(jìn)行連續(xù)性檢測，包括：

針對所述消息隊(duì)列中位于隊(duì)首的待處理數(shù)據(jù)，若該待處理數(shù)據(jù)的基準(zhǔn)消息標(biāo)識與前一展示的待處理消息對應(yīng)的消息標(biāo)識匹配，或前一展示的待處理消息不存在，則確定該待處理數(shù)據(jù)通過連續(xù)性檢測；

分別針對所述消息隊(duì)列中除位于隊(duì)首的待處理數(shù)據(jù)外的其他任一待處理數(shù)據(jù)，若所述其他任一待處理數(shù)據(jù)的基準(zhǔn)消息標(biāo)識與所述消息隊(duì)列中在所述其他任一待處理數(shù)據(jù)之前的待處理數(shù)據(jù)的基準(zhǔn)消息標(biāo)識匹配，且所述其他任一待處理數(shù)據(jù)之前的各個待處理數(shù)據(jù)都通過連續(xù)性檢測，則確定所述其他任一待處理數(shù)據(jù)通過連續(xù)性檢測。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，在進(jìn)行連續(xù)性檢測之后，所述方法還包括：

在所述消息隊(duì)列中存在未通過連續(xù)性檢測的待處理數(shù)據(jù)的情況下，將所述消息隊(duì)列中最末尾的通過連續(xù)性檢測的待處理數(shù)據(jù)作為目標(biāo)數(shù)據(jù)；

向所述服務(wù)器請求時序上位于所述目標(biāo)數(shù)據(jù)之后的待處理數(shù)據(jù)。

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

以預(yù)設(shè)時長為周期，對所述消息隊(duì)列中的待處理數(shù)據(jù)進(jìn)行連續(xù)性檢測，并按照隊(duì)列順序依次展示通過連續(xù)性檢測的待處理數(shù)據(jù)中的待處理消息。

6.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述向所述服務(wù)器請求時序上位于所述目標(biāo)數(shù)據(jù)之后的待處理數(shù)據(jù)，包括：

基于所述服務(wù)器對應(yīng)的多條訪問通道對應(yīng)的狀態(tài)信息及類型信息，從所述多條訪問通道中篩選出目標(biāo)通道；其中，所述狀態(tài)信息包括可用狀態(tài)及不可用狀態(tài)，所述類型信息包括長連接通道及短連接通道；

通過所述目標(biāo)通道向所述服務(wù)器請求時序上位于所述目標(biāo)數(shù)據(jù)之后的待處理數(shù)據(jù)。

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

在請求時序上位于所述目標(biāo)數(shù)據(jù)之后的待處理數(shù)據(jù)失敗的情況下，更新所述目標(biāo)通道的狀態(tài)信息，并跳轉(zhuǎn)至篩選目標(biāo)通道的步驟。