lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-06-05 10:06:44 +08:00
parent 6dacbafc29
commit 2fb3472de0
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/org/redkale/cluster/ClusterAgent.java
View File

@@ -53,7 +53,7 @@ public abstract class ClusterAgent {
this.name = config.getValue("name", ""); this.name = config.getValue("name", "");
{ {
String ps = config.getValue("protocols", "").toUpperCase(); String ps = config.getValue("protocols", "").toUpperCase();
if (ps == null || ps.isEmpty()) ps = "SNCP"; if (ps == null || ps.isEmpty()) ps = "SNCP;HTTP";
this.protocols = ps.split(";"); this.protocols = ps.split(";");
} }
String ts = config.getValue("ports", ""); String ts = config.getValue("ports", "");
@@ -91,11 +91,13 @@ public abstract class ClusterAgent {
ClusterEntry entry = new ClusterEntry(ns, protocol, service); ClusterEntry entry = new ClusterEntry(ns, protocol, service);
localEntrys.put(entry.serviceid, entry); localEntrys.put(entry.serviceid, entry);
} }
//远程模式加载IP列表, 只能是SNCP协议 //远程模式加载IP列表, 只支持SNCP协议
for (Service service : remoteServices) { if (ns.isSNCP()) {
ClusterEntry entry = new ClusterEntry(ns, protocol, service); for (Service service : remoteServices) {
updateTransport(entry); ClusterEntry entry = new ClusterEntry(ns, protocol, service);
remoteEntrys.put(entry.serviceid, entry); updateSncpTransport(entry);
remoteEntrys.put(entry.serviceid, entry);
}
} }
afterRegister(ns, protocol); afterRegister(ns, protocol);
} }
@@ -143,7 +145,7 @@ public abstract class ClusterAgent {
protected abstract void deregister(NodeServer ns, String protocol, Service service); protected abstract void deregister(NodeServer ns, String protocol, Service service);
//格式: protocol:classtype-resourcename //格式: protocol:classtype-resourcename
protected void updateTransport(ClusterEntry entry) { protected void updateSncpTransport(ClusterEntry entry) {
Service service = entry.serviceref.get(); Service service = entry.serviceref.get();
if (service == null) return; if (service == null) return;
Collection<InetSocketAddress> addrs = queryAddress(entry); Collection<InetSocketAddress> addrs = queryAddress(entry);