2. @Override
    3. protected void doOpen() throws Throwable {
    4.     NettyHelper.setNettyLoggerFactory();
    5.     ExecutorService boss = Executors.newCachedThreadPool(new NamedThreadFactory("NettyServerBoss", true));
    6.     ExecutorService worker = Executors.newCachedThreadPool(new NamedThreadFactory("NettyServerWorker", true));
    7.     ChannelFactory channelFactory = new NioServerSocketChannelFactory(boss, worker, getUrl().getPositiveParameter(Constants.IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS));
    8.     bootstrap = new ServerBootstrap(channelFactory);
    10.     final NettyHandler nettyHandler = new NettyHandler(getUrl(), this);
    11.     channels = nettyHandler.getChannels();
    12.     // https://issues.jboss.org/browse/NETTY-365
    13.     // https://issues.jboss.org/browse/NETTY-379
    14.     // final Timer timer = new HashedWheelTimer(new NamedThreadFactory("NettyIdleTimer", true));
    15.     bootstrap.setOption("child.tcpNoDelay", true);
    16.     bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
    17.         @Override
    18.         public ChannelPipeline getPipeline() {
    19.             NettyCodecAdapter adapter = new NettyCodecAdapter(getCodec(), getUrl(), NettyServer.this);
    20.             ChannelPipeline pipeline = Channels.pipeline();
    21.             /*int idleTimeout = getIdleTimeout();
    22.                 if (idleTimeout > 10000) {
    23.                     pipeline.addLast("timer", new IdleStateHandler(timer, idleTimeout / 1000, 0, 0));
    24.                 }*/
    25.             pipeline.addLast("decoder", adapter.getDecoder());
    26.             pipeline.addLast("encoder", adapter.getEncoder());
    27.             pipeline.addLast("handler", nettyHandler);
    28.             return pipeline;
    29.         }
    30.     });
    31.     // bind
    32.     channel = bootstrap.bind(getBindAddress());
    33. }