proxy support stop

redis/redis-proxy/src/main/java/com/ctrip/xpipe/redis/proxy/DefaultProxyServer.java

@@ -144,6 +144,7 @@ public void stop() {
         if(tlsFuture != null) {
             tlsFuture.channel().close();
         }
+        tunnelManager.removeAll();
     }
 
 

redis/redis-proxy/src/main/java/com/ctrip/xpipe/redis/proxy/controller/ProxyController.java

@@ -1,6 +1,7 @@
 package com.ctrip.xpipe.redis.proxy.controller;
 
 import com.ctrip.xpipe.codec.JsonCodec;
+import com.ctrip.xpipe.redis.proxy.ProxyServer;
 import com.ctrip.xpipe.redis.proxy.Tunnel;
 import com.ctrip.xpipe.redis.proxy.model.TunnelMeta;
 import com.ctrip.xpipe.redis.proxy.monitor.TunnelMonitorManager;
@@ -30,6 +31,30 @@ public class ProxyController {
     @Autowired
     private TunnelMonitorManager tunnelMonitorManager;
 
+    @Autowired
+    private ProxyServer proxyServer;
+
+    @PostMapping(value = "/server/start")
+    public RetMessage startServer() {
+        try {
+            proxyServer.start();
+            return RetMessage.createSuccessMessage();
+        } catch (Throwable th) {
+            return RetMessage.createFailMessage(th.getMessage());
+        }
+    }
+
+    @PostMapping(value = "/server/stop")
+    public RetMessage stopServer() {
+        try {
+            proxyServer.stop();
+            return RetMessage.createSuccessMessage();
+        } catch (Throwable th) {
+            return RetMessage.createFailMessage(th.getMessage());
+        }
+    }
+
+
     @RequestMapping(value = "/tunnels", method = RequestMethod.GET)
     public String getTunnelMetas() {
         List<Tunnel> tunnels = tunnelManager.tunnels();

redis/redis-proxy/src/main/java/com/ctrip/xpipe/redis/proxy/tunnel/DefaultTunnelManager.java

@@ -27,6 +27,7 @@
 
 import javax.annotation.PostConstruct;
 import javax.annotation.PreDestroy;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -154,6 +155,14 @@ public void remove(Channel frontendChannel) {
         }
     }
 
+    @Override
+    public void removeAll() {
+        Set<Channel> toCloseChannels = new HashSet<>(cache.keySet());
+        for (Channel channel: toCloseChannels) {
+            remove(channel);
+        }
+    }
+
     @Override
     public List<Tunnel> tunnels() {
         return Lists.newArrayList(cache.values());

redis/redis-proxy/src/main/java/com/ctrip/xpipe/redis/proxy/tunnel/TunnelManager.java

@@ -19,6 +19,8 @@ public interface TunnelManager extends Releasable, Observer {
 
     void remove(Channel frontendChannel);
 
+    void removeAll();
+
     List<Tunnel> tunnels();
 
     Tunnel getById(String id);