在进行数据传输的时候,往往需要使用到缓冲区,常用的缓冲区就是JDK NIO类库中提供的java.nio.Buffer,实现类如下:

在使用NIO编程时,最常用的是其中的ByteBuffer,本篇分析ByteBuffer内部的源码实现,顺序从父类Buffer入手,了解父类中基础API的实现,再到各个实现子类的实现。

Buffer

Buffer是存放一种特定的、原始的数据的容器。Buffer是一种特定原始类型元素的线性的有限序列集合,其核心的属性有capacity、limit、Position。

capacity:Buffer的容量,表示可以容纳的元素数量

limit:表示第一个不可以被读取或者写入的元素的位置

position:表示下一个被读取或者写入的位置

三者之间的关系如下:0<=position<=limit<=capacity

Buffer只有一个构造方法:

这个构造方式是protected的,也就是说只有在包内可以调用。构造方法中除了capacity、limit、position外还有一个mark参数,且校验了mark参数必须小于position。这个参数非常简单,用于标记position的当前位置,在进行读取写入之类的操作之后可以通过API重新将position重置到标记的位置,对应的API为:Buffer#mark()\Buffer#reset()

Buffer中一个比较重要的API是Buffer#flip

这个方法就是将limit设置到position位置,将position调整到0,将mark设置为-1。

为什么需要有这么一个方法调整位置呢?

这个主要和Buffer只有一个position作为游标相关,读写都是基于position的,所以在写操作完成之后需要进行读操作时,需要将limit设置为position标记有写到哪儿了,而将position 重新移到0,这样就可以读取到所有的写入数据。假设如果有两个游标分别表示读取和写入的位置,是否就可以不用这个API了呢?

Buffer中的代码都非常简单,主要就是自身属性信息的设置和返回,像返回position、返回limit信息等,展开细看。

ByteBuffer

ByteBuffer是Buffer的一个子类,是字节缓冲区。ByteBuffer在Buffer之上定义了6中操作:

  1. 通过当前位置和指定位置的方式读取和写入byte

  2. 通过get(byte[])的方式将ByteBuffer中的数据读取到byte[]中

  3. 通过put(byte[])的方式将连续大量的byte数据写入缓冲区

  4. 通过当前位置和指定位置的方式将其他类型的数据写入缓冲区或从缓冲区读取数据转换成特定类型

  5. 提供将ByteBuffer转换成其他类型的Buffer视图的方法,例如ByteBuffer#asCharBuffer

  6. 提供compact、duplicate、slice来执行一些对ByteBuffer的操作

ByteBuffer的构造方法如下:

提供了两个构造方法,相对于Buffer增加了一个byte数组和一个offset。byte数组用于存储数据,offset表示ByteBuffer背后实际用于存储的byte数据的其实位置。即你可以使用一个byte数据,从它的任何一个下标开始存储数据,而不一定是0。

当然,这两个方法都是protected的,也就是说实际我们“不能”通过这两个方法去构造我们需要的缓冲区。

那么当我们需要使用缓冲区的时候我们如何去构造一个呢?ByteBuffer提供了两个API:ByteBuffer#allocateDirect、ByteBuffer#allocate

ByteBuffer#allocateDirect分配一个DirectByteBuffer,即这个缓冲区是使用堆外内存的。

ByteBuffer#allocate在JVM堆上分配一块内存。

新分配的内存position都是0,limit为容量,初始内部填充的数据都为0。

除了通过allocate去创建ByteBuffer,还有一种方式是通过wrap来包装一个byte数组,这样就可以使用ByteBuffer的API来对byte数据进行操作。

因为byte数据本身在堆内,所以wrap的ByteBuffer也就是HeapByteBuffer。

offset和length将被作为ByteBuffer初始的position和limit。

