ServerUDPChannelFactory.java 文件源码

protected static Channel createAcceptorChannel(
          final ChannelType channelType,
          final InetSocketAddress localAddress,
          final ServerUDPHandler serverHandler
  ) {
      final Bootstrap serverBootstrap = ServerUDPBootstrapFactory.createServerBootstrap(channelType);

      serverBootstrap
              .option(ChannelOption.SO_REUSEADDR, false)


            .handler(new ChannelInitializer<DatagramChannel>() {
                  @Override
                  protected void initChannel(final DatagramChannel ch) throws Exception {
                      final ChannelPipeline pipeline = ch.pipeline();
                     //pipeline.addLast("readTimeoutHandler", new ReadTimeoutHandler(60));
                      pipeline.addLast("messageDecoder", serverHandler);
                      //pipeline.addLast("handler", serverHandler);
                  }
              });

      try {

          ChannelFuture channelFuture = serverBootstrap.bind(
                  new InetSocketAddress(localAddress.getPort())).sync();

          //channelFuture.channel().closeFuture().awaitUninterruptibly();//.awaitUninterruptibly();
          channelFuture.awaitUninterruptibly();
          if (channelFuture.isSuccess()) {
              return channelFuture.channel();

          } else {

          }
      } catch (InterruptedException e) {

      }
return null;

  }