Add server healthy method

shannon312 · Sep 12, 2018 · 8b29515 · 8b29515
1 parent 6bc0521
commit 8b29515
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 1 deletion.
diff --git a/client/src/main/java/com/alibaba/nacos/api/naming/NamingService.java b/client/src/main/java/com/alibaba/nacos/api/naming/NamingService.java
@@ -193,4 +193,6 @@ public interface NamingService {
      * @throws NacosException
      */
     List<ServiceInfo> getSubscribeServices() throws NacosException;
+
+    boolean serverHealthy();
 }
diff --git a/client/src/main/java/com/alibaba/nacos/api/naming/pojo/ServiceInfo.java b/client/src/main/java/com/alibaba/nacos/api/naming/pojo/ServiceInfo.java
@@ -28,6 +28,7 @@
  * @author dungu.zpf
  */
 public class ServiceInfo {
+
     @JSONField(serialize = false)
     private String jsonFromServer = StringUtils.EMPTY;
     public static final String SPLITER = "@@";

diff --git a/client/src/main/java/com/alibaba/nacos/client/naming/NacosNamingService.java b/client/src/main/java/com/alibaba/nacos/client/naming/NacosNamingService.java
@@ -253,4 +253,9 @@ public ListView<String> getServicesOfServer(int pageNo, int pageSize) throws Nac
     public List<ServiceInfo> getSubscribeServices() {
         return new ArrayList<>(hostReactor.getServiceInfoMap().values());
     }
+
+    @Override
+    public boolean serverHealthy() {
+        return serverProxy.serverHealthy();
+    }
 }
diff --git a/client/src/main/java/com/alibaba/nacos/client/naming/net/NamingProxy.java b/client/src/main/java/com/alibaba/nacos/client/naming/net/NamingProxy.java
@@ -233,6 +233,17 @@ public void deRegDom(String dom, String ip, int port, String cluster) throws Nac
         }
     }
 
+    public boolean serverHealthy() {
+
+        try {
+            reqAPI(UtilAndComs.NACOS_URL_BASE + "/api/hello", new HashMap<>());
+        } catch (Exception e) {
+            return false;
+        }
+
+        return true;
+    }
+
     public ListView<String> getServiceList(int pageNo, int pageSize) throws NacosException {
 
         Map<String, String> params = new HashMap<String, String>(4);
@@ -244,7 +255,8 @@ public ListView<String> getServiceList(int pageNo, int pageSize) throws NacosExc
         JSONObject json = JSON.parseObject(result);
         ListView<String> listView = new ListView<>();
         listView.setCount(json.getInteger("count"));
-        listView.setData(JSON.parseObject(json.getString("doms"), new TypeReference<List<String>>(){}));
+        listView.setData(JSON.parseObject(json.getString("doms"), new TypeReference<List<String>>() {
+        }));
 
         return listView;
     }