feat: 针对issue-12反馈问题，记录更详细的日志

Author: meethigher

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

@@ -48,47 +48,41 @@ protected ReverseTcpProxy(NetServer netServer, NetClient netClient,
             sourceSocket.pause();
             SocketAddress sourceRemote = sourceSocket.remoteAddress();
             SocketAddress sourceLocal = sourceSocket.localAddress();
-            log.debug("{} <-- {} connected", sourceLocal, sourceRemote);
-            sourceSocket.closeHandler(v -> log.debug("{} <-- {} closed", sourceLocal, sourceRemote));
-            netClient.connect(targetPort, targetHost).onComplete(ar -> {
-                if (ar.succeeded()) {
-                    NetSocket targetSocket = ar.result();
-                    targetSocket.pause();
-                    SocketAddress targetRemote = targetSocket.remoteAddress();
-                    SocketAddress targetLocal = targetSocket.localAddress();
-                    log.debug("{} --> {} connected", targetLocal, targetRemote);
-                    // feat: v1.0.5以前的版本，在closeHandler里面，将对端连接也关闭。比如targetSocket关闭时，则将sourceSocket也关闭。
-                    // 结果导致在转发短连接时，出现了bug。参考https://github.com/meethigher/tcp-reverse-proxy/issues/6
-                    targetSocket.closeHandler(v -> log.debug("{} --> {} closed", targetLocal, targetRemote));
-                    sourceSocket.pipeTo(targetSocket).onComplete(ar1 -> {
-                        if (ar1.succeeded()) {
-                            log.debug("pipeTo successful. {} --> {} --> {} --> {}",
-                                    sourceRemote, sourceLocal, targetLocal, targetRemote);
-                        } else {
-                            log.error("pipeTo failed. {} --> {} --> {} --> {}",
-                                    sourceRemote, sourceLocal, targetLocal, targetRemote,
-                                    ar1.cause());
-                        }
+            log.debug("source {} -- {} connected", sourceLocal, sourceRemote);
+            sourceSocket.closeHandler(v -> log.debug("source {} -- {} closed", sourceLocal, sourceRemote));
+            netClient.connect(targetPort, targetHost)
+                    .onFailure(e -> {
+                        log.error("failed to connect to {}:{}", targetHost, targetPort, e);
+                        // 若连接目标服务失败，需要断开源头服务
+                        sourceSocket.close();
+                    })
+                    .onSuccess(targetSocket -> {
+                        targetSocket.pause();
+                        SocketAddress targetRemote = targetSocket.remoteAddress();
+                        SocketAddress targetLocal = targetSocket.localAddress();
+                        log.debug("target {} -- {} connected", targetLocal, targetRemote);
+                        
+                        // feat: v1.0.5以前的版本，在closeHandler里面，将对端连接也关闭。比如targetSocket关闭时，则将sourceSocket也关闭。
+                        // 结果导致在转发短连接时，出现了bug。参考https://github.com/meethigher/tcp-reverse-proxy/issues/6
+                        targetSocket.closeHandler(v -> log.debug("target {} -- {} closed", targetLocal, targetRemote));
+
+                        // https://github.com/meethigher/tcp-reverse-proxy/issues/12
+                        // 将日志记录详细，便于排查问题
+                        sourceSocket.pipeTo(targetSocket)
+                                .onSuccess(v -> log.debug("source {} -- {} pipe to target {} -- {} succeeded",
+                                        sourceLocal, sourceRemote, targetLocal, targetRemote))
+                                .onFailure(e -> log.error("source {} -- {} pipe to target {} -- {} failed",
+                                        sourceLocal, sourceRemote, targetLocal, targetRemote, e));
+                        targetSocket.pipeTo(sourceSocket)
+                                .onSuccess(v -> log.debug("target {} -- {} pipe to source {} -- {} succeeded",
+                                        targetLocal, targetRemote, sourceLocal, sourceRemote))
+                                .onFailure(e -> log.error("target {} -- {} pipe to source {} -- {} failed",
+                                        targetLocal, targetRemote, sourceLocal, sourceRemote, e));
+                        log.debug("source {} -- {} bound to target {} -- {}",
+                                sourceLocal, sourceRemote, targetLocal, targetRemote);
+                        sourceSocket.resume();
+                        targetSocket.resume();
                     });
-                    targetSocket.pipeTo(sourceSocket).onComplete(ar1 -> {
-                        if (ar1.succeeded()) {
-                            log.debug("pipeTo successful. {} <-- {} <-- {} <-- {}",
-                                    sourceRemote, sourceLocal, targetLocal, targetRemote);
-                        } else {
-                            log.error("pipeTo failed. {} <-- {} <-- {} <-- {}",
-                                    sourceRemote, sourceLocal, targetLocal, targetRemote,
-                                    ar1.cause());
-                        }
-                    });
-                    sourceSocket.resume();
-                    targetSocket.resume();
-
-                } else {
-                    log.error("failed to connect to {}:{}", targetHost, targetPort, ar.cause());
-                    // 若连接目标服务失败，需要断开源头服务
-                    sourceSocket.close();
-                }
-            });
         };
     }