//package org.springblade.modules.webscoket;
//import io.netty.bootstrap.ServerBootstrap;
//import io.netty.channel.ChannelFuture;
//import io.netty.channel.ChannelInitializer;
//import io.netty.channel.ChannelOption;
//import io.netty.channel.EventLoopGroup;
//import io.netty.channel.nio.NioEventLoopGroup;
//import io.netty.channel.socket.SocketChannel;
//import io.netty.channel.socket.nio.NioServerSocketChannel;
//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 WebSocketServer {
//	private int port = 9034;
//
//	public WebSocketServer(int port) {
//		bind(port);
//	}
//
//	public void bind(int port) {
//		Thread thread = new Thread(new Runnable() {
//			@Override
//			public void run() {
//				EventLoopGroup bossGroup = new NioEventLoopGroup();
//				EventLoopGroup workerGroup = new NioEventLoopGroup();
//				try {
//					ServerBootstrap serverBootstrap = new ServerBootstrap();
//					serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
//						.handler(new LoggingHandler(LogLevel.INFO))
//						//保持连接
//						.childOption(ChannelOption.SO_KEEPALIVE, true)
//						.childHandler(new ChannelInitializer<SocketChannel>() {
//							@Override
//							protected void initChannel(SocketChannel ch) {
////	                            ch.pipeline().addLast("logging",new LoggingHandler("DEBUG"));//设置log监听器，并且日志级别为debug，方便观察运行流程
//								ch.pipeline().addLast("http-codec", new HttpServerCodec());//设置解码器
//								ch.pipeline().addLast("aggregator", new HttpObjectAggregator(65536));//聚合器，使用websocket会用到
//								ch.pipeline().addLast("http-chunked", new ChunkedWriteHandler());//用于大数据的分区传输
//								ch.pipeline().addLast("handler", new WebSocketHandler());//自定义的业务handler
//							}
//						});
//
//					ChannelFuture channelFuture = serverBootstrap.bind(port).sync();
//					System.out.println("WebSocketServer启动成功");
//					channelFuture.channel().closeFuture().sync();
//				} catch (Exception e) {
//					e.printStackTrace();
//				} finally {
//					bossGroup.shutdownGracefully();
//					workerGroup.shutdownGracefully();
//				}
//			}
//		});
//		thread.start();
//	}
//}