From 22c308a8c1317473c7279f7bf866814c64ef36e9 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期日, 22 六月 2025 01:09:54 +0800
Subject: [PATCH] 提交推送服务
---
MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java | 25 ++++++++++++++++++-------
1 files changed, 18 insertions(+), 7 deletions(-)
diff --git a/ZuulQYTTravel/src/main/java/com/sinata/zuul/util/applets/ChildChannelHandler.java b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java
similarity index 62%
rename from ZuulQYTTravel/src/main/java/com/sinata/zuul/util/applets/ChildChannelHandler.java
rename to MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java
index edbbae5..5072004 100644
--- a/ZuulQYTTravel/src/main/java/com/sinata/zuul/util/applets/ChildChannelHandler.java
+++ b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/ChildChannelHandler.java
@@ -1,26 +1,37 @@
-package com.sinata.zuul.util.applets;
+package com.sinata.push.util.applets;
import io.netty.channel.ChannelInitializer;
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 = "D:\\Program Files\\Apache Software Foundation\\Tomcat 8.5-80\\cert\\6855055_zhentonggongsi.com.pfx";
-// String path = "/usr/local/server/apache-tomcat-80/conf/cert/6064978_okyueche.com.pfx";
+// String path = "C:\\app\\cert\\tomcat\\www.gzjwzc.com.pfx";
// SSLContext sslContext = createSSLContext.createSSLContext("PKCS12"
-// , path, "jBOjj2fR");
-// SSLEngine 此类允许使用ssl安全套接层协议进行安全通信
+// , path, "79uc9bsd");
// SSLEngine engine = sslContext.createSSLEngine();
-// engine.setUseClientMode(false);
-// socketChannel.pipeline().addLast("ssl", new SslHandler(engine));
+
+
+ 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();
+
+ //SSLEngine 此类允许使用ssl安全套接层协议进行安全通信
+ SSLEngine engine = sslContext.newEngine(socketChannel.alloc());
+ engine.setUseClientMode(false);
+ socketChannel.pipeline().addLast("ssl", new SslHandler(engine));
// 设置30秒没有读到数据，则触发一个READER_IDLE事件。
// pipeline.addLast(new IdleStateHandler(30, 0, 0));
--
Gitblit v1.7.1