diff options
| author | lijinyang <[email protected]> | 2024-03-25 18:21:06 +0800 |
|---|---|---|
| committer | lijinyang <[email protected]> | 2024-03-25 18:21:06 +0800 |
| commit | 8a30fd1b2d8e05bae3ca15f54c7aadc1e5f802a9 (patch) | |
| tree | 0b48bf5eba887299cbb9e3ee27a0c77c0ecde7ad | |
| parent | 49fabc4c3089a9082017bad61918e17d3b4de92c (diff) | |
fix:优化检测接口状态获取逻辑
| -rw-r--r-- | src/main/java/com/mesa/reportservice/service/impl/JobServiceImpl.java | 5 | ||||
| -rw-r--r-- | src/main/java/com/mesa/reportservice/service/impl/ZookeeperServiceImpl.java | 7 |
2 files changed, 2 insertions, 10 deletions
diff --git a/src/main/java/com/mesa/reportservice/service/impl/JobServiceImpl.java b/src/main/java/com/mesa/reportservice/service/impl/JobServiceImpl.java index c60d5e3..df36440 100644 --- a/src/main/java/com/mesa/reportservice/service/impl/JobServiceImpl.java +++ b/src/main/java/com/mesa/reportservice/service/impl/JobServiceImpl.java @@ -64,12 +64,9 @@ public class JobServiceImpl extends ServiceImpl<JobMapper, JobEntity> implements } catch (Exception e) { e.printStackTrace(); } - if(ObjectUtil.isNotEmpty(status.get("nodeStatus"))){ - numMap.put("nodeStatus",status.get("nodeStatus")); - } R r = new R(); r.put("data",numMap); - r.put("status",status.get("status")); + r.putAll(status); return r; } diff --git a/src/main/java/com/mesa/reportservice/service/impl/ZookeeperServiceImpl.java b/src/main/java/com/mesa/reportservice/service/impl/ZookeeperServiceImpl.java index 070231b..123235d 100644 --- a/src/main/java/com/mesa/reportservice/service/impl/ZookeeperServiceImpl.java +++ b/src/main/java/com/mesa/reportservice/service/impl/ZookeeperServiceImpl.java @@ -6,6 +6,7 @@ import com.mesa.reportservice.configuration.SchedulerProperties; import com.mesa.reportservice.configuration.ZookeeperProperties; import com.mesa.reportservice.service.ZookeeperService; import org.apache.curator.framework.CuratorFramework; +import org.apache.curator.framework.api.GetChildrenBuilder; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.data.Stat; import org.springframework.beans.factory.annotation.Autowired; @@ -78,15 +79,10 @@ public class ZookeeperServiceImpl implements ZookeeperService { Map<String, Object> status = new HashMap<>(); status.put("status","UP"); if (zookeeperProperties.getOpen() == 0) { - List<Map> nodeList = new ArrayList<>(); - Map<String, Object> node = new HashMap<>(); List<String> children = curatorConnect.getChildren().forPath("/"); boolean isDown = true; for (String child : children) { Stat stat = curatorConnect.checkExists().forPath("/" + child); - node.put("url",child); - node.put("status",stat != null?"UP":"DOWN"); - nodeList.add(node); if (stat != null) { isDown = false; } @@ -94,7 +90,6 @@ public class ZookeeperServiceImpl implements ZookeeperService { if(isDown){ status.put("status","DOWN"); } - status.put("nodeStatus",nodeList); } return status; } |
