zl程序教程

您现在的位置是:首页 >  其它

当前栏目

ByteBuf用法

用法 ByteBuf
2023-06-13 09:13:40 时间

大家好,又见面了,我是你们的朋友全栈君。

JDK NIO之ByteBuffer的局限性如下: (1)长度固定,一旦分配完成,它的容量将不能动态扩展和收缩,而需要编码的POJO对象大雨ByteBuffer的容量时,会发生索引越界异常; (2)只有一个标识位置的指针position,读写的是偶需要搜公条用flip()和rewind()等,使用着必须小心的处理这些API,否则很容易导致程序越界异常; (3)ByteBuffer的API功能有限,一些高级和实用扽特性不支持,需要使用者自己编程实现、 为了弥补这些不足,Netty提供了自己的缓冲区实现ByteBuf。

ByteBuf通过两个位置指针来协助缓冲的读写操作:读指针:readerIndex和写指针writerIndex

ByteBuf可以分为两类:

(1)对内存:HeapByteBuf自己缓冲区,特点是内存的分配和回收速度快,可以被JVM自动回收,,缺点是如果使用Socket的IO读写,需要额外做一次内存复制,将堆内存对应的额缓冲区复制到内核Channel中,性能会有一定的下降。

(2)直接内存。DirectByteBuf字节缓冲区也可以叫做直接缓冲区,非堆内存。它在堆外进行内存分配,相比于堆内存,它的分配和回收速度会慢一些。但是将它写入或者从SocketChannel中读取时,由于少了一次内存复制。速度比堆内存要快。

因此Netty提供了多种ByteBuf 的实现共开发者选择。在长期的开发实践中,表明,在IO通信线程的读写缓冲区使用DirectByteBuf, 后端业务消息的编解码模块使用HeapByteBuf,这样组合可以达到性能最优。

1、readerIndex、writerIndex 读写索引

 //初始化ByteBuf,读写索引都为0;
ByteBuf buf = Unpooled.buffer(10);//非池化10字节大小的ByteBuf
System.out.println(buf.toString());//UnpooledHeapByteBuf(ridx: 0, widx: 0, cap: 10)
System.out.println( Arrays.toString(buf.array()));//[0, 0, 0, 0, 0, 0, 0, 0, 0, 0]
//写入5个字节的数组,写索引变为5;
byte[] bytes = {1,2,3,4,5};
buf.writeBytes(bytes);
System.out.println(buf.toString());//UnpooledHeapByteBuf(ridx: 0, widx: 5, cap: 10)
System.out.println(Arrays.toString(buf.array()));//[1, 2, 3, 4, 5, 0, 0, 0, 0, 0]
//读取两个字节,写索引为5,读索引2
byte b1 = buf.readByte();
byte b2 = buf.readByte();
System.out.println(Arrays.toString(new byte[]{b1,b2}));
System.out.println(buf.toString());//UnpooledHeapByteBuf(ridx: 2, widx: 5, cap: 10)
System.out.println(Arrays.toString(buf.array()));//[1, 2, 3, 4, 5, 0, 0, 0, 0, 0]
//将读取的内容丢弃后,读索引0,写索引(5-2)=3
buf.discardReadBytes();//将读取的内容丢弃
System.out.println(buf.toString());//UnpooledHeapByteBuf(ridx: 0, widx: 3, cap: 10)
System.out.println(Arrays.toString(buf.array()));//[3, 4, 5, 4, 5, 0, 0, 0, 0, 0]
System.out.println(buf.readableBytes());//返回可读字节的个数;  3
System.out.println(buf.writableBytes());//返回可写字节的个数;  7
//清空读写指针,读写指针都为0,clear并不会清空缓冲区内容本身,主要用来操作指针;
buf.clear();
System.out.println(buf.toString());//UnpooledHeapByteBuf(ridx: 0, widx: 0, cap: 10)
System.out.println(Arrays.toString(buf.array()));//[3, 4, 5, 4, 5, 0, 0, 0, 0, 0]
//再次写入一段内容
byte[] bytes2 = {1,2,3};
buf.writeBytes(bytes2);
buf.readByte();
System.out.println(Arrays.toString(bytes2));
System.out.println(buf.toString());//UnpooledHeapByteBuf(ridx: 1, widx: 3, cap: 10)
System.out.println(Arrays.toString(buf.array()));//[1, 2, 3, 4, 5, 0, 0, 0, 0, 0]
// 将ByteBuf清零,读写索引都不变
buf.setZero(0,buf.capacity());
System.out.println(buf.toString());//UnpooledHeapByteBuf(ridx: 1, widx: 3, cap: 10)
System.out.println(Arrays.toString(buf.array()));//[0, 0, 0, 0, 0, 0, 0, 0, 0, 0]
Charset utf8 = Charset.forName("UTF-8");
ByteBuf buf1 = Unpooled.copiedBuffer("Netty in Action rocks!", utf8);
ByteBuf sliced = buf1.slice(0, 14);
ByteBuf copy = buf1.copy(0, 14);
System.out.println(buf1.toString(utf8));//Netty in Action rocks!
System.out.println("是否支持访问数组:"+buf1.hasArray());//false  访问非堆缓冲区ByteBuf的数组会导致UnsupportedOperationException,因此下面的访问方式会报错
//System.out.println(Arrays.toString(buf1.array()));
System.out.println(sliced.toString(utf8));//Netty in Actio
//System.out.println(Arrays.toString(sliced.array()));
System.out.println(copy.toString(utf8));//Netty in Actio
//System.out.println(Arrays.toString(copy.array()));
buf1.setByte(0, (byte)'J');//get和set操作读写指定索引的数据,而不会改变索引值。read和write操作读写指定索引数据,并且会改变索引的值
System.out.println(buf1.toString(utf8));//Jetty in Action rocks!
//由于数据是共享的,对一个ByteBuf的修改对原始的ByteBuf是可见的
System.out.println(sliced.toString(utf8));//Jetty in Actio
//copy方法会重新分配新的ByteBuf,对其的修改对原始的ByteBuf不可见。
System.out.println(copy.toString(utf8));//Netty in Actio
System.out.println(buf1.getByte(0)==sliced.getByte(0));//true
System.out.println(buf1.getByte(0)==copy.getByte(0));//false

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/191884.html原文链接:https://javaforall.cn