[發明專利]基于Kafka的服務進程可視化監控與管理的方法及裝置

在審

• 申請號: 202011125256.7
• 申請日: 2020-10-20
• 公開（公告）號: CN112269767A
• 公開（公告）日: 2021-01-26
• 發明（設計）人: 和思揚;陶鈺昕
• 申請（專利權）人: 蘇州浪潮智能科技有限公司
• 主分類號: G06F16/17
• 分類號: G06F16/17;G06F16/18;G06F16/22;G06F9/451
• 代理公司: 北京眾達德權知識產權代理有限公司 11570
• 代理人: 梁凱

1.一種基于Kafka的服務進程可視化監控與管理的方法，其特征在于，包括：

接收用戶提供的端口信息，并將所述端口信息存入mysql數據庫；

根據所述端口信息，基于預設的刷新時間間隔，向業務平臺的各個節點進行查詢掃描，獲取所述端口信息對應的端口的狀態信息；

將所述狀態信息寫入Kafka主題進行存儲；

在每次查詢掃描時，都會產生一個秒級的時間信息，將所述秒級的時間信息與所述狀態信息對應存儲；

從所述Kafka主題中獲取存儲的所述狀態信息和所述秒級的時間信息；

基于所述端口狀態信息和所述秒級的時間信息對服務進程進行監控及管理；

基于所述端口狀態信息和所述秒級的時間信息，制成可視化圖像并顯示。

2.如權利要求1所述的基于Kafka的服務進程可視化監控與管理的方法，其特征在于，所述端口信息包括：監控的目標服務端口、端口所在的主機節點、服務的啟動命令以及信息刷新的時間間隔其中一種或多種結合。

3.如權利要求1所述的基于Kafka的服務進程可視化監控與管理的方法，其特征在于，所述狀態信息包括：端口的對應進程號、進程狀態與父進程的信息列表。

4.如權利要求1所述的基于Kafka的服務進程可視化監控與管理的方法，其特征在于，

所述基于所述端口狀態信息和所述秒級的時間信息對服務進程進行監控及管理；包括：

當端口的進程信息為空時，發出監控告警，同時嘗試執行所述端口的啟動命令；

當所述進程狀態為空時，則殺死所述進程及對應的父進程，執行端口的啟動命令。

5.如權利要求1所述的基于Kafka的服務進程可視化監控與管理的方法，其特征在于，還包括：

在顯示端口的進程信息時，還接收用戶對于所述進程的操作指令；

執行所述操作指令；

其中，所述操作指令包括：重啟或殺死。

6.一種基于Kafka的服務進程可視化監控與管理的裝置，其特征在于，包括：

WEB模塊，用于接收用戶提供的端口信息，并將所述端口信息存入mysql數據庫；

進程采集器，用于根據所述端口信息，基于預設的刷新時間間隔，向業務平臺的各個節點進行查詢掃描，獲取所述端口信息對應的端口的狀態信息；將所述狀態信息寫入Kafka主題進行存儲；在每次查詢掃描時，都會產生一個秒級的時間信息，將所述秒級的時間信息與所述狀態信息對應存儲；

進程控制器，用于從所述Kafka主題中獲取存儲的所述狀態信息和所述秒級的時間信息；基于所述端口狀態信息和所述秒級的時間信息對服務進程進行監控及管理；

WEB模塊，還用于基于所述端口狀態信息和所述秒級的時間信息，制成可視化圖像并顯示。

7.如權利要求6所述的基于Kafka的服務進程可視化監控與管理的裝置，其特征在于，所述端口信息包括：監控的目標服務端口、端口所在的主機節點、服務的啟動命令以及信息刷新的時間間隔其中一種或多種結合。

8.如權利要求6所述的基于Kafka的服務進程可視化監控與管理的裝置，其特征在于，所述狀態信息包括：端口的對應進程號、進程狀態與父進程的信息列表。

9.如權利要求6所述的基于Kafka的服務進程可視化監控與管理的裝置，其特征在于，

所述進程控制器基于所述端口狀態信息和所述秒級的時間信息對服務進程進行監控及管理；包括：

當端口的進程信息為空時，發出監控告警，同時嘗試執行所述端口的啟動命令；

當所述進程狀態為空時，則殺死所述進程及對應的父進程，執行端口的啟動命令。

10.如權利要求6所述的基于Kafka的服務進程可視化監控與管理的裝置，其特征在于，WEB模塊還用于在顯示端口的進程信息時，還接收用戶對于所述進程的操作指令；執行所述操作指令；其中，所述操作指令包括：重啟或殺死。