数据库

位置:IT落伍者 >> 数据库 >> 浏览文章

读写缓沖区中的数据


发布日期:2022年05月12日
 
读写缓沖区中的数据

对于缓沖区来说最重要的操作就是读写操作缓沖区提供了两种方法来读写缓沖区中的数据getput方法和array方法而getput方法可以有三种读写数据的方式按顺序读写单个数据在指定位置读写单个数据和读写数据块除了上述的几种读写数据的方法外CharBuffer类还提供了用于专门写字符串的put和append方法在本文及后面的文章中将分别介绍这些读写缓沖区的方法

虽然使用allocate方法创建的缓沖区并不是一次性地分配内存空间但我们可以从用户地角度将一个缓沖区想象成一个长度为capacity的数组当缓沖区创建后和数组一样缓沖区的大小(capacity值)将无法改变也无法访问缓沖区外的数据如下面的代码创建了一个大小为的字节缓沖区

ByteBuffer byteBuffer = ByteBufferallocate(

对于byteBuffer来说只能访问属于这个缓沖区的六个字节的数据如果超过了这个范围将抛出一个BufferOverflowException异常这是一个运行时错误因为这个错误只能在程序运行时被发现

既然缓沖区和数组类似那么缓沖区也应该象数组一样可以标识当前的位置缓沖区的position方法为我们提供了这个功能position方法有两种重载形式它们的定义如下

public final int position()

public final Buffer position(int newPosition)

第一个重载形式用来获取缓沖区的当前位置在创建缓沖区后position的初始值是也就是缓沖区第一个元素的位置当从缓沖区读取一个元素后position的值加我们从这一点可以看出position方法返回的位置就是当前可以读取的元素的位置position的取值范围从到capacity – 如果position的值等于capacity说明缓沖区当前已经没有数据可读了

position方法的第二个重载形式可以设置缓沖区的当前位置参数newPosition的取值范围是 <= newPosition < capacity如果newPosition的值超出这个范围position方法就会抛出一个IllegalArgumentException异常

在大多数情况下不需要直接控制缓沖区的位置缓沖区类提供的用于读写数据的方法可以自动地设置缓沖区的当前位置在缓沖区类中get和put方法用于读写缓沖区中的数据get和put方法的定义如下

ByteBuffer类的get和put方法

public abstract byte get()

public abstract ByteBuffer put(byte b)

IntBuffer类的get和put方法

public abstract int get()

public abstract IntBuffer put(int i)

其他五个缓沖区类中的get和put方法定义和上面的定义类似只是get方法返回相应的数据类型而put方法的参数是相应的数据类型并且返回值的类型是相应的缓沖区类

每当put方法向缓沖区写入一个数据后缓沖区的当前位置都会加如果缓沖区的当前位置已经等于capacity调用put方法就会抛出一个javanioBufferOverflowException异常在缓沖区未初赋值的区域将被填充使用get方法可以得到缓沖区当前位置的数据并使缓沖区的当前位置加和put方法一样在缓沖区当前位置等于capacity时使用get方法也会抛出javanioBufferOverflowException异常缓沖区的初始状态如图所示

缓沖区的初始状态

从图可以看出在缓沖区创建之初当前的位置和缓沖区中的数据都为当使用如下语句向缓沖区中写入数据后缓沖区当前状态如图所示

byteBufferput((byte)

byteBufferput((byte)

缓沖区的当前状态

当缓沖区的当前位置如图所示时使用put和get方法将会抛出上述的BufferOverflowException异常

当前位置处于缓沖区尾

如果要使用get方法得到缓沖区中的指定数据必须将缓沖区的当前位置移动到指定的位置我们可以使用position方法将当前位置移到缓沖区的任何位置如下面的代码将图所示的缓沖区的当前位置设为并用get方法获得位置的数据

byteBufferposition(

Systemoutprintln(byteBufferget())

上面的代码将输出缓沖区的当前位置为除了使用position方法也可以使用rewind方法将缓沖区的当前位置设为rewind方法的定义如下

public final Buffer rewind()

在图所示的缓沖区状态下调用rewind方法就会得到如图的缓沖区状态

调用rewind方法后的缓沖区状态

接下来让我们执行如下语句

Systemoutprintln(byteBufferget())

缓沖区的状态将如图所示

调用get方法后的缓沖区状态

缓沖区除了position和capacity外还提供了一个标识来限制缓沖区可访问的范围这个标识就是limitlimit和position一样在缓沖区类中也提供了两个重载方法用于获得和设置limit的值limit方法的定义如下

public final int limit()

public final Buffer limit(int newLimit)

在初始状态下缓沖区的limit和capacity值相同但limit和capacity的区别是limit可以通过limit方法进行设置而capacity在创建缓沖区时就已经指定了并且不能改变(在上面所讲的position方法的newPosition参数的取值范围时曾说是 <= newPosition < capacity其实严格地说应是 <= newPosition < limit)limit的其他性质和capacity一样如在图所示的缓沖区状态中将limit的值设为就变成了图所示的状态

将limit设为的缓沖区状态

在这时position的值等于limit就不能访问缓沖区的当前数据也就是说不能使用get和put方法否则将抛出BufferOverflowException异常由于使用allocate创建的缓沖区并不是一次性地分配内存空间因此可以将缓沖区的capacity设为很大的值M缓沖区过大可能在某些环境中会使系统性能降低(如在PDA或智能插秧机中)因此可以使用limit方法根据具体的情况来限定缓沖区的大小当然limit还可以表示缓沖区中实际的数据量这将在后面讲解下面的代码演示了如何使用limit方法来枚举缓沖区中的数据

while(byteBufferposition() < byteBufferlimit())

Systemoutprintln(byteBufferget())

我们还可以用flip和hasRemaining方法来重写上面的代码flip方法将limit设为缓沖区的当前位置当limit等于position时hasRemaining方法返回false而则返回true flip和hasRemaining方法的定义如下

public final Buffer flip()

public final boolean hasRemaining()

下面的代码演示了如何使用hasRemaining方法来枚举缓沖区中的数据

while(byteBufferhasRemaining())

Systemoutprintln(byteBufferget())

如果从缓沖区的第一个位置依次使用put方法向缓沖区写数据当写完数据后再使用flip方法这样limit的值就等于缓沖区中实际的数据量了在网络中传递数据时可以使用这种方法来设置数据的结束位置

为了回顾上面所讲内容下面的代码总结了创建缓沖区读写缓沖区中的数据设置缓沖区的limit和position的方法

package net;

import javanio*;

public class GetPutData

{

public static void main(String[] args)

{

// 创建缓沖区的四种方式

IntBuffer intBuffer = IntBufferallocate(

ByteBuffer byteBuffer = ByteBufferallocateDirect(

CharBuffer charBuffer = CharBufferwrap(abcdefg

DoubleBuffer doubleBuffer = DoubleBufferwrap(new double[] { })

// 向缓沖区中写入数据

intBufferput(

intBufferput(

Systemoutprintln(intBuffer的当前位置 + intBufferposition())

intBufferposition( // 将缓沖区的当前位置设为

Systemoutprintln(intBufferget()) // 输出缓沖区的当前数据

intBufferrewind() // 将缓沖区的当前位置设为

Systemoutprintln(intBufferget()) // 输出缓沖区的当前数据

byteBufferput((byte)

byteBufferput((byte)

byteBufferflip() // 将limit设为position在这里是

byteBufferrewind()

while(byteBufferhasRemaining()) // 枚举byteBuffer中的数据

Systemoutprint(byteBufferget() +

while(charBufferhasRemaining()) // 枚举charBuffer中的数据

Systemoutprint(charBufferget() +

// 枚举doubleBuffer中的数据

while(doubleBufferposition() < doubleBufferlimit())

Systemoutprint(doubleBufferget() +

}

}

运行结果

intBuffer的当前位置

a b c d e f g

注意如果必须使用缓沖区的大小来读取缓沖区的数据尽量不要使用capacity而要使用limit如尽量不要写成如下的代码

while(byteBufferposition() < byteBuffercapacity())

Systemoutprintln(byteBufferget())

这是因为当limit比capacity小时上面的代码将会抛出一个BufferUnderflowException异常

               

上一篇:专家讲解优化Derby数据库程序性能

下一篇:用DataGrid浏览数据相关实例