Unpooled和ByteBuf

墨蓝 2022-09-05 14:51 132阅读 0赞

ByteBuf是Netty的数据容器对象；

Unpooled是操作数据容器的工具类；

package com.tech.netty.buf;
    
    import io.netty.buffer.ByteBuf;
    import io.netty.buffer.Unpooled;
    
    /**
     * @author lw
     * @since 2021/8/18
     */
    public class NettyByteBuf {
        public static void main(String[] args) {
            // 创建一个ByteBuf
            //说明
            // 1. 创建对象 该对象包含一个数组arr 是一个byte[10]
            // 2. 在Netty的buffer中，不需要使用flip进行反转
            // 3. readerIndex 下一个读取的位置 writerIndex 下一个写入的位置
            // 0--readerIndex 已读取的范围
            // readerIndex--writerIndex 可读取的范围
            // writerIndex--capacity 可写入的范围
            ByteBuf buffer = Unpooled.buffer(10);
            for(int i=0;i<10;i++){
                buffer.writeByte(i);
            }
            System.out.println("buffer capacity="+buffer.capacity());
    //        for(int i=0;i<buffer.capacity();i++){
    //            System.out.println(buffer.getByte(i));
    //        }
            for(int i=0;i<buffer.capacity();i++){
                System.out.println(buffer.readByte());
            }
            System.out.println("执行结束");
        }
    }

package com.tech.netty.buf;
    
    import io.netty.buffer.ByteBuf;
    import io.netty.buffer.Unpooled;
    
    import java.nio.charset.Charset;
    
    /**
     * @author lw
     * @since 2021/8/18
     */
    public class NettyBuffer {
        public static void main(String[] args) {
            ByteBuf buffer = Unpooled.copiedBuffer("hello,word!", Charset.forName("utf-8"));
            if(buffer.hasArray()){
                byte[] array = buffer.array();
                System.out.println(new String(array,Charset.forName("utf-8")));
                System.out.println("byteBuf="+buffer);
                System.out.println(buffer.arrayOffset());
                System.out.println(buffer.readerIndex());
                System.out.println(buffer.writerIndex());
                System.out.println(buffer.capacity());
    
    //            System.out.println(buffer.readByte());
                System.out.println(buffer.getByte(0));
    
                int len=buffer.readableBytes(); //可读的字节数
                System.out.println("len="+len);
    
                for(int i=0;i<len;i++){
                    System.out.println((char)buffer.getByte(i));
                }
    
                System.out.println(buffer.getCharSequence(0,4,Charset.forName("utf-8")));
                System.out.println(buffer.getCharSequence(4,1,Charset.forName("utf-8")));
                System.out.println("执行结束");
            }
    
        }
    
    
    
    }