`

java的DirectBuffer源码分析(主要是DirectBuffer的资源分配和回收)

    博客分类:
  • java
阅读更多
可以看到淘宝的一个说明:http://www.tbdata.org/archives/801

Java 2 SE 6 doc :

Given a direct byte buffer, the Java virtual machine will make a best effort to perform native I/O operations directly upon it. That is, it will attempt to avoid copying the buffer’s content to (or from) an intermediate buffer before (or after) each invocation of one of the underlying operating system’s native I/O operations.

DirectBuffer通过免去中间交换的内存拷贝, 提升IO处理速度;

Java 2 SE 6 doc :

The contents of direct buffers may reside outside of the normal garbage-collected heap, and so their impact upon the memory footprint of an application might not be obvious.

DirectBuffer在-XX:MaxDirectMemorySize=xxM大小限制下[1], 使用Heap之外的内存, GC对此”无能为力”[2] ,也就意味着规避了在高负载下频繁的GC过程对应用线程的中断影响.
因此, 当系统应用场景满足:


大量原生类型数据使用
频繁IO操作
系统处理响应速度要求快且稳定
典型场景是网络数据传输, 可考虑合理应用DirectBuffer.


那么,DirectBuffer是怎么实现这些的呢:
DirectByteBuffer(int paramInt)
  {
    super(-1, 0, paramInt, paramInt, false);
    Bits.reserveMemory(paramInt);
    int i = Bits.pageSize();
    long l = 0L;
    try
    {
      l = unsafe.allocateMemory(paramInt + i); //这个是分配内存
    }
    catch (OutOfMemoryError localOutOfMemoryError)
    {
      Bits.unreserveMemory(paramInt);
      throw localOutOfMemoryError;
    }
    unsafe.setMemory(l, paramInt + i, 0);
    if (l % i != 0L)
      this.address = (l + i - (l & i - 1));
    else
      this.address = l;
    this.cleaner = Cleaner.create(this, new Deallocator(l, paramInt, null));//这个是负责回收资源。
    this.viewedBuffer = null;
  }



public native long allocateMemory(long paramLong);

allocateMemory 是一个本地方法,功能就是做一些参数检查和字节对齐,然后使用系统调用 malloc 申请一块内存。

从上面的分析也可以看出,创建一个 DirectByteBuffer 对象代价还是很大的,因为 malloc 系统调用代价就很大,需要 60 ~ 100 条 CPU 指令(一个 new Object() 只需要不足 10 条机器指令)。

注意,这个是操作系统直接分配的内存,java的垃圾回收是管不了的。


那是如何实现资源回收的呢。
 this.cleaner = Cleaner.create(this, new Deallocator(l, paramInt, null));

cleaner 的类型是Cleaner,Cleaner是PhantomReference(俗称的幽灵引用)的子类。当整个对象被回收的时候,幽灵引用会被java的虚拟机加到一个队列里去,ReferenceQueue。Reference有一个静态内部类ReferenceHandler。
 private static class ReferenceHandler extends Thread

然后还有个静态代码块:

 static
  {
    Object localObject1 = Thread.currentThread().getThreadGroup();
    for (Object localObject2 = localObject1; localObject2 != null; localObject2 = ((ThreadGroup)localObject1).getParent())
      localObject1 = localObject2;
    localObject2 = new ReferenceHandler((ThreadGroup)localObject1, "Reference Handler");
    ((Thread)localObject2).setPriority(10);
    ((Thread)localObject2).setDaemon(true);
    ((Thread)localObject2).start();
  }


也就是说虚拟机已启动,ReferenceHandler 这个线程就启动了,那ReferenceHandler 会做什么呢
public void run() {
	    for (;;) {

		Reference r;
		synchronized (lock) {
		    if (pending != null) {
			r = pending;
			Reference rn = r.next;
			pending = (rn == r) ? null : rn;
			r.next = r;
		    } else {
			try {
			    lock.wait();
			} catch (InterruptedException x) { }
			continue;
		    }
		}

		// Fast path for cleaners
		if (r instanceof Cleaner) {
		    ((Cleaner)r).clean();
		    continue;
		}

		ReferenceQueue q = r.queue;
		if (q != ReferenceQueue.NULL) q.enqueue(r);
	    }
	}
    }


可以看到其中有:
if (r instanceof Cleaner) {
		    ((Cleaner)r).clean();
		    continue;
		}

就是会执行幽灵引用的clean方法。

在clean方法执行的其实是:
 this.thunk.run();

thunk是在构造方法传进去的。对于DirectByteBuffer来说,他的thunk是Deallocator:
this.cleaner = Cleaner.create(this, new Deallocator(l, paramInt, null))


Deallocator的run方法会做什么事情呢:
public void run() {
	    if (address == 0) {
		// Paranoia
		return;
	    }
	    unsafe.freeMemory(address);
	    address = 0;
	    Bits.unreserveMemory(capacity);
	}


  public native void freeMemory(long paramLong);


可以看到这个也是个native方法。这里就会把资源回收。


有些人问为什么不用finalize去做资源回收,搞个幽灵索引,搞怎么麻烦。主要是因为java的
finalize不是很安全。如果finalize再搞一个对象本身的强引用,那么这个对象就永远不会回收掉了。但是幽灵引用不一样,幽灵引用起作用在对象的finalize之后,也就是说这个对象这个时候已经回收了。这样会更安全。
7
2
分享到:
评论
5 楼 shuizhaosi888 2015-03-19  
解决我一个大问题  
4 楼 lazy_ 2013-04-17  
huangyunbin 写道


我想请问一下,这是否意味这directBuffer可以不受HEAP大小控制?例如JVM最大2G,堆分了1.5G,那么MaxDirectMemorySize最大可以是多少呢?

我的观点是:directBuffer的使用内存已经和jvm没有关系了,他的限制是操作系统或者硬件的限制了。


我们在32位机器的前提上讨论吧。一个进程4G空间,2G内核,2G用户。你的意思好像是,DIRECT BYTE BUFFER 用的是2G内核空间里面的空间。我的理解对吗?
3 楼 huangyunbin 2013-04-17  


我想请问一下,这是否意味这directBuffer可以不受HEAP大小控制?例如JVM最大2G,堆分了1.5G,那么MaxDirectMemorySize最大可以是多少呢?

我的观点是:directBuffer的使用内存已经和jvm没有关系了,他的限制是操作系统或者硬件的限制了。
2 楼 lazy_ 2013-04-17  
引用
DirectBuffer在-XX:MaxDirectMemorySize=xxM大小限制下[1], 使用Heap之外的内存, GC对此”无能为力”[2] ,也就意味着规避了在高负载下频繁的GC过程对应用线程的中断影响.


我想请问一下,这是否意味这directBuffer可以不受HEAP大小控制?例如JVM最大2G,堆分了1.5G,那么MaxDirectMemorySize最大可以是多少呢?
1 楼 mtsw2011 2013-04-17  
   

相关推荐

    java 中Buffer源码的分析

    Java 中 Buffer 源码的分析 Java 中 Buffer 源码的分析是 Java 中一个非常重要的知识点, Buffer 是 Java 中用于高效进行 IO 操作的缓冲区。Buffer 分为两类:Direct Buffer 和 Heap Buffer。下面将详细介绍这两类 ...

    java源码包---java 源码 大量 实例

     Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java源码...

    netty源码分析buffer

    它负责维护一组`PoolChunkList`实例,并提供了一套完整的策略来分配和回收内存。 **5. 从对象池中获取 buffer** 为了从对象池中获取`ByteBuf`实例,用户可以通过`PooledByteBufAllocator`提供的方法来请求特定大小...

    java源码包2

     Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java...

    java远程监控源码

    标题“Java远程监控源码”涉及的是Java编程中关于远程监控和控制的实现。这个项目可能包含一个客户端(client)和服务器端(server)的架构,通过Socket通信进行数据交互,利用Java Robot类来捕获屏幕图像,以及...

    java人脸识别源码

    总的来说,这份Java人脸识别源码是一个很好的学习和实践资源,它可以帮助开发者深入理解特征脸识别技术以及如何在Java环境中使用JavaCV来处理图像和视频。通过研究和调试代码,可以提升在计算机视觉领域的专业技能。

    JAVA源码DataBuffer在Java中使用ADO.NET

    JAVA源码DataBuffer在Java中使用ADO.NET

    疯狂Java实战演义【书+源码】(疯狂Java讲义课后习题项目)

    源码分析可以帮助读者理解和运用这些机制,编写出高效、安全的并发程序。 文件I/O操作在任何编程语言中都是必不可少的。Java的File类和InputStream/OutputStream家族提供了丰富的功能,用于读写文件和处理流。通过...

    java电子商务网站源码

    在分析和使用这套源码时,开发者需要对Java编程、Web开发框架、数据库管理和电子商务业务流程有深入理解。由于缺少Struts的jar包,开发者需要自行解决这个问题,或者选择使用其他框架进行重构。同时,对源码的充分...

    DataBuffer在Java中使用ADO.NET

    总结来说,Java中使用DataBuffer与ADO.NET交互主要依赖于JNA这样的库来实现跨平台的调用。这个过程涉及了对.NET接口的映射、数据缓冲区的管理以及Java和.NET数据类型的转换。尽管这提供了一种灵活性,但在实际应用中...

    基于Java的RTSP服务源码

    本文将深入探讨基于Java实现RTSP服务的相关知识点,并以“基于Java的RTSP服务源码”为例进行分析。 1. RTSP协议基础 RTSP协议由IETF定义,主要目的是为了解决多媒体数据的实时传输问题。它允许客户端通过发送指令来...

    基于Java的实例开发源码-DataBuffer在Java中使用ADO.NET.zip

    他们可以研究源码,理解Java和ADO.NET之间的交互机制,并扩展这个例子以适应不同的数据库需求。 总结来说,这个基于Java的实例开发源码展示了如何在非.NET环境中利用ADO.NET的强大功能。通过学习和理解这个例子,...

    java源码包4

     Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java...

    java 制作的企业网站源码

    java源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码源码...

    Java炸弹人源码

    一个pc下的java炸弹人实现及源码

    Hadoop源码分析(完整版)

    Hadoop源码分析是深入理解Hadoop分布式计算平台原理的起点,通过源码分析,可以更好地掌握Hadoop的工作机制、关键组件的实现方式和内部通信流程。Hadoop项目包括了多个子项目,其中最核心的是HDFS和MapReduce,这两...

    129个Java项目源码下载

    这个"129个Java项目源码下载"集合提供了一个极好的学习资源,涵盖了各种类型的Java应用项目,帮助开发者深入理解Java编程的实际运用。 在Java项目开发中,我们通常会遇到多种技术栈和框架,例如Spring Boot用于构建...

    databuffer_JAVA源码_

    在Java 2D API中,`DataBuffer` 是图像数据的主要存储结构,通常与`Raster` 和 `BufferedImage` 类一起使用来处理图像。在ADO.NET中,虽然没有直接对应的`DataBuffer`概念,但在处理数据库数据时,我们会用到类似的...

    基于Java的实例源码-DataBuffer在Java中使用ADO.NET.zip

    基于Java的实例源码-DataBuffer在Java中使用ADO.NET.zip

    人力资源管理系统 java web 完整项目 包含源码和数据库

    权限管理通过角色和权限的分配,限制不同用户对资源的访问;日志记录有助于追踪操作历史,便于问题排查;异常处理则可以防止程序因意外情况崩溃,提高系统的健壮性。 总的来说,这个人力资源管理系统利用Java Web...

Global site tag (gtag.js) - Google Analytics