package com.walker.tcp.netty;
|
|
import io.netty.channel.ChannelPipeline;
|
import io.netty.channel.socket.SocketChannel;
|
import io.netty.handler.codec.http.HttpObjectAggregator;
|
import io.netty.handler.codec.http.HttpServerCodec;
|
import io.netty.handler.logging.LogLevel;
|
import io.netty.handler.logging.LoggingHandler;
|
import io.netty.handler.stream.ChunkedWriteHandler;
|
|
public class WebSocketServerInitializer extends DefaultServerInitializer {
|
|
// public void setPackageSeparator(String packageSeparator) {
|
// throw new UnsupportedOperationException("websocket类型不支持该操作");
|
// }
|
|
@Override
|
protected void initChannel(SocketChannel ch) throws Exception {
|
// protected void initChannel(GenIdClientSocketChannel ch) throws Exception {
|
logger.debug("SocketChannel = {}", ch.getClass().getName());
|
ChannelPipeline pipeline = ch.pipeline();
|
|
pipeline.addLast("logging",new LoggingHandler(LogLevel.INFO));
|
|
// 设置30秒没有读到数据，则触发一个READER_IDLE事件。
|
// pipeline.addLast(new IdleStateHandler(30, 0, 0));
|
|
// HttpServerCodec：将请求和应答消息解码为HTTP消息
|
pipeline.addLast("http-codec",new HttpServerCodec());
|
|
// HttpObjectAggregator：将HTTP消息的多个部分合成一条完整的HTTP消息
|
pipeline.addLast("aggregator",new HttpObjectAggregator(65536));
|
|
// ChunkedWriteHandler：向客户端发送HTML5文件
|
pipeline.addLast("http-chunked",new ChunkedWriteHandler());
|
|
// 在管道中添加我们自己的接收数据实现方法
|
pipeline.addLast("handler", this.getHandler());
|
}
|
|
}
|
