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

ClusterAgent优化

Browse Source
This commit is contained in:
redkale
2023-01-31 11:08:25 +08:00
parent 7b2dc52a35
commit 7c8f54dd5c
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/redkale/cluster/ClusterAgent.java
View File

@@ -253,15 +253,15 @@ public abstract class ClusterAgent {
} }
protected String generateApplicationServiceName() { protected String generateApplicationServiceName() {
return "application" + (appName == null || appName.isEmpty() ? "" : ("." + appName)) + ".node." + this.nodeid; return "application.node" + (appName == null || appName.isEmpty() ? "" : ("." + appName));
} }
protected String generateApplicationServiceType() { protected String generateApplicationServiceType() {
return "application.nodes"; return "application.nodes";
} }
protected String generateApplicationServiceId() { //与serviceName相同 protected String generateApplicationServiceId() {
return generateApplicationServiceName(); return generateApplicationServiceName() + "." + this.nodeid;
} }
protected String generateApplicationCheckName() { protected String generateApplicationCheckName() {
@@ -377,7 +377,7 @@ public abstract class ClusterAgent {
//以协议+Rest资源名为主 服务类名 //以协议+Rest资源名为主 服务类名
public String serviceName; public String serviceName;
public String resourceType; public String serviceType;
public String resourceName; public String resourceName;
@@ -405,7 +405,7 @@ public abstract class ClusterAgent {
this.serviceName = generateServiceName(ns, protocol, service); this.serviceName = generateServiceName(ns, protocol, service);
this.checkid = generateCheckId(ns, protocol, service); this.checkid = generateCheckId(ns, protocol, service);
this.checkName = generateCheckName(ns, protocol, service); this.checkName = generateCheckName(ns, protocol, service);
this.resourceType = Sncp.getResourceType(service).getName(); this.serviceType = Sncp.getResourceType(service).getName();
this.resourceName = Sncp.getResourceName(service); this.resourceName = Sncp.getResourceName(service);
this.protocol = protocol; this.protocol = protocol;
InetSocketAddress addr = ns.getSocketAddress(); InetSocketAddress addr = ns.getSocketAddress();