`

JDK7 AIO 入门(一)------AsynchronousFileChannel

阅读更多
   随着JDK7的发布,Java的AIO正式支持版本也出炉了,就像当年发布NIO特性支持时,基本上所有的Java服务器都重写了自己的网络框架以通过NIO来提高服务器的性能。AIO的发布势必也会引起Java界的一次重写风潮,现在很多的网络框架(如Mina),大型软件(如Oracle DB)都宣布自己已经在新版本中支持了AIO的特性以提高性能。下面就来看一下aio的基本原理,以及如何使用JDK7的AIO特性。
    所谓AIO,异步IO,其主要是针对进程在调用IO获取外部数据时,是否阻塞调用进程而言的。一个进程的IO调用步骤大致如下:
    1、进程向操作系统请求数据
    2、操作系统把外部数据加载到内核的缓冲区中,
    3、操作系统把内核的缓冲区拷贝到进程的缓冲区
    4、进程获得数据完成自己的功能
  
    当操作系统在把外部数据放到进程缓冲区的这段时间(即上述的第二,三步),如果应用进程是挂起等待的,那么就是同步IO,反之,就是异步IO,也就是AIO
   
    JDK对于IO支持基本上都是基于操作系统的封装,而IO操作的核心就是如何有效的管理Channel(数据通道),JDK7对AIO的支持主要提供如下的一些封装类:
AsynchronousChannel:所有AIO Channel的父类。
AsynchronousByteChannel:支持Byte读写的Channel
AsynchronousDatagramChannel:支持数据包(datagram)读写的Channel
AsynchronousFileChannel:支持文件读写的Channel
AsynchronousServerSocketChannel:支持数据流读写的服务器端Channel
AsynchronousSocketChannel:支持数据流读写的客户端Channel
AsynchronousChannelGroup:支持资源共享的Channel分组

   对于AIO的Channel,JDK定义了2种类型的操作,
1、Future operation(....):即 通过Future判断是操作是否完成。
2、void operation(Object attachment, CompletionHandler handler):即通过CompletionHandler来通知异步IO完成。

下面就是一个AsynchronousFileChannel实现的完整异步读写文件的例子
package com.jdk7.io.aio;


import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousFileChannel;
import java.nio.channels.CompletionHandler;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

/**
 * Created with IntelliJ IDEA.
 * User: twer
 * Date: 5/2/12
 * Time: 8:37 PM
 * To change this template use File | Settings | File Templates.
 */
public class AFCDemo {
    static Thread current;

    public static void main(String[] args) throws IOException, InterruptedException, ExecutionException {
        if (args == null || args.length == 0) {
            System.out.println("Please input file path");
            return;
        }
        Path filePath = Paths.get(args[0]);
        AsynchronousFileChannel afc = AsynchronousFileChannel.open(filePath);
        ByteBuffer byteBuffer = ByteBuffer.allocate(16 * 1024);
//使用FutureDemo时,请注释掉completionHandlerDemo,反之亦然
        futureDemo(afc, byteBuffer);
        completionHandlerDemo(afc, byteBuffer);
    }

    private static void completionHandlerDemo(AsynchronousFileChannel afc, ByteBuffer byteBuffer) throws IOException {
        current = Thread.currentThread();
        afc.read(byteBuffer, 0, null, new CompletionHandler<Integer, Object>() {
            @Override
            public void completed(Integer result, Object attachment) {
                System.out.println("Bytes Read = " + result);
                current.interrupt();
            }

            @Override
            public void failed(Throwable exc, Object attachment) {
                System.out.println(exc.getCause());
                current.interrupt();
            }
        });
        System.out.println("Waiting for completion...");
        try {
            current.join();
        } catch (InterruptedException e) {
        }
        System.out.println("End");
        afc.close();
    }

    private static void futureDemo(AsynchronousFileChannel afc, ByteBuffer byteBuffer) throws InterruptedException, ExecutionException, IOException {
        Future<Integer> result = afc.read(byteBuffer, 0);
        while (!result.isDone()) {
            System.out.println("Waiting file channel finished....");
            Thread.sleep(1);
        }
        System.out.println("Finished? = " + result.isDone());
        System.out.println("byteBuffer = " + result.get());
        System.out.println(byteBuffer);
        afc.close();
    }
}

分享到:
评论
2 楼 Unmi 2015-01-14  
如果内容大于 ByteBuffer 大小,还得从上次位置再不停的读,它还没有提供一个劳永逸的方法。
1 楼 悲伤逆流成河 2013-01-03  
Created with IntelliJ IDEA.
我也喜欢用 idea

相关推荐

    jdk-7u80-windows-x64安装包

    jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-...

    jdk-8u131-windows-x64

    jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-...

    jdk-8u311-windows-x64.exe

    jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u...

    jdk-6u39-windows-i586

    jdk-6u39-windows-i586,jdk-6u39-windows-i586,jdk-6u39-windows-i586,jdk-6u39-windows-i586,jdk-6u39-windows-i586,jdk-6u39-windows-i586,jdk-6u39-windows-i586,jdk-6u39-windows-i586,jdk-6u39-windows...

    jdk-8u131-windows-i586

    jdk-8u131-windows-i586jdk-8u131-windows-i586jdk-8u131-windows-i586jdk-8u131-windows-i586jdk-8u131-windows-i586jdk-8u131-windows-i586jdk-8u131-windows-i586jdk-8u131-windows-i586jdk-8u131-windows-i586...

    jdk-11.0.19-linux-x64-bin.tar.gz文件(分享给需要的同学)

    jdk-11.0.19_linux-x64_bin.tar.gz文件 jdk-11.0.19_linux-x64_bin.tar.gz文件 jdk-11.0.19_linux-x64_bin.tar.gz文件 jdk-11.0.19_linux-x64_bin.tar.gz文件 jdk-11.0.19_linux-x64_bin.tar.gz文件 jdk-11.0.19_...

    jdk-6u21-windows-x64

    jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-windows-x64 jdk-6u21-...

    jdk-8u301-linux.zip

    压缩包内容: Java SE Development Kit 8u301 (1)jdk-8u301-linux-aarch64.rpm (2)jdk-8u301-linux-aarch64.tar.gz (3)jdk-8u301-linux-arm32-vfp-hflt.tar.gz ...(7)jdk-8u301-linux-x64.tar.gz

    jdk-6u45-linux-x64.zip_jdk-1.6u45_jdk-6u45_jdk-6u45-linux-x64_jd

    这个压缩包文件"jdk-6u45-linux-x64.zip"包含的是JDK 1.6.0_45(也被称为6u45或1.6u45)的64位Linux版本。JDK 1.6是Java平台标准版的一个重要版本,它提供了许多功能和性能改进,是许多企业级应用的基础。 JDK 1.6u...

    jdk-7u67-linux-x64.tar包现在 linux jdk下载

    在这个场景中,我们关注的是`jdk-7u67-linux-x64.tar`文件,这是一款适用于64位Linux操作系统的JDK 7更新67版本的归档文件。 1. **JDK版本**: `7u67`指的是JDK 7的第67个更新。Java通常发布主要版本(如JDK 8、JDK ...

    jdk-7u51-windows-x64.zip

    标题“jdk-7u51-windows-x64.zip”指的是Java Development Kit (JDK) 的一个特定版本,针对Windows x64操作系统的安装包。这个版本是7u51,代表JDK 7 Update 51。JDK是Java编程语言的核心组件,包含了开发和运行Java...

    java-jdk1.8-8u361-all-jdk-win-linux

    java-jdk1.8-8u361-all-jdk-win-linux 该压缩包中包含jdk1.8-8u361下windows版本和linux版本,其包含快速安装包和对应的jdk压缩包版本,具体内容如下: jdk-8u361-linux-aarch64.rpm jdk-8u361-linux-i586.rpm jdk-8...

    jdk1.7 32位官方正式版 jdk-7u79-windows-i586 下载

    jdk-7u79-windows-i586.exe JDK7 稳定版 源官方下载地址: http://www.oracle.com/technetwork/java/javase/downloads/jdk7-downloads-1880260.html

    jdk-7u79-linux-x64.tar.gz.zip

    在本案例中,我们关注的是JDK的一个特定版本——"jdk-7u79-linux-x64",它是一个适用于64位Linux操作系统的版本。JDK 7u79是Java 7的更新版本79,包含了编译器、调试器、性能优化工具和其他必要的库,使得开发者能够...

    jdk-7u25-windows-i586.exe

    描述中的“jdk-7u25-windows-x64”暗示了同时存在一个64位版本的JDK,适应于运行在64位Windows系统上的用户。与32位版本相比,64位JDK通常能够利用更多的内存资源,对于处理大数据或内存密集型应用来说更为合适。 ...

    jdk-8u171-linux-x64.rpm/jdk-8u171-linux-x64.tar.gz

    首先,`jdk-8u171-linux-x64.rpm`是一个RPM(Red Hat Package Manager)格式的文件,主要用于基于RPM包管理系统的Linux发行版,如Fedora、CentOS或Red Hat Enterprise Linux。RPM包提供了方便的安装、升级和卸载功能...

    jdk7-aarch64-uos.tar.gz

    JDK7-aarch64-uos.tar.gz这个压缩包文件,便是针对arm64与aarch64架构的Linux系统,尤其是针对银河麒麟V10、uos等国产服务器系统,提供了一个兼容的Java Development Kit (JDK) 版本。本文将详细探讨JDK7在Aarch64...

    jdk-8u261-linux-x64.tar linux jdk

    描述 "JDK java jar 包最新 下载解压即可 jdk-8u261-linux-x64.tarjdk-8u261-linux-x64.tarjdk-8u261-linux-x64.tar" 表明这是Java开发工具包的一个更新版本,特别是JDK 8 Update 261(8u261),并且提供的是一个可...

    jdk-7u51-windows-x64

    jdk-7u51-windows-x64 JDK 64位,适用于WIN 64位系统JDK,全名是Java SE Development Kit,Java的研发环境,使用最广泛的Java SDK,JDK是研发与编译JAVA程序,必不可少的环境,64位的JDK解压出来就是jdk-7u51-...

    jdk-7u67-windows-x64.exe

    jdk-7u67-windows-x64.exe 资源:http://download.csdn.net/user/ajlgl/uploads 百度云:https://pan.baidu.com/s/1dESLQY9

Global site tag (gtag.js) - Google Analytics