最简单的服务器端启动

    1. AioServerStarter server = new AioServerStarter(5555);
    2. server.channelInitializer(new ChannelInitializer() {
    3. @Override
    4. public void initChannel(AioChannel channel) throws Exception {
    5. //获取责任链对象
    6. DefaultChannelPipeline defaultChannelPipeline = channel.getDefaultChannelPipeline();
    7. //添加 分隔符字符串处理器 按 "\r\n\" 进行消息分割
    8. defaultChannelPipeline.addLast(new DelimiterFrameDecoder(DelimiterFrameDecoder.lineDelimiter));
    9. //添加字符串解码器
    10. defaultChannelPipeline.addLast(new StringDecoder());
    11. //添加自定义的简单消息处理器
    12. defaultChannelPipeline.addLast(new SimpleHandler());
    13. }
    14. }).start();

    通过配置启动服务器端

    1. //初始化配置对象
    2. AioServerConfig aioServerConfig = new AioServerConfig();
    3. //设置host,不设置默认localhost
    4. aioServerConfig.setHost("127.0.0.1");
    5. //设置端口号
    6. aioServerConfig.setPort(8888);
    7. //设置服务器端内存池最大可分配空间大小,默认256mb,内存池空间可以根据吞吐量设置。
    8. // 尽量可以设置大一点,因为这不会真正的占用系统内存,只有真正使用时才会分配
    9. aioServerConfig.setServerChunkSize(512 * 1024 * 1024);
    10. //设置数据输出器队列大小,一般不用设置这个参数,默认是10*1024*1024
    11. aioServerConfig.setBufferWriterQueueSize(10*1024*1024);
    12. //设置读取缓存块大小,一般不用设置这个参数,默认128字节
    13. aioServerConfig.setReadBufferSize(128);
    14. //设置内存池等待分配内存的最大阻塞时间,默认是1秒
    15. aioServerConfig.setChunkPoolBlockTime(1000);
    16. //设置SocketOptions
    17. aioServerConfig.setOption(StandardSocketOptions.SO_RCVBUF,8192);
    18. AioServerStarter server = new AioServerStarter(aioServerConfig);
    19. server.channelInitializer(new ChannelInitializer() {
    20. @Override
    21. public void initChannel(AioChannel channel) throws Exception {
    22. //获取责任链对象
    23. DefaultChannelPipeline defaultChannelPipeline = channel.getDefaultChannelPipeline();
    24. //添加 分隔符字符串处理器 按 "\r\n\" 进行消息分割
    25. defaultChannelPipeline.addLast(new DelimiterFrameDecoder(DelimiterFrameDecoder.lineDelimiter));
    26. //添加字符串解码器
    27. defaultChannelPipeline.addLast(new StringDecoder());
    28. //添加自定义的简单消息处理器
    29. defaultChannelPipeline.addLast(new SimpleHandler());
    30. }
    31. }).start();