From c2a4926888c2665a3dabbb09a66fa70d5c0306d9 Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Sat, 28 Sep 2024 19:27:13 +0800 Subject: [PATCH] [fix] --- .../netty/filter/NettyServerPermeateServerRealFilter.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/NettyServerPermeateServerRealFilter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/NettyServerPermeateServerRealFilter.java index cffd02a..1f2ef67 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/NettyServerPermeateServerRealFilter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/NettyServerPermeateServerRealFilter.java @@ -5,6 +5,7 @@ import io.netty.channel.ChannelPipeline; import io.netty.channel.socket.SocketChannel; import io.netty.handler.ssl.SslContext; import io.netty.handler.ssl.SslContextBuilder; +import io.netty.handler.ssl.SslHandler; import io.netty.handler.ssl.util.InsecureTrustManagerFactory; import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkServerPermeateServerRealServer; @@ -13,8 +14,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer; import org.framework.lazy.cloud.network.heartbeat.server.netty.handler.NettyServerPermeateServerRealHandler; -import java.net.URI; -import java.net.URISyntaxException; +import javax.net.ssl.SSLContext; +import javax.net.ssl.SSLEngine; @Slf4j public class NettyServerPermeateServerRealFilter extends DebugChannelInitializer { @@ -42,7 +43,7 @@ public class NettyServerPermeateServerRealFilter extends DebugChannelInitializer try { SslContext sslContext = SslContextBuilder.forClient() .trustManager(InsecureTrustManagerFactory.INSTANCE).build(); - pipeline.addLast("ssl", sslContext.newHandler(ch.alloc(),targetIp,targetPort)); + pipeline.addLast(sslContext.newHandler(ch.alloc())); } catch (Exception e) { throw new RuntimeException(e); }