fix: tcp反向代理时目标不可达则断开源头连接

Author: meethigher

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>top.meethigher</groupId>
     <artifactId>tcp-reverse-proxy</artifactId>
-    <version>1.0.4</version>
+    <version>1.0.5</version>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

src/main/java/top/meethigher/proxy/tcp/ReverseTcpProxy.java

@@ -47,7 +47,10 @@ protected ReverseTcpProxy(NetServer netServer, NetClient netClient,
             // 暂停流读取
             sourceSocket.pause();
             netClient.connect(targetPort, targetHost)
-                    .onFailure(e -> log.error("failed to connect to {}:{}", targetHost, targetPort, e))
+                    .onFailure(e -> {
+                        log.error("failed to connect to {}:{}", targetHost, targetPort, e);
+                        sourceSocket.close();
+                    })
                     .onSuccess(targetSocket -> {
                         SocketAddress sourceRemoteAddress = sourceSocket.remoteAddress();
                         SocketAddress sourceLocalAddress = sourceSocket.localAddress();