udpate

g4proxy-new/src/main/java/com/virjar/g4proxy_new/client/G4ProxyClient.java

@@ -79,7 +79,11 @@ public class G4ProxyClient {
     private volatile boolean isConnecting = false;
 
     void forceReconnect() {
+        Channel channelCopy = natChannel;
         natChannel = null;
+        if (channelCopy.isActive()) {
+            channelCopy.close();
+        }
         connectNatServer();
     }
 

g4proxy-new/src/main/java/com/virjar/g4proxy_new/server/NatServerChannelHandler.java

@@ -195,7 +195,8 @@ public class NatServerChannelHandler extends SimpleChannelInboundHandler<NatMess
         NatClientImage client = clientManager.getClient(clientId);
         Channel natChannel1 = client.getNatChannel();
         if (natChannel == natChannel1) {
-            log.info("the nat channel InActive ,close ");
+            //nat channel 断开，需要关闭mapping port
+            log.info("the nat channel InActive ,close mapping port ");
             client.getUserMappingServerChannel().close();
         }
 

g4proxy-new/src/main/java/com/virjar/g4proxy_new/server/client/ClientManager.java

@@ -40,6 +40,7 @@ public class ClientManager {
 
             Channel userMappingServerChannel = userMappingServerChannels.get(mappingPort);
             if (userMappingServerChannel == null || !userMappingServerChannel.isActive()) {
+                log.info("re open mapping port: {}", mappingPort);
                 ChannelFuture channelFuture = userMappingBootstrap.bind(mappingPort);
                 try {
                     channelFuture.get();