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(port))
         .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();
        System.out.println("Web socket server started at port " + port);

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