From a6c105d63d7375497a8d35582950729eaedfae44 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Sat, 3 Jun 2017 18:41:08 +0800
Subject: [PATCH]

---
 src/org/redkale/boot/watch/TransportWatchService.java | 6 ++++++
 src/org/redkale/net/TransportFactory.java             | 4 ++++
 2 files changed, 10 insertions(+)

diff --git a/src/org/redkale/boot/watch/TransportWatchService.java b/src/org/redkale/boot/watch/TransportWatchService.java
index ede14fcb8..ce5a6ce5a 100644
--- a/src/org/redkale/boot/watch/TransportWatchService.java
+++ b/src/org/redkale/boot/watch/TransportWatchService.java
@@ -7,6 +7,7 @@ package org.redkale.boot.watch;
 
 import java.net.*;
 import java.nio.channels.AsynchronousSocketChannel;
+import java.util.List;
 import java.util.concurrent.TimeUnit;
 import javax.annotation.Resource;
 import org.redkale.boot.Application;
@@ -39,6 +40,11 @@ public class TransportWatchService implements WatchService {
     @Resource
     private TransportFactory transportFactory;
 
+    @RestMapping(name = "nodes", auth = false, comment = "获取所有Node节点")
+    public RetResult<List<TransportGroupInfo>> addNode() {
+        return new RetResult<>(transportFactory.getGroupInfos());
+    }
+
     @RestMapping(name = "addnode", auth = false, comment = "动态增加指定Group的Node节点")
     public RetResult addNode(
         @RestParam(name = "group", comment = "Group节点名") final String group,
diff --git a/src/org/redkale/net/TransportFactory.java b/src/org/redkale/net/TransportFactory.java
index aaf55ff3a..165174c63 100644
--- a/src/org/redkale/net/TransportFactory.java
+++ b/src/org/redkale/net/TransportFactory.java
@@ -141,6 +141,10 @@ public class TransportFactory {
         return executor;
     }
 
+    public List<TransportGroupInfo> getGroupInfos() {
+        return new ArrayList<>(this.groupInfos.values());
+    }
+
     public void addSncpService(Service service) {
         if (service == null) return;
         services.add(new WeakReference<>(service));