[發明專利]分布式服務調用的網絡耗時展示方法及裝置

有效

• 申請號: 202110376808.X
• 申請日: 2021-04-08
• 公開（公告）號: CN113114533B
• 公開（公告）日: 2023-04-07
• 發明（設計）人: 孫才嬋;曹輝健;劉慕雨;劉雯
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: H04L43/045
• 分類號: H04L43/045;H04L43/08;H04L67/133;H04L67/10;G06F16/28;G06F16/248
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 任默聞;王濤

1.一種分布式服務調用的網絡耗時展示方法，其特征在于，包括：

采集分布式服務調用的鏈路數據；所述鏈路數據包括：鏈路ID、當前調用ID、上一次調用ID、名稱、當前節點、調用發起時刻；

根據采集的鏈路數據，通過拓撲計算，確定所述分布式服務調用的拓撲關系數據，其中，所述拓撲關系數據中包含：多條調用鏈路；

根據所述分布式服務調用的鏈路數據和拓撲關系數據，計算各條調用鏈路的網絡耗時；

根據所述分布式服務調用的拓撲關系數據和各條調用鏈路的網絡耗時，展示所述分布式服務調用的網絡耗時情況；

根據所述分布式服務調用的鏈路數據和拓撲關系數據，計算各條調用鏈路的網絡耗時，包括：

根據所述分布式服務調用的鏈路數據和拓撲關系數據，確定單個服務調用的服務調用方節點和服務提供方節點；

獲取服務調用方節點的請求發送時刻和服務提供方節點的請求接收時刻，并根據服務調用方節點的請求發送時刻和服務提供方節點的請求接收時刻，計算單程服務調用的網絡耗時；

獲取服務提供方節點服務發送時刻和服務調用方節點的服務接收時刻，并根據服務提供方節點服務發送時刻和服務調用方節點的服務接收時刻，計算單程服務返回的網絡耗時；

所述方法還包括：

獲取服務調用方節點和服務提供方節點的設備時差；

根據服務調用方節點和服務提供方節點的設備時差，對單程服務調用的網絡耗時或單程服務返回的網絡耗時進行修正；

在采集分布式服務調用的鏈路數據之后，所述方法還包括：

將采集的鏈路數據發送到Kafka消息隊列中；

根據所述分布式服務調用的鏈路數據和拓撲關系數據，計算各條調用鏈路的網絡耗時，包括：

從Kafka消息隊列中讀取鏈路數據，確定所述分布式服務調用的拓撲關系數據；

根據所述分布式服務調用的拓撲關系數據，從Kafka消息隊列中讀取鏈路數據，計算各條調用鏈路的網絡耗時；

將各條調用鏈路的網絡耗時數據，存儲于Redis數據庫中。

2.如權利要求1所述的方法，其特征在于，在根據所述分布式服務調用的拓撲關系數據和各條調用鏈路的網絡耗時，展示所述分布式服務調用的網絡耗時情況之前，所述方法還包括：

將所述分布式服務調用的拓撲關系數據存儲于圖數據庫中；

將各條調用鏈路的網絡耗時數據存儲于時序數據庫中；

其中，根據所述分布式服務調用的拓撲關系數據和各條調用鏈路的網絡耗時，展示所述分布式服務調用的網絡耗時情況，包括：基于所述圖數據庫存儲的拓撲關系數據和所述時序數據庫存儲的網絡耗時數據，展示所述分布式服務調用的網絡耗時情況。

3.如權利要求2所述的方法，其特征在于，將所述分布式服務調用的拓撲關系數據存儲于圖數據庫中，包括：

將待存儲的拓撲關系數據發送到Kafka消息隊列中；

從Kafka消息隊列中讀取拓撲關系數據，存儲于所述圖數據庫中。

4.如權利要求2所述的方法，其特征在于，將各條調用鏈路的網絡耗時數據存儲于時序數據庫中，包括：

將各條調用鏈路的網絡耗時數據發送到Kafka消息隊列中；

從Kafka消息隊列中讀取網絡耗時數據，存儲于所述時序數據庫中。