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

Browse Source
This commit is contained in:
地平线
2015-08-10 17:33:01 +08:00
parent f5a72b29ec
commit b4ef81febe
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/com/wentch/redkale/boot/Application.java
View File

@@ -57,7 +57,7 @@ public final class Application {
//当前SNCP Server所属的组 类型: String //当前SNCP Server所属的组 类型: String
public static final String RESNAME_SNCP_GROUP = "SNCP_GROUP"; public static final String RESNAME_SNCP_GROUP = "SNCP_GROUP";
//当前SNCP Server的IP地址+端口 类型: SocketAddress、InetSocketAddress //当前SNCP Server的IP地址+端口 类型: SocketAddress、InetSocketAddress、String
public static final String RESNAME_SNCP_ADDR = "SNCP_ADDR"; public static final String RESNAME_SNCP_ADDR = "SNCP_ADDR";
//当前SNCP Server的IP地址+端口集合 类型: Map<InetSocketAddress, String>、HashMap<InetSocketAddress, String> //当前SNCP Server的IP地址+端口集合 类型: Map<InetSocketAddress, String>、HashMap<InetSocketAddress, String>

7
src/com/wentch/redkale/boot/NodeSncpServer.java
View File

@@ -31,8 +31,11 @@ public final class NodeSncpServer extends NodeServer {
this.servaddr = addr; this.servaddr = addr;
this.nodeGroup = application.addrGroups.getOrDefault(addr, ""); this.nodeGroup = application.addrGroups.getOrDefault(addr, "");
this.consumer = server == null ? null : x -> server.addService(x); this.consumer = server == null ? null : x -> server.addService(x);
this.factory.register(RESNAME_SNCP_ADDR, SocketAddress.class, this.servaddr); if (this.servaddr != null) {
this.factory.register(RESNAME_SNCP_ADDR, InetSocketAddress.class, this.servaddr); this.factory.register(RESNAME_SNCP_ADDR, SocketAddress.class, this.servaddr);
this.factory.register(RESNAME_SNCP_ADDR, InetSocketAddress.class, this.servaddr);
this.factory.register(RESNAME_SNCP_ADDR, String.class, this.servaddr.getAddress().getHostAddress());
}
this.factory.register(RESNAME_SNCP_GROUP, this.nodeGroup); this.factory.register(RESNAME_SNCP_GROUP, this.nodeGroup);
} }