[發明專利]一種消息軌跡數據的處理方法、裝置及電子設備

在審

• 申請號: 201911045244.0
• 申請日: 2019-10-30
• 公開（公告）號: CN112751893A
• 公開（公告）日: 2021-05-04
• 發明（設計）人: 胡宗棠
• 申請（專利權）人: 中移(蘇州)軟件技術有限公司;中國移動通信集團有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 劉戀;張穎玲

1.一種消息軌跡數據的處理方法，其特征在于，所述方法包括：

通過客戶端中的攔截器獲取消息軌跡數據；

確定所述消息軌跡數據對應的消息代理服務節點；

將所述消息軌跡數據發送給所述消息代理服務節點，以通過所述消息代理服務節點將所述消息軌跡數據保存至目標存儲區域。

2.根據權利要求1所述的方法，其特征在于，所述將所述消息軌跡數據發送給所述消息代理服務節點，包括：

將所述消息軌跡數據投遞至阻塞隊列；

從所述阻塞隊列中獲取所述消息軌跡數據，并基于所述消息軌跡數據生成異步請求任務，將所述異步請求任務提交至線程池；

通過所述線程池采用異步線程方式對所述異步請求任務進行處理，以將所述消息軌跡數據發送給所述消息代理服務節點。

3.根據權利要求2所述的方法，其特征在于，所述將所述消息軌跡數據發送給所述消息代理服務節點，包括：

將所述消息軌跡數據封裝成目標消息格式，將具有所述目標消息格式的所述消息軌跡數據發送至所述消息代理服務節點。

4.根據權利要求1所述的方法，其特征在于，所述通過客戶端中的攔截器獲取消息軌跡數據，包括：

通過生產者側的客戶端中的攔截器獲取消息軌跡數據；和/或，

通過消費者側的客戶端中的攔截器獲取消息軌跡數據。

5.根據權利要求1至4中任一項所述的方法，其特征在于，所述確定所述消息軌跡數據對應的消息代理服務節點，包括：

通過負載均衡算法從多個消息代理服務節點中確定出所述消息軌跡數據對應的第一消息代理服務節點，其中，所述多個消息代理服務節點均支持對所述消息軌跡數據以及普通消息的存儲。

6.根據權利要求5所述的方法，其特征在于，所述多個消息代理服務節點中的每個消息代理服務節點均創建有所述目標存儲區域，所述目標存儲區域的主題屬性為軌跡主題。

7.根據權利要求1至4中任一項所述的方法，其特征在于，所述確定所述消息軌跡數據對應的消息代理服務節點，包括：

確定所述消息軌跡數據對應的消息代理服務節點為第二消息代理服務節點，其中，所述第二消息代理服務節點僅支持對所述消息軌跡數據的存儲。

8.根據權利要求7所述的方法，其特征在于，所述第二消息代理服務節點創建有所述目標存儲區域，所述目標存儲區域的主題屬性為軌跡主題。

9.一種消息軌跡數據的處理裝置，其特征在于，所述裝置包括：

獲取單元，用于通過客戶端中的攔截器獲取消息軌跡數據；

確定單元，用于確定所述消息軌跡數據對應的消息代理服務節點；

發送單元，用于將所述消息軌跡數據發送給所述消息代理服務節點，以通過所述消息代理服務節點將所述消息軌跡數據保存至目標存儲區域。

10.根據權利要求9所述的裝置，其特征在于，所述發送單元，包括：

投遞子單元，用于將所述消息軌跡數據投遞至阻塞隊列；

獲取子單元，用于從所述阻塞隊列中獲取所述消息軌跡數據，并基于所述消息軌跡數據生成異步請求任務，將所述異步請求任務提交至線程池；

發送子單元，用于通過所述線程池采用異步線程方式對所述異步請求任務進行處理，以將所述消息軌跡數據發送給所述消息代理服務節點。

11.一種電子設備，其特征在于，包括：處理器和存儲器，該存儲器用于存儲計算機程序，所述處理器用于調用并運行所述存儲器中存儲的計算機程序，執行如權利要求1至8中任一項所述的方法。

12.一種計算機可讀存儲介質，其特征在于，用于存儲計算機程序，所述計算機程序使得計算機執行如權利要求1至8中任一項所述的方法。