feat: 验证ssl自签名/CA证书的http请求

Author: meethigher

src/main/java/top/meethigher/proxy/http/VertxHTTPReverseProxy.java

@@ -285,6 +285,16 @@ public List<ProxyRoute> getRoutes() {
         return proxyRoutes;
     }
 
+    public VertxHTTPReverseProxy port(int port) {
+        this.sourcePort = port;
+        return this;
+    }
+
+    public VertxHTTPReverseProxy host(String host) {
+        this.sourceHost = host;
+        return this;
+    }
+
     public void start() {
         httpServer.requestHandler(router).exceptionHandler(e -> log.error("request failed", e));
         Future<HttpServer> listenFuture = httpServer.listen(sourcePort, sourceHost);

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

@@ -46,12 +46,14 @@ private VertxTCPReverseProxy(NetServer netServer, NetClient netClient,
             sourceSocket.pause();
             netClient.connect(targetPort, targetHost)
                     .onSuccess(targetSocket -> {
-                        log.info("connected {} <--> {}", sourceSocket.remoteAddress().toString(), targetSocket.remoteAddress().toString());
+                        log.info("connected {} <--> {} ({} <--> {})", sourceSocket.remoteAddress().toString(), sourceSocket.localAddress().toString(),
+                                targetSocket.localAddress().toString(), targetSocket.remoteAddress().toString());
                         targetSocket.pause();
                         sourceSocket.closeHandler(v -> targetSocket.close()).pipeTo(targetSocket);
                         targetSocket.closeHandler(v -> {
                             sourceSocket.close();
-                            log.info("closed {} <--> {}", sourceSocket.remoteAddress().toString(), targetSocket.remoteAddress().toString());
+                            log.info("closed {} <--> {} ({} <--> {})", sourceSocket.remoteAddress().toString(), sourceSocket.localAddress().toString(),
+                                    targetSocket.localAddress().toString(), targetSocket.remoteAddress().toString());
                         }).pipeTo(sourceSocket);
                         sourceSocket.resume();
                         targetSocket.resume();

src/test/java/top/meethigher/VertxHTTPReverseProxyTest.java

@@ -1,6 +1,8 @@
 package top.meethigher;
 
 import io.vertx.core.Vertx;
+import io.vertx.core.http.HttpClientOptions;
+import io.vertx.ext.web.Router;
 import org.junit.Test;
 import top.meethigher.proxy.http.ProxyRoute;
 import top.meethigher.proxy.http.VertxHTTPReverseProxy;
@@ -11,12 +13,17 @@ public class VertxHTTPReverseProxyTest {
 
     @Test
     public void testVertxHTTPReverseProxyTest() throws Exception {
-        VertxHTTPReverseProxy proxy = VertxHTTPReverseProxy.create(Vertx.vertx());
-
+        Vertx vertx = Vertx.vertx();
+        VertxHTTPReverseProxy proxy = VertxHTTPReverseProxy.create(
+                Router.router(vertx),
+                vertx.createHttpServer(),
+                vertx.createHttpClient(new HttpClientOptions().setVerifyHost(false).setTrustAll(true))
+        );
+        proxy.port(998);
         proxy.start();
         ProxyRoute proxyRoute = new ProxyRoute();
-        proxyRoute.setSourceUrl("/api/*");
-        proxyRoute.setTargetUrl("https://reqres.in/");
+        proxyRoute.setSourceUrl("/*");
+        proxyRoute.setTargetUrl("https://10.0.0.10:4321");
         proxy.addRoute(proxyRoute);
         TimeUnit.MINUTES.sleep(20);
         proxy.stop();