From 846f8e416e86ee5f5f33da0977d605f355bcf75a Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期五, 08 八月 2025 15:15:16 +0800 Subject: [PATCH] 修改bug --- MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java | 29 +++++++---------------------- 1 files changed, 7 insertions(+), 22 deletions(-) diff --git a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java index 5072004..f7bbac0 100644 --- a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java +++ b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java @@ -4,34 +4,19 @@ import io.netty.channel.socket.SocketChannel; import io.netty.handler.codec.http.HttpObjectAggregator; import io.netty.handler.codec.http.HttpServerCodec; -import io.netty.handler.ssl.ClientAuth; -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 io.netty.handler.stream.ChunkedWriteHandler; - -import javax.net.ssl.SSLContext; -import javax.net.ssl.SSLEngine; -import java.io.File; public class ChildChannelHandler extends ChannelInitializer<SocketChannel> { @Override protected void initChannel(SocketChannel socketChannel) throws Exception { -// String path = "C:\\app\\cert\\tomcat\\www.gzjwzc.com.pfx"; -// SSLContext sslContext = createSSLContext.createSSLContext("PKCS12" -// , path, "79uc9bsd"); -// SSLEngine engine = sslContext.createSSLEngine(); - - - File path = new File("/root/server/app/cert/qytzt.cn.key"); - File path1 = new File("/root/server/app/cert/qytzt.cn.pem"); - SslContext sslContext = SslContextBuilder.forServer(path, path1, null).clientAuth(ClientAuth.NONE).build(); - +// String path = "C:\\Program Files\\Apache Software Foundation\\Tomcat 8.5\\cert\\SHA256withRSA_lzhyc.cn.pfx"; +// String path = "/usr/local/server/app/cert/tomcat/scs1680576839056_chaoshengdaijia.com_server.jks"; +// SSLContext sslContext = createSSLContext.createSSLContext("JKS" +// , path, "Zf3^5v6OoWmOVgeQ"); //SSLEngine 此类允许使用ssl安全套接层协议进行安全通信 - SSLEngine engine = sslContext.newEngine(socketChannel.alloc()); - engine.setUseClientMode(false); - socketChannel.pipeline().addLast("ssl", new SslHandler(engine)); +// SSLEngine engine = sslContext.createSSLEngine(); +// engine.setUseClientMode(false); +// socketChannel.pipeline().addLast("ssl", new SslHandler(engine)); // 设置30秒没有读到数据,则触发一个READER_IDLE事件。 // pipeline.addLast(new IdleStateHandler(30, 0, 0)); -- Gitblit v1.7.1