[發(fā)明專利]一種消息處理方法、裝置、終端及計算機可讀存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 202010941519.5
• 申請日: 2020-09-09
• 公開（公告）號: CN112134938B
• 公開（公告）日: 2022-08-26
• 發(fā)明（設(shè)計）人: 陶銀;童粲
• 申請（專利權(quán)）人: 重慶易寵科技有限公司
• 主分類號: H04L67/51
• 分類號: H04L67/51;H04L67/56;H04L67/10
• 代理公司: 重慶渝之知識產(chǎn)權(quán)代理有限公司 50249
• 代理人: 柴社英

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

獲取原始消息并生成所述原始消息對應(yīng)的身份識別信息，所述身份識別信息用于確定所述原始消息所對應(yīng)的方法和所述原始消息對應(yīng)的方法數(shù)據(jù)類型；

根據(jù)所述身份識別信息確定所述原始消息對應(yīng)的方法和方法數(shù)據(jù)類型；

根據(jù)所述原始消息、所述方法數(shù)據(jù)類型生成過程消息，所述過程消息的數(shù)據(jù)類型與所述方法數(shù)據(jù)類型相同；

根據(jù)所述身份識別信息、所述過程消息和所述原始消息對應(yīng)的方法，生成初始消息。

2.根據(jù)權(quán)利要求1所述的消息處理方法，其特征在于，還包括以下至少之一：

根據(jù)所述身份識別信息創(chuàng)建所述初始消息對應(yīng)的主題代理和隊列代理，通過所述主題代理和隊列代理將所述初始消息發(fā)送給云服務(wù)；

根據(jù)所述原始消息生成對應(yīng)的Mock數(shù)據(jù)，發(fā)送所述Mock數(shù)據(jù)。

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

生成所述初始消息對應(yīng)的全局追蹤編號；

獲取所述初始消息對應(yīng)的來源服務(wù)名稱；

將所述全局追蹤編號、所述來源服務(wù)名稱和所述初始消息記錄到消息追蹤日志。

4.根據(jù)權(quán)利要求1-3任一項所述的消息處理方法，其特征在于，還包括：

將所述初始消息發(fā)送至阿里云消息服務(wù)；

通過消息接收消費者從所述阿里云消息服務(wù)獲取所述初始消息，所述初始消息包括身份識別信息；

根據(jù)所述身份識別信息確定所述初始消息對應(yīng)的方法和方法數(shù)據(jù)類型；

根據(jù)所述初始消息、所述方法數(shù)據(jù)類型生成中間消息，所述中間消息的數(shù)據(jù)類型與所述方法數(shù)據(jù)類型相同；

根據(jù)所述中間消息和所述初始消息對應(yīng)的方法，生成目標(biāo)消息。

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

若干個消息接收消費者分別獲取若干條初始消息；

若存在一個消息接收消費者獲取到的所述初始消息包括空消息，其余各所述消息接收消費者暫停獲取所述初始消息；

獲取到空消息的所述消息接收消費者為目標(biāo)消息接收消費者，暫停獲取所述初始消息的消息接收消費者為空閑消息接收消費者；

所述目標(biāo)消息接收消費者根據(jù)預(yù)設(shè)時間間隔繼續(xù)獲取所述初始消息；

若所述初始消息不為空消息，所述空閑消息接收消費者繼續(xù)獲取所述初始消息。

6.根據(jù)權(quán)利要求4所述的消息處理方法，其特征在于，所述目標(biāo)消息包括結(jié)果類型，所述結(jié)果類型包括以下任意之一：

刪除所述目標(biāo)消息；

重新執(zhí)行所述初始消息對應(yīng)的方法；

執(zhí)行成功。

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

若所述目標(biāo)消息的結(jié)果類型包括執(zhí)行成功，對所述目標(biāo)消息進(jìn)行加密；

根據(jù)所述身份識別信息將加密后的所述目標(biāo)消息分發(fā)至對應(yīng)的消息訂閱者。

8.一種消息處理裝置，其特征在于，包括：

原始消息獲取模塊，用于獲取原始消息并生成所述原始消息對應(yīng)的身份識別信息，所述身份識別信息用于確定所述原始消息所對應(yīng)的方法和所述原始消息對應(yīng)的方法數(shù)據(jù)類型；

第一確定模塊，用于根據(jù)所述身份識別信息確定所述原始消息對應(yīng)的方法和方法數(shù)據(jù)類型；

過程消息生成模塊，用于根據(jù)所述原始消息、所述方法數(shù)據(jù)類型生成過程消息，所述過程消息的數(shù)據(jù)類型與所述方法數(shù)據(jù)類型相同；

初始消息生成模塊，用于根據(jù)所述身份識別信息、所述過程消息和所述原始消息對應(yīng)的方法，生成初始消息。

9.一種終端，其特征在于，包括處理器、存儲器和通信總線；

所述通信總線用于將所述處理器和存儲器連接；

所述處理器用于執(zhí)行所述存儲器中存儲的計算機程序，以實現(xiàn)如權(quán)利要求1-7中一個或多個所述的消息處理方法。

10.一種計算機可讀存儲介質(zhì)，其特征在于，其上存儲有計算機程序，

所述計算機程序用于使所述計算機執(zhí)行如權(quán)利要求1-7中任一項所述的消息處理方法。