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.SslHandler;
|
import io.netty.handler.stream.ChunkedWriteHandler;
|
|
import javax.net.ssl.SSLContext;
|
import javax.net.ssl.SSLEngine;
|
|
public class ChildChannelHandler extends ChannelInitializer<SocketChannel> {
|
@Override
|
protected void initChannel(SocketChannel socketChannel) throws Exception {
|
String path = "D:\\app\\cert\\tomcat\\17603048_www.zycx.ztrbkj.com_tomcat\\zycx.ztrbkj.com.pfx";
|
SSLContext sslContext = createSSLContext.createSSLContext("PKCS12"
|
, path, "k8q1bczh");
|
//SSLEngine 此类允许使用ssl安全套接层协议进行安全通信
|
SSLEngine engine = sslContext.createSSLEngine();
|
engine.setUseClientMode(false);
|
socketChannel.pipeline().addLast("ssl", new SslHandler(engine));
|
|
// 设置30秒没有读到数据，则触发一个READER_IDLE事件。
|
// pipeline.addLast(new IdleStateHandler(30, 0, 0));
|
// HttpServerCodec：将请求和应答消息解码为HTTP消息
|
socketChannel.pipeline().addLast("http-codec", new HttpServerCodec());
|
// HttpObjectAggregator：将HTTP消息的多个部分合成一条完整的HTTP消息
|
socketChannel.pipeline().addLast("aggregator", new HttpObjectAggregator(65536));
|
// ChunkedWriteHandler：向客户端发送HTML5文件
|
socketChannel.pipeline().addLast("http-chunked", new ChunkedWriteHandler());
|
// 在管道中添加我们自己的接收数据实现方法
|
socketChannel.pipeline().addLast("handler", new WebSocketHandler());
|
}
|
}
|
