javaNIO

一.NIO的由来

        传统的BIO即阻塞IO,不管是磁盘IO还是网络IO,在写入和读取的时候,因为内存和硬盘或网络的读写速度的差异,线程都会失去cpu的使用权(挂起),这个线程会在读写完成之后继续,这在单线程的情况下是一种性能的极大的浪费。多线程情况下cpu会在线程读写时切换线程,可以避免cpu资源的浪费,但在线程切换频繁的情况下,即便使用了线程池,减少了线程创建和回收的成本,频繁的切换线程,也会给cpu带来大量的上下文切换开销。比如在经典的阿里旺旺(类聊天室项目)中,服务器需要维持大量的http长连接,通常的做法是服务器创建海量的线程来保持连接,这么多的连接性能首先就是一个问题,再涉及到线程间的同步问题,所以在jdk1.4中引入了NIO试图解决IO中的线程阻塞问题。

二.缓冲区

        最常用的缓冲区是ByteBuffer,底层是字节数组,事实上每一种java类型都有一种Buffer抽象类的继承,有CharBuffer,LongBuffer等,都是抽象类,都需要用静态方法allocate()生成。

        position,limit,capacity是Buffer的3个公有参数,顾名思义,在向Buffer写数据时position表示下一个待写的位置,初始为0,limit和capacity表示Buffer的长度。在向Buffer读数据时position表示下一个该读的位置初始也为0,limit表示读取的位置极限,capacity依然为Buffer的总长度。在filp()操作中,position变为0,limit变为position的值,为由写转读做准备。而在clear()操作中,position还是变为0,但limit还是变成capcity,准备进行下一次写操作(不对结果进行清洗,效率更高)。

        可以调用asReadOnlyBuffer()方法返回一个只读的缓冲区

三.通道

        通道跟流很像,但是由于是抽象类不能直接创建,都是使用流的getChannel方法来创建。它主要的作用还是用于非阻塞式读写。

四.拷贝文件的demo

package nio;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.nio.ByteBuffer;

import java.nio.channels.FileChannel;

/**

* Created by ruby_ on 2018/3/16.

*/

public class CopyFile {

public static void main(String[] args)throws IOException {

FileInputStream fileInputStream =null;

        fileInputStream =new FileInputStream("aa.txt");

        FileChannel channel = fileInputStream.getChannel();

        ByteBuffer buffer = ByteBuffer.allocate(1024);

        channel.read(buffer);

        buffer.flip();

        FileOutputStream fileOutputStream =new FileOutputStream("bb.txt");

        FileChannel channel2 = fileOutputStream.getChannel();

        channel2.write(buffer);

    }

}

测试发现拷贝大文件和传统IO方式差不多

四.缓冲区分片

        缓冲区可以分出新的子缓冲区(共享数据)

ByteBufferbyteBuffer =ByteBuffer.allocate(10);

for (int i =0; i < byteBuffer.capacity(); i++) {

byteBuffer.put((byte) i);

}

byteBuffer.flip();

while (byteBuffer.hasRemaining()){

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

}

byteBuffer.position(4);

byteBuffer.limit(6);

ByteBufferslice = byteBuffer.slice();

slice.put(1, (byte)11);

byteBuffer.clear();

while (byteBuffer.hasRemaining()){

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

}

五.内存磁盘映射MappedByteBuffer

        现代操作系统通常都是利用内核缓冲区读写数据,内存磁盘映射可以跳过内核缓冲区,直接在内存和磁盘建立映射(似乎有不同的理解,暂不深究),速度更快,适合处理上G的文件。

六.NIO的第二种文件优化方法transferTo

        FileChannel的transferTo()方法可以调用系统底层方法,操作数据直接在内核空间中移动。

七.ByteBuffer的allocate和allocateDirect

        通常的IO操作是系统内存先获取,然后拷贝到JVM内存中共java使用,第二种方式省去了复制这一操作,效率有所提高,但考虑到内存泄露,前者的本地内存会在ByteBuffer被GC回收的时候顺带回收,而后者没有被自动回收的动作,这时候堆内存充足,但本地内存可能已经用光了。所以DirectByteBuffer要手动清除本地内存。貌似操作系统的System.gc()自己也会清理,但还是手动清理更安全,适合数据量比较大的情况。

ByteBufferbb =ByteBuffer.allocateDirect(1024*1024*1024);

TimeUnit.SECONDS.sleep(10);

//清除直接缓存

((DirectBuffer)bb).cleaner().clean();

System.out.println("ok");

八.SocketChannel和ServerSocketChannel

        这两个通道本质是对Socket和ServerSocket的封装

public class ChannelServer {

    public static void main(String[] args) throws IOException, InterruptedException {

        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

        serverSocketChannel.bind(new InetSocketAddress("127.0.0.1", 1313));

        SocketChannel socketChannel = serverSocketChannel.accept();

        socketChannel.configureBlocking(false);

        ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

        int read = socketChannel.read(byteBuffer);

        byteBuffer.flip();

        System.out.println(new String(byteBuffer.array(), 0, byteBuffer.limit()));

    }

}

public class ChannelClient {

    public static void main(String[] args) throws IOException, InterruptedException {

        SocketChannel socketChannel = SocketChannel.open();

        socketChannel.connect(new InetSocketAddress("127.0.0.1", 1313));

        ByteBuffer byteBuffer = ByteBuffer.allocate(10240);

        byteBuffer.put("hello".getBytes());

        byteBuffer.flip();

        socketChannel.write(byteBuffer);

    }

}

九.seletor

案例

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,980评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,178评论 2 380
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,868评论 0 336
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,498评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,492评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,521评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,910评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,569评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,793评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,559评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,639评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,342评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,931评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,904评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,144评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,833评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,350评论 2 342

推荐阅读更多精彩内容

  • 传统的BIO模式 上面的代码中,我们在主线程中处理客户端的连接请求,然后为每个建立的连接分配一个线程去执行。soc...
    德彪阅读 905评论 0 0
  • 1、Netty基础入门 Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应...
    我是嘻哈大哥阅读 4,686评论 0 31
  • NIO(Non-blocking I/O,在Java领域,也称为New I/O),是一种同步非阻塞的I/O模型,也...
    闪电是只猫阅读 3,077评论 0 7
  • 没输过的人,常常会输得一塌糊涂;没摔过跤的人,跌倒了往往爬不起来;没体会过饥寒的人,贫困注定会成为你的归宿;没历经...
    守真山房阅读 174评论 0 0
  • 1、腰是人体的带脉区,所有的经络都是竖着的,只有带脉是横着的,也是身体微循环最薄弱的地方,腰部脂肪过多容易造成淤堵...
    潇湘妃子JC阅读 236评论 0 0