mina IoBuffer 常用方法

 

Limit(int)

如果position>limit, position = limit,如果mark>limit, 重置mark

Mark()

取当前的position的快照标记mark

Reset()

恢复position到先前标记的mark

Clear()

limit=capacity , position=0,重置mark,但是不清空数据,为了从头开始put做准备,其实就是清空数据,因为你put就覆盖了原来的数据

Rewind()

position=0,重置mark,一系列写操作后,为了从头开始get做准备,和clear()有用途上的区别,他大部分是用来从头开始读取,而clear是大部分用来重头开始填充,就是清理的意思

Flip()

limit=position , position=0,重置mask,为了将buf写出做好准备,一般是结束buf操作,将buf写入输出流时调用,这个必须要调用,否则极有可能position!=limit,导致position后面没有数据,每次写入数据到输出流时,必须确保position=limit。

Remaining()

返回limit-position,返回缓冲器中的剩余字节

Wrap(byte[])

组装到新的buffer,capacity=limit=byte[].length,position=0 重置mark

Slice()

分割缓冲器,将remaining的空间形成一个新的buffer,新的position=0,limit=capacity=remaining,重置mark,和主缓冲区内容共享,其它都独立

Duplicate()

缓冲区,内容共享,其它都独立

asReadOnlyBuffer()

和duplicate一样,只是不可写

Compact()

将position和limit之间的字节移到最前面,position=limit-position,这就是这里的压缩的意思,一般是结束buf操作,将buf写入输出流时调用

Position(int)

position=newPosition,如果position<mark,重置mark

Remaining()

返回position和limit之间的字节数

IoBuffer

IoBuffer是MINA内部使用的一个byte buffer,MINA并没有直接使用NIO 的ByteBuffer。不过IoBuffer 是对 ByteBuffer 的一个封装。IoBuffer 中的很多方法都是对 ByteBuffer 的直接继承。只是对 ByteBuffer 添加了一些扩展了更加实用的方法。

基本用法

由于IoBuffer是对Nio的ByteBuffer 的封装,所以基本概念还是相同的,下面简单介绍一下:

1、capacity:该属性描述这个缓冲区最多能缓冲多少个元素,也是Buffer最大存储元素数,这个值是在创建Buffer的时候指定的,且不能修改。

2、Limit:在从Buffer中向Channel中写数据时,limit变量指示了还剩多少数据可以读取,在从Channel中读取数据到Buffer中时,limit变量指示了还剩多少空间可供存放数据。position正常情况下小于或者等于limit。

3、Position:Buffer实际上也就是个array。当你从Channel中读数据时,你把从Channel中读出来的数据放进底层array,position变量用来跟踪截止目前为止已经写了多少数据。更精确的讲,它指示如果下次写Buffer时数据应该进入array的哪个位置。因此如果已经从Channel中读出了3个字节,Buffer的position会被置为3,指向array中第四个位置。

4、Mark:一个可以记忆的Position位置的值,在调用reset()方法时会将缓冲区的Position重置为该索引,并非总是需要定义Mark,但是在定义Mark时,不能将其定义为负数,并且不能让它大于Position,如果定义了Mark,则在该Position或Limit调整为小于该Mark值时,该Mark将被丢弃。

下面通过一个例子来说明:

i、初始状态下:

此时position为0,limit和capacity都被设为9;

ii、从Channel中读入4个字节数据到Buffer,这时position指向4(第5个):

iii、在做写操作之前,我们必须调用一次flip()方法,这个方法做了两件重要的事情: 
1. 将limit设置到当前的position处。 
2. 设置position为0。

iiii、执行写操作后;

iv、执行clear后,position设为0,limit设为capition,mark则丢弃;

因为IoBuffer是一个抽象类,不能直接实例化,所有使用的时候需要调用allocate方法来进行内存分配;

allocate有两种定义:

   1: // Allocates a new buffer with a specific size, defining its type (direct or heap)
   2: public static IoBuffer allocate(int capacity, boolean direct)
   3:  
   4: // Allocates a new buffer with a specific size
   5: public static IoBuffer allocate(int capacity)

这里:

capacity:buffer的大小;

direct:如果为true,则得到direct buffer,如果为false,则得到heap buffer

direct buffer和heap buffer的区别分析:

Direct Buffer不是分配在堆上的,它不被GC直接管理(但Direct Buffer的JAVA对象是归GC管理的,只要GC回收了它的JAVA对象,操作系统才会释放Direct Buffer所申请的空间),它似乎给人感觉是“内核缓冲区(buffer in kernel)”。Heap Buffer则是分配在堆上的,或者我们可以简单理解为Heap Buffer就是byte[]数组的一种封装形式。当我们把一个Heap Buffer写入Channel的时候,实际上底层实现会先构建一个临时的Direct Buffer,然后把Heap Buffer的内容复制到这个临时的Direct Buffer上,再把这个Direct Buffer写出去。因此把一个Direct Buffer写入一个Channel的速度要比把一个Heap Buffer写入一个Channel的速度要快。但是Direct Buffer创建和销毁的代价很高,所以要用在尽可能重用的地方。

public static IoBuffer allocate(int capacity)的用法:
   1: // 设置Allocates分配的默认类型,这里设为heap buffer.
   2:  IoBuffer.setUseDirectBuffer(false);
   3:  // 返回一个新的heap buffer.
   4:  IoBuffer buf = IoBuffer.allocate(1024);

IoBuffer允许生成一个自动扩展的buffer(这也是没有选择使用NIO的ByteBuffer的原因之一);通过设置AutoExpand属性即可:

   1: IoBuffer buffer = IoBuffer.allocate(8);
   2: buffer.setAutoExpand(true);
   3:  
   4: buffer.putString("12345678", encoder);
   5:        
   6: // Add more to this buffer
   7: buffer.put((byte)10);

最新文章

  1. javascript (2)
  2. *HDU2147 博弈
  3. Virtualbox虚拟机配置CentOS7.0静态网络
  4. 第一个structs+spring+hibernate的web程序
  5. PHP-数组函数
  6. Chapter 1: A Simple Web Server
  7. Just Have a Change
  8. Head First设计模式-观察者模式
  9. ECMA5.1中Object.seal()和Object.freeze()的区别
  10. [RxJS] Sharing Streams with Share
  11. .net 中文显示乱码问题(Chinese display with messy code)
  12. 为大型数据文件每行只能产生id
  13. XTU 1252 Defense Tower
  14. rinetd 一个linux下的端口转发工具
  15. Linux下部署多个Tomcat(完整)
  16. [转]Eclipse下开发Struts奇怪异常:org.apache.struts.taglib.bean.CookieTei
  17. PHP 中 var_export、print_r、var_dump 调试中的区别
  18. java实验三——求平均数,数组排序(有关java保留小数位数,由于编译器版本未到1.5导致的报错format函数第二个参数不对,要求是Object[])
  19. 《绝地求生大逃杀》BE错误怎么办 BE服务未正常运行及安装失败解决方法
  20. docker搭建gitbook服务

热门文章

  1. 11,SFDC 管理员篇 - 报表和数据的可视化
  2. (分享)多功能 PDF转换器v3.0版本
  3. ubuntu修改设备名称
  4. Spring概念
  5. java 平台 权限管理
  6. Salt 安装方式(CentOS)
  7. Foundation -----&gt;NSArray
  8. Eclipse 4.2 (Juno) &#39;Cannot create a server using the selected type&#39; in Tomcat 7 - Stack Overflow.html
  9. Redis配置文件参数说明
  10. asp.net core 阿里云消息服务(Message Service,原MQS)发送接口的实现