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(2048);
    14.             //设置内存池等待分配内存的最大阻塞时间，默认是1秒
    15.             aioServerConfig.setChunkPoolBlockTime(1000);
    16.             //设置SocketOptions
    17.             aioServerConfig.setOption(StandardSocketOptions.SO_RCVBUF, 8192);
    19.             server.socketChannel(SocketChannel.TCP).channelInitializer(new ChannelInitializer() {
    20.                 @Override
    21.                 public void initChannel(AioChannel channel) throws Exception {
    22.                     //获取责任链对象
    23.                     DefaultChannelPipeline defaultChannelPipeline = channel.getDefaultChannelPipeline();
    25.                     //获取证书
    26.                     String pkPath = ResourceUtils.getURL("classpath:serverStore.jks")
    27.                             .getPath();
    28.                     //ssl配置
    29.                     SslConfig sSLConfig = new SslConfig();
    30.                     sSLConfig.setKeyFile(pkPath);
    31.                     sSLConfig.setKeyPassword("123456");
    32.                     sSLConfig.setKeystorePassword("123456");
    33.                     sSLConfig.setTrustFile(pkPath);
    34.                     sSLConfig.setTrustPassword("123456");
    35.                     //设置服务器模式
    36.                     sSLConfig.setClientMode(false);
    37.                     sSLConfig.setClientAuth(ClientAuth.NONE);
    38.                     //初始化ssl服务
    39.                     SslService sslService = new SslService(sSLConfig, "TLSv1.2");
    40.                     //注意，只要使用ssl。都需要把ssl编解码器放到责任链最前面
    41.                     defaultChannelPipeline.addFirst(new SslHandler(channel, sslService));
    42.                     //紧跟着把ws的编解码器添加到责任链前面。注意，只有先通过ws的编解码器，才能解析ws的消息帧，
    43.                     //后续的解码器才能继续解析期望得到的结果
    44.                     defaultChannelPipeline.addLast(new WebSocketEncoder());
    45.                     defaultChannelPipeline.addLast(new WebSocketDecoder());
    47.                     defaultChannelPipeline.addLast(new StringDecoder());
    48.                     //添加自定义的简单消息处理器
    49.                     defaultChannelPipeline.addLast(new SimpleHandler());
    50.                 }
    51.             }).start();
    52.             System.out.println("启动ws服务");
    53.         } catch (Exception e) {