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

Browse Source
This commit is contained in:
Redkale
2017-05-17 18:11:44 +08:00
parent 804b4dc07d
commit c3560b0ef0
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/org/redkale/net/http/WebSocketNode.java
View File

@@ -30,6 +30,7 @@ public abstract class WebSocketNode {
protected final boolean finest = logger.isLoggable(Level.FINEST); protected final boolean finest = logger.isLoggable(Level.FINEST);
//如果不是分布式(没有SNCP) 值为null
@Resource(name = Application.RESNAME_SERVER_ADDR) @Resource(name = Application.RESNAME_SERVER_ADDR)
protected InetSocketAddress localSncpAddress; //为SncpServer的服务address protected InetSocketAddress localSncpAddress; //为SncpServer的服务address
@@ -37,7 +38,7 @@ public abstract class WebSocketNode {
protected WebSocketNode remoteNode; protected WebSocketNode remoteNode;
//存放所有用户分布在节点上的队列信息,Set<InetSocketAddress> 为 sncpnode 的集合， key: groupid //存放所有用户分布在节点上的队列信息,Set<InetSocketAddress> 为 sncpnode 的集合， key: groupid
//如果不是分布式(没有SNCP)，则InetSocketAddress为当前WebSocketServlet的监听地址 //如果不是分布式(没有SNCP)，sncpAddressNodes 将不会被用到
@Resource(name = "$") @Resource(name = "$")
protected CacheSource<Serializable, InetSocketAddress> sncpAddressNodes; protected CacheSource<Serializable, InetSocketAddress> sncpAddressNodes;