WebSocketEnhancmentNettyBoot

gistfile1.java

public static void main(String[] args) throws Exception {
    final ServerBootstrap sb = new ServerBootstrap();
    try {
        sb.group(new NioEventLoopGroup(), new NioEventLoopGroup())
         .channel(NioServerSocketChannel.class)
         .localAddress(new InetSocketAddress(6666))
         .childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            public void initChannel(final SocketChannel ch) throws Exception {
                ch.pipeline().addLast(
                    new HttpRequestDecoder(),
                    new HttpChunkAggregator(65536),
                    new HttpResponseEncoder(),
                    new WebSocketServerProtocolHandler("/websocket"),
                    new CustomTextFrameHandler());
            }
        });

        final Channel ch = sb.bind().sync().channel();

        ch.closeFuture().sync();
    } finally {
        sb.shutdown();
    }
}