You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/08/03 12:31:23 UTC
[iotdb-web-workbench] 28/34: 新增监控指标展示功能
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb-web-workbench.git
commit 21d9ebedf396eb936e72fcbbee7ad4d4a12bed3e
Author: loveher147 <lo...@qq.com>
AuthorDate: Mon May 30 10:40:30 2022 +0800
新增监控指标展示功能
- 该版本适配低于0.13版本的iotdb并提供数据库管理功能，但不提供监控管理(低于0.13版本iotdb不支持监控);
- 仍然存在部分接口返回后端假数据，等待清华提供接口后替换为真实数据。
---
.../iotdb/admin/controller/IotDBController.java | 57 +-
.../iotdb/admin/controller/MetricsController.java | 170 ++
.../apache/iotdb/admin/mapper/ViewModeMapper.java | 13 +
.../iotdb/admin/model/dto/DataModelDetailDTO.java | 15 +
.../apache/iotdb/admin/model/dto/QueryInfoDTO.java | 19 +
.../apache/iotdb/admin/model/entity/ViewMode.java | 30 +
.../iotdb/admin/model/metricsDo/QueryDataDo.java | 18 +
.../apache/iotdb/admin/model/vo/DataModelVO.java | 10 +
.../org/apache/iotdb/admin/model/vo/GroupInfo.java | 16 +
.../apache/iotdb/admin/model/vo/GroupInfoVO.java | 6 +-
.../iotdb/admin/model/vo/JVMMetricsListDataVO.java | 14 +
.../model/vo/MetircsQueryClassificationVO.java | 15 +
.../iotdb/admin/model/vo/MetricsChartDataVO.java | 23 +
.../iotdb/admin/model/vo/MetricsConnectionVO.java | 15 +
.../iotdb/admin/model/vo/MetricsDataCountVO.java | 20 +
.../admin/model/vo/MetricsDataForDiagramVO.java | 16 +
.../iotdb/admin/model/vo/MetricsDataForListVO.java | 16 +
.../iotdb/admin/model/vo/MetricsListDataVO.java | 17 +
.../admin/model/vo/QueryClassificationVO.java | 14 +
.../apache/iotdb/admin/model/vo/QueryData1VO.java | 15 +
.../iotdb/admin/model/vo/QueryDataForListVO.java | 16 +
.../iotdb/admin/model/vo/QueryDataStrVO.java | 21 +
.../iotdb/admin/model/vo/QueryDataStrVO1.java | 15 +
.../apache/iotdb/admin/model/vo/QueryDataVO.java | 21 +
.../apache/iotdb/admin/model/vo/QueryInfoVO.java | 19 +
.../iotdb/admin/model/vo/QueryMetricsVO.java | 14 +
.../apache/iotdb/admin/service/IotDBService.java | 3 +
.../iotdb/admin/service/MetricsResultService.java | 23 +
.../apache/iotdb/admin/service/MetricsService.java | 41 +
.../iotdb/admin/service/impl/IotDBServiceImpl.java | 60 +
.../service/impl/MetricsResultServiceImpl.java | 283 ++++
.../admin/service/impl/MetricsServiceImpl.java | 1746 ++++++++++++++++++++
32 files changed, 2764 insertions(+), 17 deletions(-)
diff --git a/backend/src/main/java/org/apache/iotdb/admin/controller/IotDBController.java b/backend/src/main/java/org/apache/iotdb/admin/controller/IotDBController.java
index 5b4d0d0..8930913 100644
--- a/backend/src/main/java/org/apache/iotdb/admin/controller/IotDBController.java
+++ b/backend/src/main/java/org/apache/iotdb/admin/controller/IotDBController.java
@@ -95,28 +95,57 @@ public class IotDBController {
return BaseVO.success("Get IoTDB data model successfully", dataModelVO);
}
+ @GetMapping("/dataModel/detail")
+ @ApiOperation("Get IoTDB data model in detail")
+ public BaseVO<DataModelVO> getDataModelDetail(
+ @PathVariable("serverId") Integer serverId,
+ @RequestParam(value = "path", required = false, defaultValue = "root") String path,
+ @RequestParam(value = "pageSize", required = false, defaultValue = "10") Integer pageSize,
+ @RequestParam(value = "pageNum", required = false, defaultValue = "1") Integer pageNum,
+ HttpServletRequest request)
+ throws BaseException {
+ check(request, serverId);
+ Connection connection = connectionService.getById(serverId);
+ DataModelVO dataModelVO = iotDBService.getDataModelDetail(connection, path, pageSize, pageNum);
+ return BaseVO.success("Get IoTDB data model successfully", dataModelVO);
+ }
+
@GetMapping("/storageGroups/info")
@ApiOperation("Get information of the storage group list")
- public BaseVO<List<GroupInfoVO>> getAllStorageGroupsInfo(
- @PathVariable("serverId") Integer serverId, HttpServletRequest request) throws BaseException {
+ public BaseVO<GroupInfoVO> getAllStorageGroupsInfo(
+ @PathVariable("serverId") Integer serverId,
+ @RequestParam(value = "pageSize", required = false, defaultValue = "15") Integer pageSize,
+ @RequestParam(value = "pageNum", required = false, defaultValue = "1") Integer pageNum,
+ HttpServletRequest request)
+ throws BaseException {
check(request, serverId);
Connection connection = connectionService.getById(serverId);
List<String> groupNames = iotDBService.getAllStorageGroups(connection);
- List<GroupInfoVO> groupInfoList = new ArrayList<>();
- if (groupNames == null || groupNames.size() == 0) {
- return BaseVO.success("Get successfully", groupInfoList);
+ List<String> subGroupNames = new ArrayList<>();
+ int size = groupNames.size();
+ int pageStart = pageNum == 1 ? 0 : (pageNum - 1) * pageSize;
+ int pageEnd = size < pageNum * pageSize ? size : pageNum * pageSize;
+ if (size > pageStart) {
+ subGroupNames = groupNames.subList(pageStart, pageEnd);
+ }
+ List<GroupInfo> groupInfoList = new ArrayList<>();
+ GroupInfoVO groupInfoVO = new GroupInfoVO();
+ if (subGroupNames == null || subGroupNames.size() == 0) {
+ return BaseVO.success("Get successfully", groupInfoVO);
}
String host = connection.getHost();
- List<Integer> deviceCounts = iotDBService.getDevicesCount(connection, groupNames);
- List<String> descriptions = groupService.getGroupDescription(host, groupNames);
- for (int i = 0; i < groupNames.size(); i++) {
- GroupInfoVO groupInfoVO = new GroupInfoVO();
- groupInfoVO.setGroupName(groupNames.get(i));
- groupInfoVO.setDeviceCount(deviceCounts.get(i));
- groupInfoVO.setDescription(descriptions.get(i));
- groupInfoList.add(groupInfoVO);
+ List<Integer> deviceCounts = iotDBService.getDevicesCount(connection, subGroupNames);
+ List<String> descriptions = groupService.getGroupDescription(host, subGroupNames);
+ for (int i = 0; i < subGroupNames.size(); i++) {
+ GroupInfo groupInfo = new GroupInfo();
+ groupInfo.setGroupName(subGroupNames.get(i));
+ groupInfo.setDeviceCount(deviceCounts.get(i));
+ groupInfo.setDescription(descriptions.get(i));
+ groupInfoList.add(groupInfo);
}
- return BaseVO.success("Get successfully", groupInfoList);
+ groupInfoVO.setGroupInfoList(groupInfoList);
+ groupInfoVO.setGroupCount(size);
+ return BaseVO.success("Get successfully", groupInfoVO);
}
@GetMapping("/storageGroups")
diff --git a/backend/src/main/java/org/apache/iotdb/admin/controller/MetricsController.java b/backend/src/main/java/org/apache/iotdb/admin/controller/MetricsController.java
new file mode 100644
index 0000000..5c5a968
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/controller/MetricsController.java
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.iotdb.admin.controller;
+
+import org.apache.iotdb.admin.common.exception.BaseException;
+import org.apache.iotdb.admin.common.utils.AuthenticationUtils;
+import org.apache.iotdb.admin.model.entity.Connection;
+import org.apache.iotdb.admin.model.vo.*;
+import org.apache.iotdb.admin.service.ConnectionService;
+import org.apache.iotdb.admin.service.IotDBService;
+import org.apache.iotdb.admin.service.MetricsService;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-22-上午 9:55
+ */
+@RestController
+@Api(value = "metrics related")
+public class MetricsController {
+
+ @Autowired private ConnectionService connectionService;
+ @Autowired private IotDBService iotDBService;
+ @Autowired private MetricsService metricsService;
+
+ private static final Logger logger = LoggerFactory.getLogger(MetricsController.class);
+
+ @GetMapping("/servers/metrics/connection")
+ @ApiOperation("[metrics]Get All Connection")
+ public BaseVO<List<MetricsConnectionVO>> getConnectionList(HttpServletRequest request)
+ throws BaseException {
+ Integer userId = AuthenticationUtils.getUserId(request);
+ AuthenticationUtils.userAuthentication(userId, request);
+ List<ConnVO> allConnections = connectionService.getAllConnections(userId);
+ ArrayList<MetricsConnectionVO> metricsConnectionVOS = new ArrayList<>();
+ for (ConnVO connVO : allConnections) {
+ MetricsConnectionVO temp = new MetricsConnectionVO();
+ temp.setId(connVO.getId());
+ temp.setName(connVO.getAlias());
+ metricsConnectionVOS.add(temp);
+ }
+ return BaseVO.success("Get Successfully", metricsConnectionVOS);
+ }
+
+ @GetMapping("/servers/{serverId}/metrics/datacount")
+ @ApiOperation("[metrics]Get Datacount")
+ public BaseVO<MetricsDataCountVO> getMetricsConnectionDataCount(
+ @PathVariable("serverId") Integer serverId, HttpServletRequest request) throws BaseException {
+ check(request, serverId);
+ MetricsDataCountVO metricsDataCountVO = metricsService.getMetricsDataCount(serverId);
+ return BaseVO.success("Get IoTDB data statistics successfully", metricsDataCountVO);
+ }
+
+ @GetMapping("/servers/{serverId}/metrics/QueryClassification")
+ @ApiOperation("[metrics]Get all query classifications")
+ public BaseVO<MetircsQueryClassificationVO> getAllQueryClassification(
+ @PathVariable("serverId") Integer serverId, HttpServletRequest request) throws BaseException {
+ check(request, serverId);
+ MetircsQueryClassificationVO metircsQueryClassificationVO =
+ metricsService.getMetircsQueryClassification(serverId);
+ return BaseVO.success("Get IoTDB data statistics successfully", metircsQueryClassificationVO);
+ }
+
+ @GetMapping("/servers/{serverId}/metrics/{queryClassificationId}/selectcount")
+ @ApiOperation("[Metrics]Get detail information of query sql")
+ public BaseVO<QueryInfoVO> getQueryInfo(
+ @PathVariable("serverId") Integer serverId,
+ @PathVariable("queryClassificationId") Integer queryClassificationId,
+ @RequestParam(value = "pageSize", required = false, defaultValue = "10") Integer pageSize,
+ @RequestParam(value = "pageNum", required = false, defaultValue = "1") Integer pageNum,
+ @RequestParam(value = "filterString", required = false) String filterString,
+ @RequestParam(value = "startTime", required = false, defaultValue = "-1") String startTimeStr,
+ @RequestParam(value = "endTime", required = false, defaultValue = "-1") String endTimeStr,
+ @RequestParam(value = "executionResult", required = false) Integer executionResult,
+ HttpServletRequest request)
+ throws BaseException {
+ check(request, serverId);
+ QueryInfoVO queryInfoVO =
+ metricsService.getQueryInfo(
+ serverId,
+ queryClassificationId,
+ pageSize,
+ pageNum,
+ filterString,
+ startTimeStr,
+ endTimeStr,
+ executionResult);
+ return BaseVO.success("Get IoTDB query statement data statistics successfully", queryInfoVO);
+ }
+
+ @GetMapping("/servers/{serverId}/metrics/diagram")
+ @ApiOperation("Get metrics data for diagram")
+ public BaseVO<MetricsDataForDiagramVO> getMetricsDataForDiagram(
+ @PathVariable("serverId") Integer serverId,
+ @RequestParam Integer metricId,
+ HttpServletRequest request)
+ throws BaseException {
+ check(request, serverId);
+ Connection connection = connectionService.getById(serverId);
+ MetricsDataForDiagramVO metricsDataForDiagramVO =
+ iotDBService.getMetricDataByMetricId(connection, metricId);
+ metricsDataForDiagramVO.setServerId(serverId);
+ return BaseVO.success("Get metrics data for diagram successfully", metricsDataForDiagramVO);
+ }
+
+ @GetMapping("/servers/{serverId}/metrics/list/{metricsType}")
+ @ApiOperation("Get metrics data for list")
+ public BaseVO<MetricsDataForListVO> getMetricsDataForList(
+ @PathVariable("serverId") Integer serverId,
+ @PathVariable("metricsType") Integer metricsType,
+ HttpServletRequest request)
+ throws BaseException {
+ check(request, serverId);
+ MetricsDataForListVO metricsDataForListVO =
+ metricsService.getMetricsDataForList(serverId, metricsType);
+ return BaseVO.success("Get metrics data for list successfully", metricsDataForListVO);
+ }
+
+ @GetMapping("/servers/{serverId}/metrics/list/query/{mode}")
+ @ApiOperation("Get query metrics data for list")
+ public BaseVO<QueryDataForListVO> getQueryMetricsDataForList(
+ @PathVariable("serverId") Integer serverId, @PathVariable("mode") Integer mode)
+ throws BaseException {
+ QueryDataForListVO queryDataForListVO = new QueryDataForListVO();
+ queryDataForListVO.setMode(mode);
+ queryDataForListVO.setServerId(serverId);
+
+ if (mode == 1) {
+ List<QueryMetricsVO> queryMetricsVOs = iotDBService.getTopQueryMetricsData();
+ queryDataForListVO.setQueryMetricsVOs(queryMetricsVOs);
+
+ } else if (mode == 0) {
+ List<QueryMetricsVO> queryMetricsVOs = iotDBService.getSlowQueryMetricsData();
+ queryDataForListVO.setQueryMetricsVOs(queryMetricsVOs);
+ }
+ return BaseVO.success("Get query metrics data for list successfully", queryDataForListVO);
+ }
+
+ private void check(HttpServletRequest request, Integer serverId) throws BaseException {
+ Integer userId = AuthenticationUtils.getUserId(request);
+ connectionService.check(serverId, userId);
+ }
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/mapper/ViewModeMapper.java b/backend/src/main/java/org/apache/iotdb/admin/mapper/ViewModeMapper.java
new file mode 100644
index 0000000..66f9ea3
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/mapper/ViewModeMapper.java
@@ -0,0 +1,13 @@
+package org.apache.iotdb.admin.mapper;
+
+import org.apache.iotdb.admin.model.entity.ViewMode;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Erickin
+ * @create 2022-04-22-上午 10:32
+ */
+@Component
+public interface ViewModeMapper extends BaseMapper<ViewMode> {}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/dto/DataModelDetailDTO.java b/backend/src/main/java/org/apache/iotdb/admin/model/dto/DataModelDetailDTO.java
new file mode 100644
index 0000000..b33cce1
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/dto/DataModelDetailDTO.java
@@ -0,0 +1,15 @@
+package org.apache.iotdb.admin.model.dto;
+
+import lombok.Data;
+import org.apache.iotdb.admin.model.vo.DataModelVO;
+
+import java.io.Serializable;
+import java.util.List;
+
+@Data
+public class DataModelDetailDTO implements Serializable {
+ private List<DataModelVO> dataModelVOList;
+ private Integer pageNum;
+ private Integer pageSize;
+ private Integer total;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/dto/QueryInfoDTO.java b/backend/src/main/java/org/apache/iotdb/admin/model/dto/QueryInfoDTO.java
new file mode 100644
index 0000000..7f3210b
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/dto/QueryInfoDTO.java
@@ -0,0 +1,19 @@
+package org.apache.iotdb.admin.model.dto;
+
+import org.apache.iotdb.admin.model.vo.QueryDataStrVO;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-下午 5:12
+ */
+@Data
+public class QueryInfoDTO {
+ private Long latestRunningTime;
+ private Integer totalCount;
+ private Integer totalPage;
+ List<QueryDataStrVO> filteredQueryDataStrVOSList;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/entity/ViewMode.java b/backend/src/main/java/org/apache/iotdb/admin/model/entity/ViewMode.java
new file mode 100644
index 0000000..56c9ae6
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/entity/ViewMode.java
@@ -0,0 +1,30 @@
+package org.apache.iotdb.admin.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Null;
+import javax.validation.constraints.Pattern;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-22-上午 10:35
+ */
+@Data
+@TableName("view_mode")
+public class ViewMode implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ @Null
+ @TableId(type = IdType.AUTO)
+ private Integer id;
+
+ @NotBlank
+ @Pattern(regexp = "^[^ ]+$", message = "The account name cannot contain spaces")
+ private String name;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/metricsDo/QueryDataDo.java b/backend/src/main/java/org/apache/iotdb/admin/model/metricsDo/QueryDataDo.java
new file mode 100644
index 0000000..2be1e09
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/metricsDo/QueryDataDo.java
@@ -0,0 +1,18 @@
+package org.apache.iotdb.admin.model.metricsDo;
+
+import org.apache.iotdb.admin.model.vo.QueryDataVO;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-上午 9:28
+ */
+@Data
+public class QueryDataDo {
+ private List<QueryDataVO> QueryDataVOs;
+ private Long latestTimeStamp;
+ private Integer count;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/DataModelVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/DataModelVO.java
index 2763728..60f9a60 100644
--- a/backend/src/main/java/org/apache/iotdb/admin/model/vo/DataModelVO.java
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/DataModelVO.java
@@ -47,6 +47,16 @@ public class DataModelVO implements Serializable {
private List<DataModelVO> children;
+ private Integer showNum;
+
+ private Integer pageNum;
+
+ private Integer pageSize;
+
+ private Integer total;
+
+ private Integer totalSonNodeCount;
+
public DataModelVO(String name) {
this.name = name;
this.isGroup = false;
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/GroupInfo.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/GroupInfo.java
new file mode 100644
index 0000000..62e3cb2
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/GroupInfo.java
@@ -0,0 +1,16 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class GroupInfo implements Serializable {
+ private String groupName;
+ private Integer deviceCount;
+ private String description;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/GroupInfoVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/GroupInfoVO.java
index 512deb7..87f4823 100644
--- a/backend/src/main/java/org/apache/iotdb/admin/model/vo/GroupInfoVO.java
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/GroupInfoVO.java
@@ -24,12 +24,12 @@ import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
+import java.util.List;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class GroupInfoVO implements Serializable {
- private String groupName;
- private Integer deviceCount;
- private String description;
+ private Integer groupCount;
+ private List<GroupInfo> groupInfoList;
}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/JVMMetricsListDataVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/JVMMetricsListDataVO.java
new file mode 100644
index 0000000..3661555
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/JVMMetricsListDataVO.java
@@ -0,0 +1,14 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 5:26
+ */
+@Data
+public class JVMMetricsListDataVO extends MetricsListDataVO implements Serializable {
+ private String metricType;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetircsQueryClassificationVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetircsQueryClassificationVO.java
new file mode 100644
index 0000000..851c833
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetircsQueryClassificationVO.java
@@ -0,0 +1,15 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-上午 10:00
+ */
+@Data
+public class MetircsQueryClassificationVO {
+ private Integer serverId;
+ private List<QueryClassificationVO> classificationList;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsChartDataVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsChartDataVO.java
new file mode 100644
index 0000000..9bfa81f
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsChartDataVO.java
@@ -0,0 +1,23 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-上午 10:15
+ */
+@Data
+public class MetricsChartDataVO implements Serializable {
+ private List<String> timeList;
+ private List<String> metricnameList;
+ private List<String> unitList;
+ private HashMap<String, List<String>> dataList;
+}
+
+// List<String> timeList;
+// List<String> metricnameList;
+// HashMap<String, List<Integer> dataList;
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsConnectionVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsConnectionVO.java
new file mode 100644
index 0000000..8045fdb
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsConnectionVO.java
@@ -0,0 +1,15 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-上午 9:12
+ */
+@Data
+public class MetricsConnectionVO implements Serializable {
+ Integer id;
+ String name;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataCountVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataCountVO.java
new file mode 100644
index 0000000..82f6337
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataCountVO.java
@@ -0,0 +1,20 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-上午 9:38
+ */
+@Data
+public class MetricsDataCountVO {
+ private Integer serverId;
+ private Boolean status;
+ private String url;
+ private Integer port;
+ private Integer storageGroupCount;
+ private Integer deviceCount;
+ private Integer monitorCount;
+ private Integer dataCount;
+ private String version;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataForDiagramVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataForDiagramVO.java
new file mode 100644
index 0000000..08135e3
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataForDiagramVO.java
@@ -0,0 +1,16 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-上午 10:12
+ */
+@Data
+public class MetricsDataForDiagramVO implements Serializable {
+ private Integer serverId;
+ private Integer metricId;
+ private MetricsChartDataVO chartData;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataForListVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataForListVO.java
new file mode 100644
index 0000000..269cde1
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsDataForListVO.java
@@ -0,0 +1,16 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 8:12
+ */
+@Data
+public class MetricsDataForListVO {
+ private Integer serverId;
+ private Integer metricsType;
+ private List<MetricsListDataVO> listInfo;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsListDataVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsListDataVO.java
new file mode 100644
index 0000000..7bde7ca
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/MetricsListDataVO.java
@@ -0,0 +1,17 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 5:24
+ */
+@Data
+public class MetricsListDataVO implements Serializable {
+ private String name;
+ private String latestScratchTime;
+ private String latestResult;
+ private Integer detailAvailable;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryClassificationVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryClassificationVO.java
new file mode 100644
index 0000000..17993c0
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryClassificationVO.java
@@ -0,0 +1,14 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-上午 10:02
+ */
+@Data
+public class QueryClassificationVO {
+ private Integer id;
+ private String name;
+ private Integer flag;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryData1VO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryData1VO.java
new file mode 100644
index 0000000..b14e3c4
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryData1VO.java
@@ -0,0 +1,15 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-下午 3:56
+ */
+@Data
+public class QueryData1VO extends QueryDataVO implements Serializable {
+ private Integer precompiledTime;
+ private Integer optimizedTime;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataForListVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataForListVO.java
new file mode 100644
index 0000000..b200a0d
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataForListVO.java
@@ -0,0 +1,16 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 9:22
+ */
+@Data
+public class QueryDataForListVO {
+ private Integer serverId;
+ private Integer mode;
+ private List<QueryMetricsVO> queryMetricsVOs;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataStrVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataStrVO.java
new file mode 100644
index 0000000..5aecf44
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataStrVO.java
@@ -0,0 +1,21 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-28-下午 10:02
+ */
+@Data
+public class QueryDataStrVO implements Serializable {
+ private Integer id;
+ private String statement;
+ private String runningTime;
+ private Boolean isSlowQuery;
+ private Integer totalTime;
+ private Integer analysisTime;
+ private Integer executionTime;
+ private Integer executionResult;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataStrVO1.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataStrVO1.java
new file mode 100644
index 0000000..a14537a
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataStrVO1.java
@@ -0,0 +1,15 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-29-下午 2:10
+ */
+@Data
+public class QueryDataStrVO1 extends QueryDataStrVO implements Serializable {
+ private Integer precompiledTime;
+ private Integer optimizedTime;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataVO.java
new file mode 100644
index 0000000..081be81
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryDataVO.java
@@ -0,0 +1,21 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-下午 8:36
+ */
+@Data
+public class QueryDataVO implements Serializable {
+ private Integer id;
+ private String statement;
+ private Long runningTime;
+ private Boolean isSlowQuery;
+ private Integer totalTime;
+ private Integer analysisTime;
+ private Integer executionTime;
+ private Integer executionResult;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryInfoVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryInfoVO.java
new file mode 100644
index 0000000..e2b3529
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryInfoVO.java
@@ -0,0 +1,19 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-25-下午 5:13
+ */
+@Data
+public class QueryInfoVO {
+ private Integer queryClassificationId;
+ private String latestRunningTime;
+ private Integer totalCount;
+ private Integer totalPage;
+ private Integer serverId;
+ private List<QueryDataStrVO> filteredQueryDataStrVOSList;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryMetricsVO.java b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryMetricsVO.java
new file mode 100644
index 0000000..cdf3e12
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/model/vo/QueryMetricsVO.java
@@ -0,0 +1,14 @@
+package org.apache.iotdb.admin.model.vo;
+
+import lombok.Data;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 9:20
+ */
+@Data
+public class QueryMetricsVO {
+ private String SQLStatement;
+ private String runningTime;
+ private Integer executionTime;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/service/IotDBService.java b/backend/src/main/java/org/apache/iotdb/admin/service/IotDBService.java
index 0b050d7..2a97117 100644
--- a/backend/src/main/java/org/apache/iotdb/admin/service/IotDBService.java
+++ b/backend/src/main/java/org/apache/iotdb/admin/service/IotDBService.java
@@ -62,6 +62,9 @@ public interface IotDBService {
void setIotDBRole(Connection connection, IotDBRole iotDBRole) throws BaseException;
+ DataModelVO getDataModelDetail(
+ Connection connection, String path, Integer pageSize, Integer pageNum) throws BaseException;
+
UserRolesVO getRolesOfUser(Connection connection, String userName) throws BaseException;
void userGrant(Connection connection, String userName, UserGrantDTO userGrantDTO)
diff --git a/backend/src/main/java/org/apache/iotdb/admin/service/MetricsResultService.java b/backend/src/main/java/org/apache/iotdb/admin/service/MetricsResultService.java
new file mode 100644
index 0000000..1180f23
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/service/MetricsResultService.java
@@ -0,0 +1,23 @@
+package org.apache.iotdb.admin.service;
+
+import org.apache.iotdb.admin.common.exception.BaseException;
+import org.apache.iotdb.admin.model.entity.Connection;
+import org.apache.iotdb.admin.model.vo.MetricsListDataVO;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 4:07
+ */
+public interface MetricsResultService {
+ List<MetricsListDataVO> getJVMMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getCPUMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getMemMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getDiskMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getWriteMetricsDataList(Connection connection) throws BaseException;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/service/MetricsService.java b/backend/src/main/java/org/apache/iotdb/admin/service/MetricsService.java
new file mode 100644
index 0000000..50f8663
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/service/MetricsService.java
@@ -0,0 +1,41 @@
+package org.apache.iotdb.admin.service;
+
+import org.apache.iotdb.admin.common.exception.BaseException;
+import org.apache.iotdb.admin.model.entity.Connection;
+import org.apache.iotdb.admin.model.vo.*;
+
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 4:07
+ */
+public interface MetricsService {
+ List<MetricsListDataVO> getJVMMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getCPUMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getMemMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getDiskMetricsDataList(Connection connection) throws BaseException;
+
+ List<MetricsListDataVO> getWriteMetricsDataList(Connection connection) throws BaseException;
+
+ MetircsQueryClassificationVO getMetircsQueryClassification(Integer serverId);
+
+ QueryInfoVO getQueryInfo(
+ Integer serverId,
+ Integer queryClassificationId,
+ Integer pageSize,
+ Integer pageNum,
+ String filterString,
+ String startTimeStr,
+ String endTimeStr,
+ Integer executionResult)
+ throws BaseException;
+
+ MetricsDataCountVO getMetricsDataCount(Integer serverId) throws BaseException;
+
+ MetricsDataForListVO getMetricsDataForList(Integer serverId, Integer metricsType)
+ throws BaseException;
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/service/impl/IotDBServiceImpl.java b/backend/src/main/java/org/apache/iotdb/admin/service/impl/IotDBServiceImpl.java
index e904462..4318825 100644
--- a/backend/src/main/java/org/apache/iotdb/admin/service/impl/IotDBServiceImpl.java
+++ b/backend/src/main/java/org/apache/iotdb/admin/service/impl/IotDBServiceImpl.java
@@ -765,6 +765,66 @@ public class IotDBServiceImpl implements IotDBService {
}
}
+ @Override
+ public DataModelVO getDataModelDetail(
+ Connection connection, String path, Integer pageSize, Integer pageNum) throws BaseException {
+ SessionPool sessionPool = null;
+ try {
+ sessionPool = getSessionPool(connection);
+ DataModelVO root = new DataModelVO(path);
+ setNodeInfo(root, sessionPool, path);
+ List<DataModelVO> childrenDataModel = null;
+ DataModelDetailDTO childrenDataModelDetail =
+ getChildrenDataModelDetail(root, path, sessionPool, pageSize, pageNum);
+ childrenDataModel =
+ childrenDataModelDetail == null ? null : childrenDataModelDetail.getDataModelVOList();
+ if (childrenDataModelDetail != null) {
+ root.setPageNum(childrenDataModelDetail.getPageNum());
+ root.setPageSize(childrenDataModelDetail.getPageSize());
+ root.setTotal(childrenDataModelDetail.getTotal());
+ }
+ root.setChildren(childrenDataModel);
+ root.setTotalSonNodeCount(
+ getChildrenNode(path, sessionPool) == null
+ ? 0
+ : getChildrenNode(path, sessionPool).size());
+ root.setGroupCount(path.equals("root") ? getGroupCount(sessionPool) : null);
+ root.setPath(path);
+ return root;
+ } finally {
+ closeSessionPool(sessionPool);
+ }
+ }
+
+ private DataModelDetailDTO getChildrenDataModelDetail(
+ DataModelVO root, String path, SessionPool sessionPool, Integer pageSize, Integer pageNum)
+ throws BaseException {
+ Set<String> childrenNode = getChildrenNode(path, sessionPool);
+ if (childrenNode == null) {
+ return null;
+ }
+ List<DataModelVO> childrenlist = new ArrayList<>();
+ List<String> childrenNodeList = new ArrayList<>(childrenNode);
+ List<String> childrenNodeSubList = new ArrayList<>();
+ int size = childrenNode.size();
+ int pageStart = pageNum == 1 ? 0 : (pageNum - 1) * pageSize;
+ int pageEnd = size < pageNum * pageSize ? size : pageNum * pageSize;
+ if (size > pageStart) {
+ childrenNodeSubList = childrenNodeList.subList(pageStart, pageEnd);
+ }
+ for (String child : childrenNodeSubList) {
+ DataModelVO childNode = new DataModelVO(child);
+ setNodeInfo(childNode, sessionPool, path + "." + child);
+ childrenlist.add(childNode);
+ }
+ DataModelDetailDTO dataModelDetailDTO = new DataModelDetailDTO();
+ dataModelDetailDTO.setDataModelVOList(childrenlist);
+ dataModelDetailDTO.setPageNum(pageNum);
+ dataModelDetailDTO.setPageSize(pageSize);
+ dataModelDetailDTO.setTotal(size);
+ return dataModelDetailDTO;
+ }
+
@Override
public UserRolesVO getRolesOfUser(Connection connection, String userName) throws BaseException {
SessionPool sessionPool = getSessionPool(connection);
diff --git a/backend/src/main/java/org/apache/iotdb/admin/service/impl/MetricsResultServiceImpl.java b/backend/src/main/java/org/apache/iotdb/admin/service/impl/MetricsResultServiceImpl.java
new file mode 100644
index 0000000..de26ba5
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/service/impl/MetricsResultServiceImpl.java
@@ -0,0 +1,283 @@
+package org.apache.iotdb.admin.service.impl;
+
+import org.apache.iotdb.admin.common.exception.BaseException;
+import org.apache.iotdb.admin.model.entity.Connection;
+import org.apache.iotdb.admin.model.vo.JVMMetricsListDataVO;
+import org.apache.iotdb.admin.model.vo.MetricsListDataVO;
+import org.apache.iotdb.admin.service.MetricsResultService;
+
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 4:41
+ */
+@Service
+public class MetricsResultServiceImpl implements MetricsResultService {
+
+ public JVMMetricsListDataVO getCurrentThreadsCount(long currentTimeMillis) throws BaseException {
+ String name = "JVM当前线程数";
+ String metricType = "线程";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 1;
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:8086\".\"jvm.threads.daemon\","
+ + " root._metric.\"127.0.0.1:8086\".\"jvm.threads.live\" "
+ + "order by time desc limit 1";
+ try {
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ String latestResult = "[Just Test] 前台:20个，后台:39个，线程总数:59个";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getYGCHappendCountAndCostTime(long currentTimeMillis)
+ throws BaseException {
+ // TODO 暂时写死
+ String name = "YGC发生次数及总耗时";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 2;
+ String latestResult = "[Just Test] 20次 200s";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getUsedBufferSize(long currentTimeMillis) throws BaseException {
+ String name = "已经使用的缓冲区大小";
+ String metricType = "内存";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 3;
+ String latestResult = "[Just Test] 20G";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getJVMTotalUnloadClass(long currentTimeMillis) throws BaseException {
+ String name = "JVM累计卸载的class数量";
+ String metricType = "Classes";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 4;
+ String latestResult = "[Just Test] 30次";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public MetricsListDataVO getCPUUsed(long currentTimeMillis) throws BaseException {
+ String name = "CPU使用率";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 1;
+ String latestResult = "[Just Test] 50%";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getCPUCores(long currentTimeMillis) throws BaseException {
+ String name = "CPU核数";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 0;
+ String latestResult = "[Just Test] 4核";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getIotDBProcessMemUsed(long currentTimeMillis) throws BaseException {
+ String name = "IoTDB进程内存占用比例";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 1;
+ String latestResult = "[Just Test] 70%";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getTotalMem(long currentTimeMillis) throws BaseException {
+ String name = "物理内存大小";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 0;
+ String latestResult = "[Just Test] 4G";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getDiskAvaliable(long currentTimeMillis) throws BaseException {
+ String name = "磁盘剩余";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 1;
+ String latestResult = "[Just Test] 2G";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getDiskTotalSize(long currentTimeMillis) throws BaseException {
+ String name = "磁盘总大小";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 0;
+ String latestResult = "[Just Test] 4G";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO writeSucceedProportion(long currentTimeMillis) throws BaseException {
+ String name = "写入成功率";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 0;
+ String latestResult = "[Just Test] 80%";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO writeLatency(long currentTimeMillis) throws BaseException {
+ String name = "写入延迟（最近一分钟）";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ String latestScratchTime = simpleDateFormat.format(currentTimeMillis);
+ Integer detailAvailable = 1;
+ String latestResult = "[Just Test] 90%";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getJVMMetricsDataList(Connection connection) throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ long currentTimeMillis = System.currentTimeMillis();
+ JVMMetricsListDataVO currentThreadsCount = getCurrentThreadsCount(currentTimeMillis);
+ JVMMetricsListDataVO ygcHappendCountAndCostTime =
+ getYGCHappendCountAndCostTime(currentTimeMillis);
+ JVMMetricsListDataVO usedBufferSize = getUsedBufferSize(currentTimeMillis);
+ JVMMetricsListDataVO jvmTotalUnloadClass = getJVMTotalUnloadClass(currentTimeMillis);
+ // TODO 把所有指标都加进来
+ list.add(currentThreadsCount);
+ list.add(ygcHappendCountAndCostTime);
+ list.add(usedBufferSize);
+ list.add(jvmTotalUnloadClass);
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getCPUMetricsDataList(Connection connection) throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ long currentTimeMillis = System.currentTimeMillis();
+ MetricsListDataVO cpuUsed = getCPUUsed(currentTimeMillis);
+ MetricsListDataVO cpuCores = getCPUCores(currentTimeMillis);
+ list.add(cpuUsed);
+ list.add(cpuCores);
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getMemMetricsDataList(Connection connection) throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ long currentTimeMillis = System.currentTimeMillis();
+ MetricsListDataVO iotDBProcessMemUsed = getIotDBProcessMemUsed(currentTimeMillis);
+ MetricsListDataVO totalMem = getTotalMem(currentTimeMillis);
+ list.add(iotDBProcessMemUsed);
+ list.add(totalMem);
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getDiskMetricsDataList(Connection connection)
+ throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ long currentTimeMillis = System.currentTimeMillis();
+ MetricsListDataVO metricsListDataVO = getDiskAvaliable(currentTimeMillis);
+ MetricsListDataVO diskTotalSize = getDiskTotalSize(currentTimeMillis);
+ list.add(metricsListDataVO);
+ list.add(diskTotalSize);
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getWriteMetricsDataList(Connection connection)
+ throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ long currentTimeMillis = System.currentTimeMillis();
+ MetricsListDataVO writeSucceedProportion = writeSucceedProportion(currentTimeMillis);
+ MetricsListDataVO writeLatency = writeLatency(currentTimeMillis);
+ list.add(writeSucceedProportion);
+ list.add(writeLatency);
+ return list;
+ }
+}
diff --git a/backend/src/main/java/org/apache/iotdb/admin/service/impl/MetricsServiceImpl.java b/backend/src/main/java/org/apache/iotdb/admin/service/impl/MetricsServiceImpl.java
new file mode 100644
index 0000000..5dd025d
--- /dev/null
+++ b/backend/src/main/java/org/apache/iotdb/admin/service/impl/MetricsServiceImpl.java
@@ -0,0 +1,1746 @@
+package org.apache.iotdb.admin.service.impl;
+
+import org.apache.iotdb.admin.common.exception.BaseException;
+import org.apache.iotdb.admin.common.exception.ErrorCode;
+import org.apache.iotdb.admin.model.dto.QueryInfoDTO;
+import org.apache.iotdb.admin.model.entity.Connection;
+import org.apache.iotdb.admin.model.vo.*;
+import org.apache.iotdb.admin.service.ConnectionService;
+import org.apache.iotdb.admin.service.IotDBService;
+import org.apache.iotdb.admin.service.MetricsService;
+import org.apache.iotdb.rpc.IoTDBConnectionException;
+import org.apache.iotdb.rpc.StatementExecutionException;
+import org.apache.iotdb.session.pool.SessionDataSetWrapper;
+import org.apache.iotdb.session.pool.SessionPool;
+import org.apache.iotdb.tsfile.read.common.RowRecord;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.io.*;
+import java.math.BigDecimal;
+import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author Erickin
+ * @create 2022-04-26-下午 4:41
+ */
+@Service
+public class MetricsServiceImpl implements MetricsService {
+
+ @Autowired ConnectionService connectionService;
+ @Autowired IotDBService iotDBService;
+
+ private static final Logger logger = LoggerFactory.getLogger(IotDBServiceImpl.class);
+
+ public JVMMetricsListDataVO getCurrentThreadsCount(Connection connection) throws BaseException {
+ String name = "JVM当前线程数";
+ String metricType = "线程";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 1;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.daemon\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.live\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(2);
+ String s2 = values.get(1);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ s2 = s2.substring(0, s2.indexOf('.'));
+ int totalThreadCount = Integer.parseInt(s1);
+ int demoThreadCount = Integer.parseInt(s2);
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult =
+ "前台:"
+ + (totalThreadCount - demoThreadCount)
+ + "个，后台:"
+ + demoThreadCount
+ + "个，线程总数:"
+ + totalThreadCount
+ + "个";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getCurrentDaemonThreadsCount(Connection connection)
+ throws BaseException {
+ String name = "当前daemon线程数";
+ String metricType = "线程";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.daemon\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(1);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ int daemonThreadCount = Integer.parseInt(s1);
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = daemonThreadCount + "个";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getPeakThreadsCount(Connection connection) throws BaseException {
+ String name = "峰值线程数";
+ String metricType = "线程";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.peak\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(1);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ int daemonThreadCount = Integer.parseInt(s1);
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = daemonThreadCount + "个";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getVariableThreadsCount(Connection connection) throws BaseException {
+ String name = "处于各种状态的线程数";
+ String metricType = "线程";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.states\".\"state=new\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.states\".\"state=waiting\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.states\".\"state=runnable\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.states\".\"state=blocked\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.states\".\"state=timed-waiting\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.threads.states\".\"state=terminated\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(1);
+ String s2 = values.get(2);
+ String s3 = values.get(3);
+ String s4 = values.get(4);
+ String s5 = values.get(5);
+ String s6 = values.get(6);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ s2 = s2.substring(0, s2.indexOf('.'));
+ s3 = s3.substring(0, s3.indexOf('.'));
+ s4 = s4.substring(0, s4.indexOf('.'));
+ s5 = s5.substring(0, s5.indexOf('.'));
+ s6 = s6.substring(0, s6.indexOf('.'));
+ int newThreadCount = Integer.parseInt(s1);
+ int waitingThreadCount = Integer.parseInt(s2);
+ int runnableThreadCount = Integer.parseInt(s3);
+ int blockedThreadCount = Integer.parseInt(s4);
+ int timedWaitingThreadCount = Integer.parseInt(s5);
+ int terminatedThreadCount = Integer.parseInt(s6);
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult =
+ "新建("
+ + newThreadCount
+ + ")、"
+ + "可运行("
+ + waitingThreadCount
+ + ")、"
+ + "运行("
+ + runnableThreadCount
+ + ")、"
+ + "阻塞("
+ + blockedThreadCount
+ + ")、"
+ + "休眠("
+ + timedWaitingThreadCount
+ + ")、"
+ + "死亡("
+ + terminatedThreadCount
+ + ")";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getYGCHappendCountAndCostTime(Connection connection)
+ throws BaseException {
+ String name = "YGC发生次数及总耗时";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ SessionPool sessionPool = getSessionPool(connection);
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String countSQL =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_count\".\"action=end of minor GC\".\"cause=Allocation Failure\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_count\".\"action=end of minor GC\".\"cause=Metadata GC Threshold\" "
+ + "order by time desc limit 1";
+ String timeSQL =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_total\".\"action=end of minor GC\".\"cause=Allocation Failure\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_total\".\"action=end of minor GC\".\"cause=Metadata GC Threshold\" "
+ + "order by time desc limit 1";
+ List<String> countValues = executeQueryOneLine(sessionPool, countSQL);
+ List<String> timeValues = executeQueryOneLine(sessionPool, timeSQL);
+ long lastestTimeStamp = Long.parseLong(countValues.get(0));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ Integer detailAvailable = 2;
+ String s1 = countValues.get(1);
+ String s2 = countValues.get(2);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ s2 = s2.substring(0, s2.indexOf('.'));
+ int count = Integer.parseInt(s1) + Integer.parseInt(s2);
+ double time =
+ (Double.parseDouble(timeValues.get(1)) + Double.parseDouble(timeValues.get(2))) / 1000;
+ String latestResult = count + "次 " + time + "s";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getYGCMaxCostTimeAndReason(Connection connection)
+ throws BaseException {
+ String name = "YGC最大耗时及原因";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ SessionPool sessionPool = getSessionPool(connection);
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String timeSQL =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_max\".\"action=end of minor GC\".\"cause=Metadata GC Threshold\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_max\".\"action=end of minor GC\".\"cause=Allocation Failure\" "
+ + "order by time desc limit 1";
+ List<String> timeValues = executeQueryOneLine(sessionPool, timeSQL);
+ long lastestTimeStamp = Long.parseLong(timeValues.get(0));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ Integer detailAvailable = 2;
+ String latestResult =
+ Double.parseDouble(timeValues.get(1)) / 1000
+ + "s(Metadata GC Threshold)、"
+ + Double.parseDouble(timeValues.get(2)) / 1000
+ + "s(Allocation Failure)";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getFGCHappendCountAndCostTime(Connection connection)
+ throws BaseException {
+ String name = "FGC发生次数及总耗时";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ SessionPool sessionPool = getSessionPool(connection);
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String countSQL =
+ "select * from "
+ +
+ // "root._metric.\"127.0.0.1:8086\".\"jvm.gc.pause_count\".\"action=end of
+ // major GC\".\"cause=Allocation Failure\", " +
+ "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_count\".\"action=end of major GC\".\"cause=Metadata GC Threshold\" "
+ +
+ // "root._metric.\"127.0.0.1:8086\".\"jvm.gc.pause_count\".\"action=end of
+ // major GC\".\"cause=Ergonomics\" " +
+ "order by time desc limit 1";
+ String timeSQL =
+ "select * from "
+ +
+ // "root._metric.\"127.0.0.1:8086\".\"jvm.gc.pause_total\".\"action=end of
+ // major GC\".\"cause=Allocation Failure\", " +
+ "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_total\".\"action=end of major GC\".\"cause=Metadata GC Threshold\" "
+ +
+ // "root._metric.\"127.0.0.1:8086\".\"jvm.gc.pause_total\".\"action=end of
+ // major GC\".\"cause=Ergonomics\" " +
+ "order by time desc limit 1";
+ List<String> countValues = executeQueryOneLine(sessionPool, countSQL);
+ List<String> timeValues = executeQueryOneLine(sessionPool, timeSQL);
+ long lastestTimeStamp = Long.parseLong(countValues.get(0));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ Integer detailAvailable = 2;
+ // TODO: IOTDB BUG 等待修复
+ String s1 = countValues.get(1).equals("null") ? "0.0" : countValues.get(1);
+ // String s2 = countValues.get(2).equals("null") ? "0.0" : countValues.get(2);
+ // String s3 = countValues.get(3).equals("null") ? "0.0" : countValues.get(3);
+
+ s1 = s1.substring(0, s1.indexOf('.'));
+ // s2 = s2.substring(0, s2.indexOf('.'));
+ // s3 = s3.substring(0, s3.indexOf('.'));
+ // int count = Integer.parseInt(s1) + Integer.parseInt(s2) + Integer.parseInt(s3);
+ int count = Integer.parseInt(s1);
+ // TODO: IOTDB BUG 等待修复
+ double d1 = timeValues.get(1).equals("null") ? 0.0 : Double.parseDouble(timeValues.get(1));
+ // double d2 = timeValues.get(2).equals("null")? 0.0 : Double.parseDouble(timeValues.get(2));
+ // double d3 = timeValues.get(3).equals("null")? 0.0 : Double.parseDouble(timeValues.get(3));
+ // double time = d1 + d2 + d3;
+ double time = (d1) / 1000;
+ String latestResult = count + "次 " + time + "s";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getFGCMaxCostTimeAndReason(Connection connection)
+ throws BaseException {
+ String name = "FGC最大耗时及原因";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ SessionPool sessionPool = getSessionPool(connection);
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String timeSQL =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.pause_max\".\"action=end of major GC\".\"cause=Metadata GC Threshold\" "
+ +
+ // "root._metric.\"127.0.0.1:8086\".\"jvm.gc.pause_max\".\"action=end of
+ // major GC\".\"cause=Allocation Failure\", " +
+ // "root._metric.\"127.0.0.1:8086\".\"jvm.gc.pause_max\".\"action=end of
+ // major GC\".\"cause=Ergonomics\" " +
+ "order by time desc limit 1";
+ List<String> timeValues = executeQueryOneLine(sessionPool, timeSQL);
+ long lastestTimeStamp = Long.parseLong(timeValues.get(0));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ Integer detailAvailable = 2;
+ // TODO: IOTDB BUG 等待修复
+ String s1 = timeValues.get(1).equals("null") ? "0.0" : timeValues.get(1);
+ // String s2 = timeValues.get(2).equals("null")? "0.0" : timeValues.get(2);
+ // String s3 = timeValues.get(3).equals("null")? "0.0" : timeValues.get(3);
+ // String latestResult = timeValues.get(1)+"s(Metadata GC
+ // Threshold)、"+timeValues.get(2)+"s(Allocation Failure)、"+timeValues.get(3)+"s(Ergonomics)";
+ String latestResult = Double.parseDouble(timeValues.get(1)) / 1000 + "s(Metadata GC Threshold)";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getGCCPUoverhead(Connection connection) throws BaseException {
+ String name = "GC消耗CPU的比例";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.overhead\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ double percent = Double.parseDouble(values.get(1));
+ BigDecimal b = new BigDecimal(percent);
+ double percent1 = b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = percent1 + "%";
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getGCPromoted(Connection connection) throws BaseException {
+ String name = "从GC之前到GC之后老年代内存池大小正增长的累计";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.memory.promoted\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestResult = getNetFileSizeDescription((long) (Double.parseDouble(values.get(1))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getMajorMemoryMaxValueEver(Connection connection)
+ throws BaseException {
+ String name = "老年代内存的历史最大值";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.max.data.size\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestResult = getNetFileSizeDescription((long) (Double.parseDouble(values.get(1))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getMajorMemorySizeAfterGC(Connection connection)
+ throws BaseException {
+ String name = "GC之后老年代内存的大小";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.live.data.size\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = getNetFileSizeDescription((long) (Double.parseDouble(values.get(1))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = count;
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getMinorMemorySizeAddedBetweentwoGC(Connection connection)
+ throws BaseException {
+ String name = "在一个GC之后到下一个GC之前年轻代增加的内存";
+ String metricType = "垃圾回收";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.gc.memory.allocated\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = getNetFileSizeDescription((long) (Double.parseDouble(values.get(1))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = count;
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getBufferUsed(Connection connection) throws BaseException {
+ String name = "已经使用的缓冲区大小";
+ String metricType = "内存";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.buffer.memory.used\".\"id=mapped\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.buffer.memory.used\".\"id=direct\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count =
+ getNetFileSizeDescription(
+ (long) (Double.parseDouble(values.get(1)) + Double.parseDouble(values.get(2))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = count;
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getMaxBuffer(Connection connection) throws BaseException {
+ String name = "最大缓冲区大小";
+ String metricType = "内存";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.buffer.total.capacity\".\"id=mapped\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.buffer.total.capacity\".\"id=direct\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count =
+ getNetFileSizeDescription(
+ (long) (Double.parseDouble(values.get(1)) + Double.parseDouble(values.get(2))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = count;
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getBufferCount(Connection connection) throws BaseException {
+ String name = "当前缓冲区数量";
+ String metricType = "内存";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.buffer.count\".\"id=mapped\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.buffer.count\".\"id=direct\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(1);
+ String s2 = values.get(2);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ s2 = s2.substring(0, s2.indexOf('.'));
+ String latestResult = (Integer.parseInt(s1) + Integer.parseInt(s2)) + "个";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getJVMCommittedMemorySize(Connection connection)
+ throws BaseException {
+ String name = "当前向JVM申请的内存大小";
+ String metricType = "内存";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.committed\".\"area=nonheap\".\"id=Compressed Class Space\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.committed\".\"area=nonheap\".\"id=Code Cache\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.committed\".\"area=nonheap\".\"id=Metaspace\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.committed\".\"area=heap\".\"id=PS Old Gen\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.committed\".\"area=heap\".\"id=PS Eden Space\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.committed\".\"area=heap\".\"id=PS Survivor Space\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count =
+ getNetFileSizeDescription(
+ (long)
+ (Double.parseDouble(values.get(1))
+ + Double.parseDouble(values.get(2))
+ + Double.parseDouble(values.get(3))
+ + Double.parseDouble(values.get(4))
+ + Double.parseDouble(values.get(5))
+ + Double.parseDouble(values.get(6))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = count;
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getJVMMemoryMaxSize(Connection connection) throws BaseException {
+ String name = "JVM最大内存";
+ String metricType = "内存";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.max\".\"area=nonheap\".\"id=Compressed Class Space\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.max\".\"area=nonheap\".\"id=Code Cache\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.max\".\"area=nonheap\".\"id=Metaspace\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.max\".\"area=heap\".\"id=PS Old Gen\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.max\".\"area=heap\".\"id=PS Eden Space\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.max\".\"area=heap\".\"id=PS Survivor Space\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count =
+ getNetFileSizeDescription(
+ (long)
+ (Double.parseDouble(values.get(1))
+ + Double.parseDouble(values.get(2))
+ + Double.parseDouble(values.get(3))
+ + Double.parseDouble(values.get(4))
+ + Double.parseDouble(values.get(5))
+ + Double.parseDouble(values.get(6))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = count;
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getJVMMemoryUsedSize(Connection connection) throws BaseException {
+ String name = "JVM已使用内存大小";
+ String metricType = "内存";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.used\".\"area=nonheap\".\"id=Compressed Class Space\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.used\".\"area=nonheap\".\"id=Code Cache\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.used\".\"area=nonheap\".\"id=Metaspace\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.used\".\"area=heap\".\"id=PS Old Gen\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.used\".\"area=heap\".\"id=PS Eden Space\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.memory.used\".\"area=heap\".\"id=PS Survivor Space\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count =
+ getNetFileSizeDescription(
+ (long)
+ (Double.parseDouble(values.get(1))
+ + Double.parseDouble(values.get(2))
+ + Double.parseDouble(values.get(3))
+ + Double.parseDouble(values.get(4))
+ + Double.parseDouble(values.get(5))
+ + Double.parseDouble(values.get(6))));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = count;
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getJVMUnloadedClassesTotal(Connection connection)
+ throws BaseException {
+ String name = "JVM累计卸载的Class数量";
+ String metricType = "Classes";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.classes.unloaded\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(1);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ String latestResult = Integer.parseInt(s1) + "个";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getJVMloadedClassesTotal(Connection connection) throws BaseException {
+ String name = "JVM累计加载的Class数量";
+ String metricType = "Classes";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.classes.loaded\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(1);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ String latestResult = Integer.parseInt(s1) + "个";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public JVMMetricsListDataVO getJVMCompilationTime(Connection connection) throws BaseException {
+ String name = "JVM耗费在编译上的时间";
+ String metricType = "Classes";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"jvm.compilation.time\".\"compiler=HotSpot 64-Bit Tiered Compilers\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestResult = values.get(1) + "s";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ JVMMetricsListDataVO jvmMetricsListDataVO = new JVMMetricsListDataVO();
+ jvmMetricsListDataVO.setMetricType(metricType);
+ jvmMetricsListDataVO.setDetailAvailable(detailAvailable);
+ jvmMetricsListDataVO.setLatestResult(latestResult);
+ jvmMetricsListDataVO.setLatestScratchTime(latestScratchTime);
+ jvmMetricsListDataVO.setName(name);
+ return jvmMetricsListDataVO;
+ }
+
+ public MetricsListDataVO getCPUUsed(Connection connection) throws BaseException {
+ String name = "CPU使用率";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"sys_cpu_load\".\"name=system\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestResult = values.get(1) + "%";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getCPUCores(Connection connection) throws BaseException {
+ String name = "CPU核数";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"sys_cpu_cores\".\"name=system\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String s1 = values.get(1);
+ s1 = s1.substring(0, s1.indexOf('.'));
+ String latestResult = s1 + "核";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getCPUTime(Connection connection) throws BaseException {
+ String name = "CPU Time";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"process_cpu_time\".\"name=process\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String timeStr = values.get(1);
+ long count = Long.parseLong(timeStr.substring(timeStr.indexOf("E") + 1));
+ double time = Double.parseDouble(timeStr.substring(0, timeStr.indexOf("E")));
+ while (count > 0) {
+ time *= 10;
+ count--;
+ }
+ String latestResult = (float) (time / 1000000000) + "s";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getTotalMem(Connection connection) throws BaseException {
+ String name = "物理内存大小";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ String str = connection.getHost();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"sys_total_physical_memory_size\".\"name=system\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestResult = getNetFileSizeDescription((long) Double.parseDouble(values.get(1)));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getProcessRatio(Connection connection) throws BaseException {
+ String name = "IoTDB进程内存占用比例";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"process_mem_ratio\".\"name=process\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ String latestResult = values.get(1) + "%";
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getDiskTotalSize(Connection connection) throws BaseException {
+ String name = "磁盘总大小";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"sys_disk_total_space\".\"name=system\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestResult = getNetFileSizeDescription((long) Double.parseDouble(values.get(1)));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getDiskLoadSize(Connection connection) throws BaseException {
+ // TODO: 假数据，等待iotdb增加该指标
+ String name = "磁盘挂载";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"sys_disk_total_space\".\"name=system\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ // String latestResult = getNetFileSizeDescription((long)Double.parseDouble(values.get(1)));
+ String latestResult = "【假数据：指标暂缺】2G";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getDiskAvailableSize(Connection connection) throws BaseException {
+ String name = "磁盘剩余";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"sys_disk_free_space\".\"name=system\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String latestResult = getNetFileSizeDescription((long) Double.parseDouble(values.get(1)));
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getDiskIO(Connection connection) throws BaseException {
+ String name = "磁盘IO吞吐";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"sys_disk_free_space\".\"name=system\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ // String latestResult = getNetFileSizeDescription((long)Double.parseDouble(values.get(1)));
+ String latestResult = "【假数据：指标暂缺】136K/s";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getWalFileCountAndSize(Connection connection) throws BaseException {
+ String name = "wal日志文件数量及大小";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_count\".\"name=wal\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_size\".\"name=wal\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = values.get(1);
+ count = count.substring(0, count.indexOf('.'));
+ String size = getNetFileSizeDescription((long) Double.parseDouble(values.get(2)));
+ String latestResult = "数量：" + count + "；" + "大小：" + size;
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getSeqTSFileCountAndSize(Connection connection) throws BaseException {
+ String name = "顺序TsFile文件数量及大小";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_count\".\"name=seq\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_size\".\"name=seq\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = values.get(1);
+ count = count.substring(0, count.indexOf('.'));
+ String size = getNetFileSizeDescription((long) Double.parseDouble(values.get(2)));
+ String latestResult = "数量：" + count + "；" + "大小：" + size;
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getUnSeqTSFileCountAndSize(Connection connection) throws BaseException {
+ String name = "乱序TsFile文件数量及大小";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_count\".\"name=unseq\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_size\".\"name=unseq\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = values.get(1);
+ count = count.substring(0, count.indexOf('.'));
+ String size = getNetFileSizeDescription((long) Double.parseDouble(values.get(2)));
+ String latestResult = "数量：" + count + "；" + "大小：" + size;
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getWriteDelay(Connection connection) throws BaseException {
+ String name = "写入延迟(最近一分钟)";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_count\".\"name=unseq\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_size\".\"name=unseq\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = values.get(1);
+ count = count.substring(0, count.indexOf('.'));
+ String size = getNetFileSizeDescription((long) Double.parseDouble(values.get(2)));
+ String latestResult = "【假数据：指标暂缺】" + "90" + "%";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getWriteSucceedCount(Connection connection) throws BaseException {
+ String name = "查询成功次数(最近1分钟)";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_count\".\"name=unseq\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_size\".\"name=unseq\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = values.get(1);
+ count = count.substring(0, count.indexOf('.'));
+ String size = getNetFileSizeDescription((long) Double.parseDouble(values.get(2)));
+ String latestResult = "【假数据：指标暂缺】" + "100" + "次";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getWriteFailedCount(Connection connection) throws BaseException {
+ String name = "查询失败次数(最近1分钟)";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_count\".\"name=unseq\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_size\".\"name=unseq\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = values.get(1);
+ count = count.substring(0, count.indexOf('.'));
+ String size = getNetFileSizeDescription((long) Double.parseDouble(values.get(2)));
+ String latestResult = "【假数据：指标暂缺】" + "20" + "次";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ public MetricsListDataVO getWriteSucceedRatio(Connection connection) throws BaseException {
+ String name = "查询成功率";
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Integer detailAvailable = 0;
+ int port = connection.getPort();
+ // TODO bug 修复后删除
+ if (port == 6668) {
+ port = 8086;
+ }
+ String sql =
+ "select * from "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_count\".\"name=unseq\", "
+ + "root._metric.\"127.0.0.1:"
+ + port
+ + "\".\"file_size\".\"name=unseq\" "
+ + "order by time desc limit 1";
+ SessionPool sessionPool = getSessionPool(connection);
+ List<String> values = executeQueryOneLine(sessionPool, sql);
+ long lastestTimeStamp = Long.parseLong(values.get(0));
+ String count = values.get(1);
+ count = count.substring(0, count.indexOf('.'));
+ String size = getNetFileSizeDescription((long) Double.parseDouble(values.get(2)));
+ String latestResult = "【假数据：指标暂缺】" + "80" + "%";
+ String latestScratchTime = simpleDateFormat.format(lastestTimeStamp);
+ MetricsListDataVO metricsListDataVO = new MetricsListDataVO();
+ metricsListDataVO.setDetailAvailable(detailAvailable);
+ metricsListDataVO.setLatestResult(latestResult);
+ metricsListDataVO.setLatestScratchTime(latestScratchTime);
+ metricsListDataVO.setName(name);
+ return metricsListDataVO;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getJVMMetricsDataList(Connection connection) throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ list.add(getCurrentThreadsCount(connection));
+ list.add(getCurrentDaemonThreadsCount(connection));
+ list.add(getPeakThreadsCount(connection));
+ list.add(getVariableThreadsCount(connection));
+ list.add(getYGCHappendCountAndCostTime(connection));
+ list.add(getYGCMaxCostTimeAndReason(connection));
+ list.add(getFGCHappendCountAndCostTime(connection));
+ list.add(getFGCMaxCostTimeAndReason(connection));
+ list.add(getGCCPUoverhead(connection));
+ list.add(getGCPromoted(connection));
+ list.add(getMajorMemoryMaxValueEver(connection));
+ list.add(getMajorMemorySizeAfterGC(connection));
+ list.add(getMinorMemorySizeAddedBetweentwoGC(connection));
+ list.add(getBufferUsed(connection));
+ list.add(getMaxBuffer(connection));
+ list.add(getBufferCount(connection));
+ list.add(getJVMCommittedMemorySize(connection));
+ list.add(getJVMMemoryMaxSize(connection));
+ list.add(getJVMMemoryUsedSize(connection));
+ list.add(getJVMUnloadedClassesTotal(connection));
+ list.add(getJVMloadedClassesTotal(connection));
+ list.add(getJVMCompilationTime(connection));
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getCPUMetricsDataList(Connection connection) throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ list.add(getCPUCores(connection));
+ list.add(getCPUUsed(connection));
+ list.add(getCPUTime(connection));
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getMemMetricsDataList(Connection connection) throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ list.add(getTotalMem(connection));
+ list.add(getProcessRatio(connection));
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getDiskMetricsDataList(Connection connection)
+ throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ list.add(getDiskTotalSize(connection));
+ list.add(getDiskLoadSize(connection));
+ list.add(getDiskAvailableSize(connection));
+ list.add(getDiskIO(connection));
+ list.add(getWalFileCountAndSize(connection));
+ list.add(getSeqTSFileCountAndSize(connection));
+ list.add(getUnSeqTSFileCountAndSize(connection));
+ return list;
+ }
+
+ @Override
+ public List<MetricsListDataVO> getWriteMetricsDataList(Connection connection)
+ throws BaseException {
+ List<MetricsListDataVO> list = new ArrayList<>();
+ list.add(getWriteDelay(connection));
+ list.add(getWriteSucceedCount(connection));
+ list.add(getWriteFailedCount(connection));
+ list.add(getWriteFailedCount(connection));
+ list.add(getWriteSucceedRatio(connection));
+ return list;
+ }
+
+ @Override
+ public MetircsQueryClassificationVO getMetircsQueryClassification(Integer serverId) {
+ // TODO：等待清华提供查询分类的接口
+ List<QueryClassificationVO> fakeData = new ArrayList<>();
+ for (int i = 0; i < 6; i++) {
+ QueryClassificationVO queryClassificationVO = new QueryClassificationVO();
+ queryClassificationVO.setId(i + 1);
+ queryClassificationVO.setName("查询分类" + (i + 1));
+ queryClassificationVO.setFlag(i % 2 == 0 ? 1 : 0);
+ fakeData.add(queryClassificationVO);
+ }
+ MetircsQueryClassificationVO metircsQueryClassificationVO = new MetircsQueryClassificationVO();
+ metircsQueryClassificationVO.setServerId(serverId);
+ metircsQueryClassificationVO.setClassificationList(fakeData);
+ return metircsQueryClassificationVO;
+ }
+
+ @Override
+ public QueryInfoVO getQueryInfo(
+ Integer serverId,
+ Integer queryClassificationId,
+ Integer pageSize,
+ Integer pageNum,
+ String filterString,
+ String startTimeStr,
+ String endTimeStr,
+ Integer executionResult)
+ throws BaseException {
+ long startTime = Long.parseLong(startTimeStr);
+ long endTime = Long.parseLong(endTimeStr);
+ Connection connection = connectionService.getById(serverId);
+ QueryInfoDTO queryInfoDTO =
+ iotDBService.getQueryInfoListByQueryClassificationId(
+ connection,
+ queryClassificationId,
+ pageSize,
+ pageNum,
+ filterString,
+ startTime,
+ endTime,
+ executionResult);
+ QueryInfoVO queryInfoVO = new QueryInfoVO();
+ queryInfoVO.setQueryClassificationId(queryClassificationId);
+ String pattern = "yyyy-MM-dd' 'HH:mm:ss.SSS";
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
+ Long latestRunningTime = queryInfoDTO.getLatestRunningTime();
+ queryInfoVO.setLatestRunningTime(
+ latestRunningTime == 0 ? null : simpleDateFormat.format(latestRunningTime));
+ BeanUtils.copyProperties(queryInfoDTO, queryInfoVO);
+ queryInfoVO.setServerId(serverId);
+ return queryInfoVO;
+ }
+
+ @Override
+ public MetricsDataCountVO getMetricsDataCount(Integer serverId) throws BaseException {
+ Connection connection = connectionService.getById(serverId);
+ DataCountVO dataCountVO = new DataCountVO();
+ MetricsDataCountVO metricsDataCountVO = new MetricsDataCountVO();
+ DataCountVO dataCount = new DataCountVO();
+ try {
+ dataCount = iotDBService.getDataCount(connection);
+ metricsDataCountVO.setStatus(true);
+ } catch (BaseException e) {
+ metricsDataCountVO.setStatus(false);
+ }
+ metricsDataCountVO.setServerId(serverId);
+ metricsDataCountVO.setUrl(connection.getHost());
+ metricsDataCountVO.setPort(connection.getPort());
+ BeanUtils.copyProperties(dataCount, metricsDataCountVO);
+ metricsDataCountVO.setDataCount(dataCount.getDataCount());
+ return metricsDataCountVO;
+ }
+
+ @Override
+ public MetricsDataForListVO getMetricsDataForList(Integer serverId, Integer metricsType)
+ throws BaseException {
+ Connection connection = connectionService.getById(serverId);
+ List<MetricsListDataVO> metricsDataList = null;
+ // TODO：具体区分和判断等待清华提供方案和策略
+ switch (metricsType) {
+ case 0:
+ metricsDataList = getJVMMetricsDataList(connection);
+ break;
+ case 1:
+ metricsDataList = getCPUMetricsDataList(connection);
+ break;
+ case 2:
+ metricsDataList = getMemMetricsDataList(connection);
+ break;
+ case 3:
+ metricsDataList = getDiskMetricsDataList(connection);
+ break;
+ case 4:
+ metricsDataList = getWriteMetricsDataList(connection);
+ break;
+ }
+ MetricsDataForListVO metricsDataForListVO = new MetricsDataForListVO();
+ metricsDataForListVO.setServerId(serverId);
+ metricsDataForListVO.setMetricsType(metricsType);
+ metricsDataForListVO.setListInfo(metricsDataList);
+ return metricsDataForListVO;
+ }
+
+ public static SessionPool getSessionPool(Connection connection) throws BaseException {
+ String host = connection.getHost();
+ Integer port = connection.getPort();
+ String username = connection.getUsername();
+ String password = connection.getPassword();
+ SessionPool sessionPool = null;
+ try {
+ sessionPool = new SessionPool(host, port, username, password, 3);
+ } catch (Exception e) {
+ throw new BaseException(ErrorCode.GET_SESSION_FAIL, ErrorCode.GET_SESSION_FAIL_MSG);
+ }
+ return sessionPool;
+ }
+
+ private List<String> executeQueryOneLine(SessionPool sessionPool, String sql)
+ throws BaseException {
+ SessionDataSetWrapper sessionDataSetWrapper = null;
+ try {
+ List<String> valueList = new ArrayList<>();
+ sessionDataSetWrapper = sessionPool.executeQueryStatement(sql);
+ if (sessionDataSetWrapper.hasNext()) {
+ RowRecord rowRecord = sessionDataSetWrapper.next();
+ valueList.add(rowRecord.getTimestamp() + "");
+ List<org.apache.iotdb.tsfile.read.common.Field> fields = rowRecord.getFields();
+ for (org.apache.iotdb.tsfile.read.common.Field field : fields) {
+ valueList.add(field.toString());
+ }
+ }
+ return valueList;
+ } catch (IoTDBConnectionException e) {
+ logger.error(e.getMessage());
+ throw new BaseException(ErrorCode.GET_SESSION_FAIL, ErrorCode.GET_SESSION_FAIL_MSG);
+ } catch (StatementExecutionException e) {
+ logger.error(e.getMessage());
+ throw new BaseException(ErrorCode.SQL_EP, ErrorCode.SQL_EP_MSG);
+ } finally {
+ closeResultSet(sessionDataSetWrapper);
+ }
+ }
+
+ private void closeSessionPool(SessionPool sessionPool) {
+ if (sessionPool != null) {
+ sessionPool.close();
+ }
+ }
+
+ private void closeResultSet(SessionDataSetWrapper sessionDataSetWrapper) {
+ if (sessionDataSetWrapper != null) {
+ sessionDataSetWrapper.close();
+ }
+ }
+
+ private static String getNetFileSizeDescription(long size) {
+ StringBuffer bytes = new StringBuffer();
+ DecimalFormat format = new DecimalFormat("###.0");
+ if (size >= 1024 * 1024 * 1024) {
+ double i = (size / (1024.0 * 1024.0 * 1024.0));
+ bytes.append(format.format(i)).append("GB");
+ } else if (size >= 1024 * 1024) {
+ double i = (size / (1024.0 * 1024.0));
+ bytes.append(format.format(i)).append("MB");
+ } else if (size >= 1024) {
+ double i = (size / (1024.0));
+ bytes.append(format.format(i)).append("KB");
+ } else if (size < 1024) {
+ if (size <= 0) {
+ bytes.append("0B");
+ } else {
+ bytes.append((int) size).append("B");
+ }
+ }
+ return bytes.toString();
+ }
+}