From 38711299a49493dc6469e95f8a71caa5b80e7711 Mon Sep 17 00:00:00 2001 From: xyli Date: Wed, 14 Jun 2023 14:12:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0getNodeInfo=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/mpms/monitor/NodeMonitor.java | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/src/main/java/mpms/monitor/NodeMonitor.java b/src/main/java/mpms/monitor/NodeMonitor.java index be1da23..a4223e3 100644 --- a/src/main/java/mpms/monitor/NodeMonitor.java +++ b/src/main/java/mpms/monitor/NodeMonitor.java @@ -76,4 +76,25 @@ public class NodeMonitor implements Task { private void checkList(List nodeModels) { } + private void getNodeInfo(NodeModel nodeModel) { + JsonMessage message = NodeForward.request(nodeModel, null, NodeUrl.GetDirectTop); + JSONObject jsonObject = message.getData(); + if (jsonObject == null) { + return; + } + double disk = jsonObject.getDoubleValue("disk"); + if (disk <= 0) { + return; + } + + SystemMonitorLog log = new SystemMonitorLog(); + log.setId(IdUtil.fastSimpleUUID()); + log.setOccupyMemory(jsonObject.getDoubleValue("memory")); + log.setOccupyDisk(disk); + log.setOccupyCpu(jsonObject.getDoubleValue("cpu")); + log.setMonitorTime(jsonObject.getLongValue("time")); + log.setNodeId(nodeModel.getId()); + System.console().printf("start write da\n"); + dbSystemMonitorLogService.insert(log); + } } -- Gitee