客户端启动 

    1.    AioClientStarter client = new AioClientStarter("127.0.0.1",8888);
    2.         client.channelInitializer(new ChannelInitializer() {
    3.             @Override
    4.             public void initChannel(AioChannel channel) throws Exception {
    5.                 //责任链
    6.                 DefaultChannelPipeline defaultChannelPipeline = channel.getDefaultChannelPipeline();
    8.                 //指定结束符解码器
    9.                 defaultChannelPipeline.addLast(new DelimiterFrameDecoder(DelimiterFrameDecoder.lineDelimiter));
    10.                 //字符串解码器
    11.                 defaultChannelPipeline.addLast(new StringDecoder());
    12.                 //定义消息解码器
    13.                 defaultChannelPipeline.addLast(new SimpleHandler());
    14.             }
    15.         });
    17.         try {
    18.             client.start();
    19.         } catch (Exception e) {
    20.             e.printStackTrace();
    21.         }

    通过配置启动 

    1.    //实例化客户端配置
    2.         AioClientConfig aioConfig = new AioClientConfig();
    3.         //设置远程地址
    4.         aioConfig.setHost("127.0.0.1");
    5.         //设置远程端口
    6.         aioConfig.setPort(8888);
    7.         //设置客户端端内存池最大可分配空间大小，默认256mb，内存池空间可以根据吞吐量设置。
    8.         aioConfig.setClientChunkSize(512 * 1024 * 1024);
    9.         //设置数据输出器队列大小，一般不用设置这个参数，默认是10*1024*1024
    10.         aioConfig.setBufferWriterQueueSize(2 * 1024 * 1024);
    11.         //设置读取缓存块大小，一般不用设置这个参数，默认128字节
    12.         aioConfig.setReadBufferSize(128);
    13.         //设置内存池等待分配内存的最大阻塞时间，默认是1秒
    14.         aioConfig.setChunkPoolBlockTime(1000);
    15.         //设置SocketOptions
    16.         aioConfig.setOption(StandardSocketOptions.SO_RCVBUF,8192);
    18.         AioClientStarter client = new AioClientStarter(aioConfig);
    19.         client.channelInitializer(new ChannelInitializer() {
    20.             @Override
    21.             public void initChannel(AioChannel channel) throws Exception {
    22.                 //责任链
    23.                 DefaultChannelPipeline defaultChannelPipeline = channel.getDefaultChannelPipeline();
    25.                 //指定结束符解码器
    26.                 defaultChannelPipeline.addLast(new DelimiterFrameDecoder(DelimiterFrameDecoder.lineDelimiter));
    27.                 //字符串解码器
    28.                 defaultChannelPipeline.addLast(new StringDecoder());
    29.                 //定义消息解码器
    30.                 defaultChannelPipeline.addLast(new SimpleHandler());
    31.             }
    32.         });
    34.         try {
    35.             client.start();
    36.         } catch (Exception e) {
    37.             e.printStackTrace();
    38.         }