diff --git a/src/org/redkale/boot/Application.java b/src/org/redkale/boot/Application.java index 930bf7768..b580b95f7 100644 --- a/src/org/redkale/boot/Application.java +++ b/src/org/redkale/boot/Application.java @@ -945,7 +945,11 @@ public final class Application { serversLatch.countDown(); } }); - + if (clusterAgents != null) { + for (ClusterAgent cluster : clusterAgents) { + if (cluster != null) cluster.destroy(cluster.getConfig()); + } + } for (DataSource source : dataSources) { if (source == null) continue; try { diff --git a/src/org/redkale/boot/ClusterAgent.java b/src/org/redkale/boot/ClusterAgent.java index 3467a46ef..0236176ba 100644 --- a/src/org/redkale/boot/ClusterAgent.java +++ b/src/org/redkale/boot/ClusterAgent.java @@ -5,6 +5,7 @@ */ package org.redkale.boot; +import java.net.InetSocketAddress; import java.util.*; import org.redkale.convert.json.JsonConvert; import org.redkale.net.sncp.Sncp; @@ -81,6 +82,9 @@ public abstract class ClusterAgent { //远程模式不注册 } + //获取远程服务的可用ip列表 + public abstract List queryAddress(NodeServer server, Service service); + //注册服务 public abstract void register(NodeServer server, Service service);