Java网络编程从入门到精通(34):读写缓冲区中的数据---使用get和put方法按顺序读写单个数据

简介: 本文为原创,如需转载,请注明作者和出处,谢谢! 上一篇:Java网络编程从入门到精通(33):非阻塞I/O的缓冲区(Buffer)     对于缓冲区来说,最重要的操作就是读写操作。

本文为原创,如需转载,请注明作者和出处,谢谢!

上一篇:Java网络编程从入门到精通(33):非阻塞I/O的缓冲区(Buffer)

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

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

ByteBuffer byteBuffer  =  ByteBuffer.allocate( 6 );

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

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

public   final   int  position()
public   final  Buffer position( int  newPosition)

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

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

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

ByteBuffer类的getput方法:

public   abstract   byte  get()            
public   abstract  ByteBuffer put( byte  b)

IntBuffer类的getput方法:

public   abstract   int  get()            
public   abstract  IntBuffer put( int  i)

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

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

图1 缓冲区的初始状态

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

 

byteBuffer.put(( byte ) 2 );
byteBuffer.put((
byte ) - 1 );

图2  缓冲区的当前状态

 

当缓冲区的当前位置如图3所示时,使用putget方法将会抛出上述的BufferOverflowException异常。

图3  当前位置处于缓冲区尾

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

byteBuffer.position( 2 );
System.out.println(byteBuffer.get());

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

public   final  Buffer rewind()

在图2所示的缓冲区状态下调用rewind方法,就会得到如图4的缓冲区状态。

图4  调用rewind方法后的缓冲区状态

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

System.out.println(byteBuffer.get());

缓冲区的状态将如图5所示。

图5  调用get方法后的缓冲区状态

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


public   final   int  limit()
public   final  Buffer limit( int  newLimit)

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

图6  将limit设为2的缓冲区状态

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

while (byteBuffer.position()  <  byteBuffer.limit())
    System.out.println(byteBuffer.get());

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


public   final  Buffer flip()
public   final   boolean  hasRemaining()

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

while (byteBuffer.hasRemaining())
    System.out.println(byteBuffer.get());

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

为了回顾上面所讲内容,下面的代码总结了创建缓冲区、读写缓冲区中的数据、设置缓冲区的limitposition的方法。

   package net;
  
  
import  java.nio. * ;
  
  
public   class  GetPutData
  {
      
public   static   void  main(String[] args)
      {
          
//  创建缓冲区的四种方式
          IntBuffer intBuffer  =  IntBuffer.allocate( 10 );
          ByteBuffer byteBuffer 
=  ByteBuffer.allocateDirect( 10 );
          CharBuffer charBuffer 
=  CharBuffer.wrap( " abcdefg " );
          DoubleBuffer doubleBuffer 
=  DoubleBuffer.wrap( new   double [] {  1.1 2.2  });
          
          
//  向缓冲区中写入数据
          intBuffer.put( 1000 );
          intBuffer.put(
2000 );
          
          System.out.println(
" intBuffer的当前位置: "   +  intBuffer.position());
          
          intBuffer.position(
1 );   //  将缓冲区的当前位置设为1
          System.out.println(intBuffer.get());   //  输出缓冲区的当前数据
          
          intBuffer.rewind();  
//  将缓冲区的当前位置设为0
          System.out.println(intBuffer.get());   //  输出缓冲区的当前数据
          
          byteBuffer.put((
byte ) 20 );
          byteBuffer.put((
byte ) 33 );
          byteBuffer.flip();   
//  将limit设为position,在这里是2
          byteBuffer.rewind(); 
          
while (byteBuffer.hasRemaining())   //  枚举byteBuffer中的数据
              System.out.print(byteBuffer.get()  +   "   " );
          
          
while (charBuffer.hasRemaining())   //  枚举charBuffer中的数据
              System.out.print(charBuffer.get()  +   "   " );
  
          
//  枚举doubleBuffer中的数据
           while (doubleBuffer.position()  <  doubleBuffer.limit())
              System.out.print(doubleBuffer.get() 
+   "   " );
  
      }
  }

运行结果:  

intBuffer的当前位置: 2
2000
1000
20   33  a b c d e f g  1.1   2.2

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

while (byteBuffer.position()  <  byteBuffer.capacity())
    System.out.println(byteBuffer.get());

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



国内最棒的Google Android技术社区(eoeandroid),欢迎访问!

《银河系列原创教程》发布

《Java Web开发速学宝典》出版,欢迎定购

目录
相关文章
|
3月前
|
存储 Oracle Java
java零基础学习者入门课程
本课程为Java零基础入门教程,涵盖环境搭建、变量、运算符、条件循环、数组及面向对象基础,每讲配示例代码与实践建议,助你循序渐进掌握核心知识,轻松迈入Java编程世界。
368 0
|
3月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
234 1
|
3月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
248 1
|
4月前
|
Java
java入门代码示例
本文介绍Java入门基础,包含Hello World、变量类型、条件判断、循环及方法定义等核心语法示例,帮助初学者快速掌握Java编程基本结构与逻辑。
456 0
|
4月前
|
Java API 数据库
2025 年最新 Java 实操学习路线,从入门到高级应用详细指南
2025年Java最新实操学习路线,涵盖从环境搭建到微服务、容器化部署的全流程实战内容,助你掌握Java 21核心特性、Spring Boot 3.2开发、云原生与微服务架构,提升企业级项目开发能力,适合从入门到高级应用的学习需求。
1380 0
|
4月前
|
前端开发 Java 数据库连接
帮助新手快速上手的 JAVA 学习路线最详细版涵盖从入门到进阶的 JAVA 学习路线
本Java学习路线涵盖从基础语法、面向对象、异常处理到高级框架、微服务、JVM调优等内容,适合新手入门到进阶,助力掌握企业级开发技能,快速成为合格Java开发者。
661 3
|
4月前
|
监控 Java API
2025 年全新出炉的 Java 学习路线:从入门起步到实操精通的详细指南
2025年Java学习路线与实操指南,涵盖Java 21核心特性、虚拟线程、Spring Boot 3、微服务、Spring Security、容器化部署等前沿技术,助你从入门到企业级开发进阶。
970 0
|
4月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
Java 数据库 Spring
203 0
|
4月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
372 16