This commit is contained in:
Redkale
2020-05-16 20:10:21 +08:00
parent d83e7c22ac
commit a97f8efe21
2 changed files with 9 additions and 1 deletions

View File

@@ -945,7 +945,11 @@ public final class Application {
serversLatch.countDown(); serversLatch.countDown();
} }
}); });
if (clusterAgents != null) {
for (ClusterAgent cluster : clusterAgents) {
if (cluster != null) cluster.destroy(cluster.getConfig());
}
}
for (DataSource source : dataSources) { for (DataSource source : dataSources) {
if (source == null) continue; if (source == null) continue;
try { try {

View File

@@ -5,6 +5,7 @@
*/ */
package org.redkale.boot; package org.redkale.boot;
import java.net.InetSocketAddress;
import java.util.*; import java.util.*;
import org.redkale.convert.json.JsonConvert; import org.redkale.convert.json.JsonConvert;
import org.redkale.net.sncp.Sncp; import org.redkale.net.sncp.Sncp;
@@ -81,6 +82,9 @@ public abstract class ClusterAgent {
//远程模式不注册 //远程模式不注册
} }
//获取远程服务的可用ip列表
public abstract List<InetSocketAddress> queryAddress(NodeServer server, Service service);
//注册服务 //注册服务
public abstract void register(NodeServer server, Service service); public abstract void register(NodeServer server, Service service);