package com.sinata.zuul.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 = "C:\\Program Files\\Apache Software Foundation\\Tomcat 8.5\\cert\\SHA256withRSA_lzhyc.cn.pfx";
|
// String path = "C:\\cert\\5084549_express.feimadache.com.pfx";
|
// SSLContext sslContext = createSSLContext.createSSLContext("PKCS12"
|
// , path, "4zw2YVpF");
|
// //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());
|
}
|
}
|
