From a99c7d3454790bd61f8d8b00e4ce88e89c81da0a Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Sat, 27 May 2017 15:07:24 +0800
Subject: [PATCH]

---
 src/org/redkale/net/http/WebSocket.java | 27 +++++++++++++++++++++++++
 1 file changed, 27 insertions(+)

diff --git a/src/org/redkale/net/http/WebSocket.java b/src/org/redkale/net/http/WebSocket.java
index 31c85bef2..cee8cb4b0 100644
--- a/src/org/redkale/net/http/WebSocket.java
+++ b/src/org/redkale/net/http/WebSocket.java
@@ -315,6 +315,33 @@ public abstract class WebSocket<G extends Serializable, T> {
         return rs;
     }
 
+    /**
+     * 获取用户在线的SNCP节点地址列表，不是分布式则返回元素数量为1，且元素值为null的列表<br>
+     * InetSocketAddress 为 SNCP节点地址
+     *
+     * @param groupid Serializable
+     *
+     * @return 地址列表
+     */
+    public CompletableFuture<Collection<InetSocketAddress>> getRpcNodeAddresses(final Serializable groupid) {
+        if (_engine.node == null) return CompletableFuture.completedFuture(null);
+        return _engine.node.getRpcNodeAddresses(groupid);
+    }
+
+    /**
+     * 获取在线用户的详细连接信息 <br>
+     * Map.key 为 SNCP节点地址, 含值为null的key表示没有分布式
+     * Map.value 为 用户客户端的IP
+     *
+     * @param groupid Serializable
+     *
+     * @return 地址集合
+     */
+    public CompletableFuture<Map<InetSocketAddress, List<String>>> getRpcNodeWebSocketAddresses(final Serializable groupid) {
+        if (_engine.node == null) return CompletableFuture.completedFuture(null);
+        return _engine.node.getRpcNodeWebSocketAddresses(groupid);
+    }
+
     /**
      * 获取当前WebSocket下的属性，非线程安全
      *