allocate和wrap都是创建了“新”的ByteBuffer,这里新的含义是他们背后都有自己独立的byte数组用于存储数据。还有一类API,他们也创建ByteBuffer,但是它只是个视图,拥有自己的position、limit等属性,但是存储的byte数组是共享的:

  • ByteBuffer#slice:创建一个的ByteBuffer,内容是当前ByteBuffer的一个子序列,共享一个byte数组;两个ByteBuffer的position、limit、mark是独立的;新ByteBuffer的起始位置是原ByteBuffer的position位置

  • ByteBuffer#duplicate:“复制”一个ByteBuffer,共享存储的byte数据,拥有独立的capacity、limit、position、mark属性;如果当前ByteBuffer是DirectByteBuffer,那么新Buffer也是DirectByteBuffer,如果当前是HeapByteBuffer,那么新分配的也是HeapByteBuffer

ByteBuffer提供另外一类API来将自己转换成另一个类型的缓冲区:

  • ByteBuffer#asXXXBuffer:比如asLongBuffer创建一个新的LongBuffer,底层的存储还是共享当前的byte数组,同时拥有自己的position、limit、mark属性,新Buffer的position为0,limit和capacity为原Buffer除8,因为一个long类型占用8个byte;其他asXXXBuffer方法都类似

ByteBuffer中还有一类API是提供基于当前位置或者指定位置来读写数据的:

  • byte getByte()

  • byte getByte(int index)

  • int getInt()

  • int getInt(int index)

  • ...

这两种API的差异是没有参数的API会从当前position开始读取数据,之后会修改position位置。而通过传入index,会从index开始读取数据,不会变更position信息。所以如果只是要读取数据,并不希望更改Buffer本身的信息(position),应该使用带有参数的方法。

ByteBuffer的内容只有这么多,接着看它的子类实现,主要是HeapByteBuffer和DirectByteBuffer。

HeapByteBuffer

HeapByteBuffer顾名思义就是JVM堆上的字节缓冲区,他用于缓存数据的byte数组就是直接在堆内申请的。默认的构造方法直接就是new一个byte数组作为数据存储的缓冲区。

HeapByteBuffer非常简单,就是实现了ByteBuffer定义的各种put和get方法,没有什么好分析的。

DirectByteBuffer

DirectByteBuffer翻译过来就是直接的字节缓冲区,它是使用直接内存的,即不从JVM的堆上分配内存。

首先看DirectByteBuffer的一个内部类:Deallocator。从类名可以看出这个类应该是做“回收的”。

从代码看,Deallocator实现了Runnable接口,run方法内的实现就是通过unsafe释放内存。

结合Cleaner就能明白Cleaner是统一的接口,返回Cleaner来执行清楚操作,而真正的内存回收在Deallocator中执行。

接着看DirectByteBuffer的构造方法:

只有一个容量作为参数,而内存是直接通过unsafe分配的,可见内存是直接分配的,而不是在堆上申请的。另外这是一个受保护的方法,也就是说用户是不能直接调用的。

另外还有几个构造方法,可以直接通过内存地址来初始化,或者通过文件描述符来初始化(For memory-mapped buffers),通过已近存在的DirectBuffer来初始化。

这些方法都是提供给MMAP之类的使用的,一般用户都不会直接调用到。

剩下的方法,像是slice、duplicate,包括通过address返回内存地址都非常简单就不描述了。

另外DirectByteBuffer内部还有一个特殊的方法是asReadOnlyBuffer方法,返回了一个DirectByteBufferR对象。下面看一下DirectByteBufferR做了些什么。

简单从方法出发,大概就是返回只读的一个对象,不能做写入操作。

实际上也是非常简单,所有的put操作都抛出了异常。剩下get和slice等也类似,不再赘述。

转载于:https://blog.51cto.com/12902932/1949351

