netty学习笔记

Server:

bootstrap.option(ChannelOption.SO_BACKLOG,100)

 

private final ByteBuf firstMessage;

firstMessage = Unpooled.buffer(EchoClient.SIZE);

       for(int i = 0; i<sendNumber; i++){

           firstMessage.writeByte((byte)i);

       }

 

Server:

// 以(" ")为结尾分割的 解码器

       pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));

       // 字符串解码和编码

       pipeline.addLast("decoder", new StringDecoder());

       pipeline.addLast("encoder", new StringEncoder());

      

       //自己的逻辑Handler

       pipeline.addLast("handler", new HelloServerHandler());

 

Client:

/*

       * 这个地方的 必须和服务端对应上。否则无法正常解码和编码

       */

      pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));

      pipeline.addLast("decoder", new StringDecoder());

      pipeline.addLast("encoder", new StringEncoder());

     

      pipeline.addLast("handler", new HelloClientHandler());

 

ByteBuf与java的ByteBuffer类似，Byte数组的缓冲区。

ByteBufAllocator,字节缓冲区分配器

Future 获取异步操作的结果，异步操作的通知回调。

Promise是可写的Future