补充多集群健康状态概览信息

Author: zengqiao

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/MultiClusterPhyManager.java

@@ -1,5 +1,6 @@
 package com.xiaojukeji.know.streaming.km.biz.cluster;
 
+import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhysHealthState;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhysState;
 import com.xiaojukeji.know.streaming.km.common.bean.dto.cluster.MultiClusterDashboardDTO;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.result.PaginationResult;
@@ -15,6 +16,8 @@ public interface MultiClusterPhyManager {
      */
     ClusterPhysState getClusterPhysState();
 
+    ClusterPhysHealthState getClusterPhysHealthState();
+
     /**
      * 查询多集群大盘
      * @param dto 分页信息

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/cluster/impl/MultiClusterPhyManagerImpl.java

@@ -5,6 +5,7 @@
 import com.xiaojukeji.know.streaming.km.biz.cluster.MultiClusterPhyManager;
 import com.xiaojukeji.know.streaming.km.common.bean.dto.metrices.MetricDTO;
 import com.xiaojukeji.know.streaming.km.common.bean.dto.metrices.MetricsClusterPhyDTO;
+import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhysHealthState;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhysState;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy;
 import com.xiaojukeji.know.streaming.km.common.bean.dto.cluster.MultiClusterDashboardDTO;
@@ -16,6 +17,7 @@
 import com.xiaojukeji.know.streaming.km.common.bean.vo.metrics.line.MetricMultiLinesVO;
 import com.xiaojukeji.know.streaming.km.common.constant.Constant;
 import com.xiaojukeji.know.streaming.km.common.converter.ClusterVOConverter;
+import com.xiaojukeji.know.streaming.km.common.enums.health.HealthStateEnum;
 import com.xiaojukeji.know.streaming.km.common.utils.ConvertUtil;
 import com.xiaojukeji.know.streaming.km.common.utils.PaginationUtil;
 import com.xiaojukeji.know.streaming.km.common.utils.PaginationMetricsUtil;
@@ -75,6 +77,32 @@ public ClusterPhysState getClusterPhysState() {
         return physState;
     }
 
+    @Override
+    public ClusterPhysHealthState getClusterPhysHealthState() {
+        List<ClusterPhy> clusterPhyList = clusterPhyService.listAllClusters();
+
+        ClusterPhysHealthState physState = new ClusterPhysHealthState(clusterPhyList.size());
+        for (ClusterPhy clusterPhy: clusterPhyList) {
+            ClusterMetrics metrics = clusterMetricService.getLatestMetricsFromCache(clusterPhy.getId());
+            Integer state = metrics.getMetric(ClusterMetricVersionItems.CLUSTER_METRIC_HEALTH_STATE).intValue();
+            if (state == null) {
+                physState.setUnknownCount(physState.getUnknownCount() + 1);
+            } else if (state.equals(HealthStateEnum.GOOD.getDimension())) {
+                physState.setGoodCount(physState.getGoodCount() + 1);
+            } else if (state.equals(HealthStateEnum.MEDIUM.getDimension())) {
+                physState.setMediumCount(physState.getMediumCount() + 1);
+            } else if (state.equals(HealthStateEnum.POOR.getDimension())) {
+                physState.setPoorCount(physState.getPoorCount() + 1);
+            } else if (state.equals(HealthStateEnum.DEAD.getDimension())) {
+                physState.setDeadCount(physState.getDeadCount() + 1);
+            } else {
+                physState.setUnknownCount(physState.getUnknownCount() + 1);
+            }
+        }
+
+        return physState;
+    }
+
     @Override
     public PaginationResult<ClusterPhyDashboardVO> getClusterPhysDashboard(MultiClusterDashboardDTO dto) {
         // 获取集群
@@ -148,16 +176,7 @@ private PaginationResult<ClusterMetrics> getAndPagingClusterWithLatestMetricsFro
         // 获取所有的metrics
         List<ClusterMetrics> metricsList = new ArrayList<>();
         for (ClusterPhyDashboardVO vo: voList) {
-            ClusterMetrics clusterMetrics = clusterMetricService.getLatestMetricsFromCache(vo.getId());
-            if (!clusterMetrics.getMetrics().containsKey(ClusterMetricVersionItems.CLUSTER_METRIC_HEALTH_SCORE)) {
-                Float alive = clusterMetrics.getMetrics().get(ClusterMetricVersionItems.CLUSTER_METRIC_ALIVE);
-                // 如果集群没有健康分，则设置一个默认的健康分数值
-                clusterMetrics.putMetric(ClusterMetricVersionItems.CLUSTER_METRIC_HEALTH_SCORE,
-                        (alive != null && alive <= 0)? 0.0f: Constant.DEFAULT_CLUSTER_HEALTH_SCORE.floatValue()
-                );
-            }
-
-            metricsList.add(clusterMetrics);
+            metricsList.add(clusterMetricService.getLatestMetricsFromCache(vo.getId()));
         }
 
         // 范围搜索

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/cluster/ClusterPhysHealthState.java

@@ -0,0 +1,37 @@
+package com.xiaojukeji.know.streaming.km.common.bean.entity.cluster;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+
+/**
+ * 集群状态信息
+ * @author zengqiao
+ * @date 22/02/24
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class ClusterPhysHealthState {
+    private Integer unknownCount;
+
+    private Integer goodCount;
+
+    private Integer mediumCount;
+
+    private Integer poorCount;
+
+    private Integer deadCount;
+
+    private Integer total;
+
+    public ClusterPhysHealthState(Integer total) {
+        this.unknownCount = 0;
+        this.goodCount = 0;
+        this.mediumCount = 0;
+        this.poorCount = 0;
+        this.deadCount = 0;
+        this.total = total;
+    }
+}

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/cluster/ClusterPhysHealthStateVO.java

@@ -0,0 +1,32 @@
+package com.xiaojukeji.know.streaming.km.common.bean.vo.cluster;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+
+/**
+ * @author zengqiao
+ * @date 22/02/24
+ */
+@Data
+@ApiModel(description = "集群健康状态信息")
+public class ClusterPhysHealthStateVO {
+    @ApiModelProperty(value = "未知", example = "30")
+    private Integer unknownCount;
+
+    @ApiModelProperty(value = "好", example = "30")
+    private Integer goodCount;
+
+    @ApiModelProperty(value = "中", example = "30")
+    private Integer mediumCount;
+
+    @ApiModelProperty(value = "差", example = "30")
+    private Integer poorCount;
+
+    @ApiModelProperty(value = "down", example = "30")
+    private Integer deadCount;
+
+    @ApiModelProperty(value = "总数", example = "150")
+    private Integer total;
+}

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/MultiClusterPhyController.java

@@ -4,6 +4,7 @@
 import com.xiaojukeji.know.streaming.km.common.bean.dto.cluster.MultiClusterDashboardDTO;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.result.PaginationResult;
 import com.xiaojukeji.know.streaming.km.common.bean.entity.result.Result;
+import com.xiaojukeji.know.streaming.km.common.bean.vo.cluster.ClusterPhysHealthStateVO;
 import com.xiaojukeji.know.streaming.km.common.bean.vo.cluster.ClusterPhysStateVO;
 import com.xiaojukeji.know.streaming.km.common.bean.vo.cluster.ClusterPhyDashboardVO;
 import com.xiaojukeji.know.streaming.km.common.constant.ApiPrefix;
@@ -47,6 +48,13 @@ public Result<ClusterPhysStateVO> getClusterPhysState() {
         return Result.buildSuc(ConvertUtil.obj2Obj(multiClusterPhyManager.getClusterPhysState(), ClusterPhysStateVO.class));
     }
 
+    @ApiOperation(value = "多物理集群-健康状态", notes = "")
+    @GetMapping(value = "physical-clusters/health-state")
+    @ResponseBody
+    public Result<ClusterPhysHealthStateVO> getClusterPhysHealthState() {
+        return Result.buildSuc(ConvertUtil.obj2Obj(multiClusterPhyManager.getClusterPhysHealthState(), ClusterPhysHealthStateVO.class));
+    }
+
     @ApiOperation(value = "多物理集群-已存在kafka版本", notes = "")
     @GetMapping(value = "physical-clusters/exist-version")
     public Result<List<String>> getClusterPhysVersion() {