[發明專利]目標消息的處理方法及裝置、存儲介質及電子裝置

在審

• 申請號: 202010968907.2
• 申請日: 2020-09-15
• 公開（公告）號: CN112148504A
• 公開（公告）日: 2020-12-29
• 發明（設計）人: 劉東東
• 申請（專利權）人: 海爾優家智能科技（北京）有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京康信知識產權代理有限責任公司 11240
• 代理人: 王曉婷

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

獲取目標應用生成的待延遲消息，將所述待延遲消息上傳到第一數據平臺；

通過延遲隊列對所述第一數據平臺中的所述待延遲消息進行延遲處理，將所述待延遲消息的延遲處理結果存儲至所述延遲隊列對應的緩存；

根據所述延遲處理結果將延遲處理后的消息上傳至第二數據平臺。

2.根據權利要求1所述的方法，其特征在于，通過延遲隊列對所述第一數據平臺中的所述待延遲消息進行延遲處理，包括：

通過所述延遲隊列從所述第一數據平臺獲取所述待延遲消息；

從所述延遲隊列中保存的所述待延遲消息中獲取所述待延遲消息的消息內容；

根據所述消息內容確定待延遲消息的到期時間戳；

根據所述到期時間戳對所述待延遲消息進行延遲處理。

3.根據權利要求2所述的方法，其特征在于，根據所述到期時間戳對所述待延遲消息進行延遲處理，包括：

比較所述到期時間戳與預設閾值，得到比較結果；

根據所述比較結果對所述待延遲消息進行延遲處理。

4.根據權利要求3所述的方法，其特征在于，根據所述比較結果對所述待延遲消息進行延遲處理，包括：

在所述到期時間戳的數值小于所述預設閾值的情況下，將所述到期時間戳對應的所述待延遲消息直接發送到所述第二數據平臺上；

當所述到期時間戳的數值大于或等于預設閾值的情況下，將所述待延遲消息緩存到所述延遲隊列的有序隊列中，其中，所述有序隊列用于對需要進行延遲處理的待延遲消息進行排列存儲。

5.根據權利要求1所述的方法，其特征在于，根據所述延遲處理結果將延遲處理后的消息數據上傳至第二數據平臺之前，所述方法還包括：

對所述延遲隊列對應的緩存進行周期檢測；

在所述周期檢測的結果指示存在已完成延遲處理的待延遲消息的情況下，從所述延遲隊列中獲取所對應的消息標識符，其中，所述消息標識符通過所述待延遲消息的內容確定，且所述消息標識符用于唯一標識所述待延遲消息；

將所述消息標識符對應的待延遲消息發送至所述第二數據平臺。

6.根據權利要求1所述的方法，其特征在于，根據所述延遲處理結果將延遲處理后的消息上傳至第二數據平臺，包括：

獲取所述延遲處理后的消息的屬性信息；

從多個第二數據平臺中確定與所述屬性信息對應的第二數據平臺，并將所述延遲處理后的消息上傳至與所述屬性信息對應的第二數據平臺。

7.一種目標消息的處理裝置，其特征在于，包括：

獲取模塊，用于獲取目標應用生成的待延遲消息，將所述待延遲消息上傳到第一數據平臺；

處理模塊，用于通過延遲隊列對所述第一數據平臺中的所述待延遲消息進行延遲處理，將所述待延遲消息的延遲處理結果存儲至所述延遲隊列對應的緩存；

上傳模塊，用于根據所述延遲處理結果將延遲處理后的消息數據上傳至第二數據平臺。

8.根據權利要求7所述的裝置，其特征在于，所述處理模塊，還用于通過所述延遲隊列從所述第一數據平臺獲取所述待延遲消息；從所述延遲隊列中保存的所述待延遲消息中獲取所述待延遲消息的消息內容；根據所述消息內容確定待延遲消息的到期時間戳；根據所述到期時間戳對所述待延遲消息進行延遲處理。

9.一種計算機可讀的存儲介質，其特征在于，所述計算機可讀的存儲介質包括存儲的程序，其中，所述程序運行時執行上述權利要求1至6任一項中所述的方法。

10.一種電子裝置，包括存儲器和處理器，其特征在于，所述存儲器中存儲有計算機程序，所述處理器被設置為通過所述計算機程序執行所述權利要求1至6任一項中所述的方法。