ByteBuffer源码分析相关推荐

  1. Spark源码分析之七:Task运行(一)

    在Task调度相关的两篇文章<Spark源码分析之五:Task调度(一)>与<Spark源码分析之六:Task调度(二)>中,我们大致了解了Task调度相关的主要逻辑,并且在T ...

  2. soundtouch源码分析__based on csdn :

    1. soundtouch介绍和相关资源 The SoundTouch Library Copyright © Olli Parviainen 2001-2014 SoundTouch is an o ...

  3. java直接内存为什么快_直接内存与 JVM 源码分析

    直接内存(堆外内存) 直接内存有一种叫法,堆外内存. 直接内存(堆外内存)指的是 Java 应用程序通过直接方式从操作系统中申请的内存.这个差别与之前的堆.栈.方法区,那些内存都是经过了虚拟化.所以严 ...

  4. Spark源码分析之九:内存管理模型

    Spark是现在很流行的一个基于内存的分布式计算框架,既然是基于内存,那么自然而然的,内存的管理就是Spark存储管理的重中之重了.那么,Spark究竟采用什么样的内存管理模型呢?本文就为大家揭开Sp ...

  5. spark 源码分析 Blockmanager

    原文链接 参考, Spark源码分析之-Storage模块 对于storage, 为何Spark需要storage模块?为了cache RDD  Spark的特点就是可以将RDD cache在memo ...

  6. zookeeper源码分析之四服务端(单机)处理请求流程

    上文: zookeeper源码分析之一服务端启动过程 中,我们介绍了zookeeper服务器的启动过程,其中单机是ZookeeperServer启动,集群使用QuorumPeer启动,那么这次我们分析 ...

  7. zookeeper源码分析之三客户端发送请求流程

    znode 可以被监控,包括这个目录节点中存储的数据的修改,子节点目录的变化等,一旦变化可以通知设置监控的客户端,这个功能是zookeeper对于应用最重要的特性,通过这个特性可以实现的功能包括配置的 ...

  8. NanoHttpd源码分析

    最近在GitHub上发现一个有趣的项目--NanoHttpd. 说它有趣,是因为他是一个只有一个Java文件构建而成,实现了部分http协议的http server. GitHub地址:https:/ ...

  9. spark 源码分析之十八 -- Spark存储体系剖析

    本篇文章主要剖析BlockManager相关的类以及总结Spark底层存储体系. 总述 先看 BlockManager相关类之间的关系如下: 我们从NettyRpcEnv 开始,做一下简单说明. Ne ...

最新文章

  1. linux gcc安装
  2. 推荐一些网站给大家[转]
  3. Java HashMap工作原理深入探讨
  4. 购买7个球彩票(人输入or机输入)(python )
  5. android数据回传多个页面_Android Day06四大组件之Activity多页面跳转和数据传递
  6. 10_30_unittest
  7. Jdbc创建表 利用循环添加数据 ,更新数据
  8. MATLAB正太分布函数
  9. java统计字符串中每个字符出现的次数_统计字符串出现的次数
  10. 怎样在matlab q-q图上读出斜率,Q分解法潮流计算matlab小程序
  11. python和java哪个好-Python和Java对比,全面解读哪个语言最赚钱,前景最好?
  12. [postgresql]postgresql的锁介绍
  13. Visual Studio 开发者命令行找不到 ildasm命令及无法创建 CLR 项目的解决方法
  14. linux 汇编 变址寻址,【计组】偏移地址、段地址和寻址方式
  15. 渲染的本质: 纹理过滤(Texture filtering)技术
  16. 永恒骑士 小程序服务器列表空,微信小程序一键登录应用服务器通过AES解密返回purePhoneNumber为空?...
  17. putty linux上安装及使用
  18. ORACEL R12 总账和子账的关系
  19. 计算机 先进事迹范文,计算机,先进事迹范文.doc
  20. 网络代理服务器的设计与实现

热门文章

  1. java项目close wait_java – 排除连接卡在CLOSE_WAIT状态
  2. 计算机专业PS模版,计算机专业PS范例十一
  3. cad转shp 奥维_CAD转换工具程序包(附下载)
  4. python多态_多态是什么?为什么要使用多态?
  5. mysql自动生成日期序列号_mysql – 在一天内为实体生成唯一的序列号
  6. rpc wmi 服务不可用_golang 基础(5) RPC
  7. linux查看锁了的用户,linux – 如何查找Unix用户帐户被锁定的所有方式
  8. sqlite like concat 怎么 替代_Joplin:真正的 Evernote 开源替代品
  9. 获取浏览器高度_QQ浏览器违法收集用户信息,你的浏览器还安全吗?
  10. 手电筒java_Java鼠标“手电筒”效果如何?