1. @Override
    2. protected void doOpen() throws Throwable {
    3.     bootstrap = new ServerBootstrap();
    5.     bossGroup = new NioEventLoopGroup(1, new DefaultThreadFactory("NettyServerBoss", true));
    6.     workerGroup = new NioEventLoopGroup(getUrl().getPositiveParameter(Constants.IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS),
    7.                                         new DefaultThreadFactory("NettyServerWorker", true));
    9.     final NettyServerHandler nettyServerHandler = new NettyServerHandler(getUrl(), this);
    10.     channels = nettyServerHandler.getChannels();
    12.     bootstrap.group(bossGroup, workerGroup)
    13.         .channel(NioServerSocketChannel.class)
    14.         .childOption(ChannelOption.TCP_NODELAY, Boolean.TRUE)
    15.         .childOption(ChannelOption.SO_REUSEADDR, Boolean.TRUE)
    16.         .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)
    17.         .childHandler(new ChannelInitializer<NioSocketChannel>() {
    18.             @Override
    19.             protected void initChannel(NioSocketChannel ch) throws Exception {
    20.                 // FIXME: should we use getTimeout()?
    21.                 int idleTimeout = UrlUtils.getIdleTimeout(getUrl());
    22.                 NettyCodecAdapter adapter = new NettyCodecAdapter(getCodec(), getUrl(), NettyServer.this);
    23.                 ch.pipeline()//.addLast("logging",new LoggingHandler(LogLevel.INFO))//for debug
    24.                     .addLast("decoder", adapter.getDecoder())
    25.                     .addLast("encoder", adapter.getEncoder())
    26.                     .addLast("server-idle-handler", new IdleStateHandler(0, 0, idleTimeout, MILLISECONDS))
    27.                     .addLast("handler", nettyServerHandler);
    28.             }
    29.         });
    30.     // bind
    31.     ChannelFuture channelFuture = bootstrap.bind(getBindAddress());
    32.     channelFuture.syncUninterruptibly();
    33.     channel = channelFuture.channel();
    35. }