class myInitListener implements ChannelInitListener
{
    
    // 当通道被建立的时候触发
    @Override
    public void channelInit(ServerChannelInfo serverChannelInfo)
    {
        // 可以设置通道的读取超时时长。默认为3000毫秒
        serverChannelInfo.setReadTimeout(3000);
        // 可以设置通道无数据的读取等待时长。默认为30分钟
        serverChannelInfo.setWaitTimeout(1000 * 60 * 30);
        // 设置数据流的处理器，这步是最重要的，也是业务逻辑的所在。每一个通道的处理器都是通过这种方式新建而来。所以其中的数据都是针对该通道的
        serverChannelInfo.setHandlers(new DataHandler() {
            
            // 这样的数据都是只针对该通道的。因此这种结构很方便用来做登录拦截之类的
            private String loginName;
            
            // data是上一个处理器传递过来的数据，返回值是要给下一个处理器的数据。如果是最开头的处理器，则data就是包解码器解码出来的一个完整报文
            @Override
            public Object handle(Object data, InternalResult result) throws SocketException
            {
                ByteBuf<?> buf = (ByteBuf<?>) data;
                System.out.println("收到消息:"+buf.readString(Charset.forName("utf8")));
                buf.release();
                return "客户端你好，我收到消息了";
            }
        }, new DataHandler() {
            
            @Override
            public Object handle(Object data, InternalResult result) throws SocketException
            {
                // 这里的data就是上一个处理器返回的数据了。处理器之间的顺序就是在代码中他们初始化的顺序
                String value = (String) data;
                // 从内存缓存池中获取一个内存缓存区用来写出数据
                ByteBuf<?> buf = DirectByteBufPool.getInstance().get(100);
                buf.writeString(value, Charset.forName("utf8"));
                buf.writeByte((byte) '\r');
                buf.writeByte((byte) '\n');
                // 末尾的处理器一定要返回ByteBuf类型的数据。这样框架就会自动将这个数据通过socket发送出去
                return buf;
            }
        });
    }
    
}

public class BaseServerTest
{
    private Logger logger = ConsoleLogFactory.getLogger(ConsoleLogFactory.DEBUG);
    
    @Test
    public void test() throws IOException, InterruptedException, ExecutionException, SocketException
    {
        ServerConfig config = new ServerConfig();
        // 服务端监听的端口
        config.setPort(80);
        config.setInitListeners(new myInitListener());
        // 设置包解码器。包解码器用来从tcp的数据流中截取出一个完整的tcp报文
        // 这个解码器是行解码器。使用换行符进行报文切割
        // 当然，开发者也可以根据自己的业务需求，自行定制包解码器。框架本身提供了4种最为常见的包解码器。
        config.setFrameDecodec(new LineBasedFrameDecodec(1000));
        // 使用上面的配置新建一个服务端对象
        AioServer aioServer = new AioServer(config);
        // 启动服务端
        aioServer.start();
        AioClient aioClient = new FutureClient();
        aioClient.setAddress("127.0.0.1").setPort(80);
        aioClient.setFrameDecodec(new LineBasedFrameDecodec(100));
        aioClient.setWriteHandlers(new DataHandler() {
            
            @Override
            public Object handle(Object data, InternalResult result) throws SocketException
            {
                String value = (String) data;
                ByteBuf<?> buf = DirectByteBufPool.getInstance().get(100);
                buf.writeString(value, Charset.forName("utf8"));
                buf.writeByte((byte) '\r');
                buf.writeByte((byte) '\n');
                return buf;
            }
        });
        aioClient.setReadHandlers(new DataHandler() {
            
            @Override
            public Object handle(Object data, InternalResult result) throws SocketException
            {
                ByteBuf<?> buf = (ByteBuf<?>) data;
                String value = buf.readString(Charset.forName("utf8"));
                buf.release();
                return value;
            }
        });
        // 使用对应的参数链接服务端
        aioClient.connect();
		//返回一个future实现。在收到消息后
        Future<?> future = aioClient.write("你好，这里是客户端");
        System.out.println(future.get());
        // 服务端关闭
        aioServer.stop();
    }
}