Okio的使用和源码解析「建议收藏」

Okio的使用和源码解析「建议收藏」一.javaNIO和堵塞I/O的区别  1.阻塞I/O通信模型:    阻塞I/O在调用InputStream.read()方法时是阻塞的,它会一直等到数据到来时才会返回       2.javaNIO原理及通信模型    JavaNIO是在jdk1.4开始使用的,是一种非阻塞式的I/O    javaNIO的工作原理:      (1)Jav

大家好,又见面了,我是你们的朋友全栈君。一.java NIO和堵塞I/O的区别


   1.阻塞I/O通信模型:
     阻塞I/O在调用InputStream.read()方法时是阻塞的,它会一直等到数据到来时才会返回
      
   2.java NIO原理及通信模型
     Java NIO是在jdk1.4开始使用的,是一种非阻塞式的I/O
     java NIO的工作原理:
       (1)Java NIO的服务端由一个专门的线程来处理所有的I/O事件,并负责分发
       (2)线程通讯:线程之间通过wait,notify等方式通讯。保证每次上下文切换都是有意义的。减少无谓的线程切换。    
      



   
二.Okio概述


 
1.概述:
    Okio补充了io包和nio包的内容,使得数据访问和处理更加便捷,主要功能封装在ByteString和Buffer这两个类中;
    Okio使用起来是很简单的,减少了很多io操作的基本代码,并且对内存和cpu使用做了优化
    
  2.ByteString
     ByteString(字节串)代表一个immutable字节序列。对于字符数据来说,String是非常基础的,但在二进制数据的处理中,
   则没有与之对应的存在。ByteString应运而生。它为我们提供了对串操作所需要的各种 API,例如子串、判等、查找等,也
   能把二进制数据编解码为十六进制(hex),base64和UTF-8格式。
   
  3.Source和Sink
    Source和Sink,它们和InputStream与OutputStream类似,Source相对应于InpuStream,Sink相对应于OutputStream
    
    但它们还有一些新特性:
      a.超时机制,所有的流都有超时机制;
      b.API非常简洁,易于实现;
      c.Source和Sink的API非常简洁,为了应对更复杂的需求,Okio还提供了BufferedSource和BufferedSink
        接口,便于使用(按照任意类型进行读写,BufferedSource 还能进行查找和判等);
      d.不再区分字节流和字符流,它们都是数据,可以按照任意类型去读写;
      e.便于测试,Buffer 同时实现了 BufferedSource 和 BufferedSink 接口,便于测试;
      
  4.Buffer-(Read和Write数据缓冲区)
      Buffer实现了BufferSource接口和BufferSink接口,它集BufferedSource和BufferedSink的功能于一身,
   为我们提供了访问数据缓冲区所需要的一切API
     
      Buffer是一个可变的字节序列,包含一个双端链表Segment。我们使用时只管从它的头部读取数据,往它的尾部写入数据就行了,
   而无需考虑容量、大小、位置等其他因素。


三.Okio使用     
  1.Okio的使用
      (0)简单的步骤:

         a.构建缓冲池,缓冲源对象
         b.读写操作
         c.关闭缓冲池
         
      (1)ButteredSink      
          

<span style="font-size:14px;"> File file=new File("xx.txt");
            //1.构建缓冲池
            BufferedSink sink = Okio.buffer(Okio.sink(file));
            //2.向缓存池写入信息
            sink.writeUtf8("写入数据");
            //3.重新构建缓冲池对象,会清空之前write的信息
            sink = Okio.buffer(Okio.appendingSink(file));
            //4.重写输入信息
            sink.writeUtf8("java.io file!");
            //5.关闭缓冲区
            sink.close();</span>

            
      (2)BufferedSource
         

<span style="font-size:14px;"> //1.构建缓冲区
           BufferedSource source=Okio.buffer(Okio.source(file));
           //2.读文件
           source.readUtf8();
           //3.关闭缓冲源
           source.close(); </span>

           
      (3)Buffer
        Sink中写入Buffer
           

<span style="font-size:14px;"> //1.构建buffer对象
          Buffer data = new Buffer();
          //2.向缓冲中写入文本
          data.writeUtf8("a");
          //3.可以连续追加,类似StringBuffer
          data.writeUtf8("c");
          //4.构建字节数组流对象
          ByteArrayOutputStream out = new ByteArrayOutputStream();
          //5.构建写缓冲池
          Sink sink = Okio.sink(out);
          //6.向池中写入buffer
          sink.write(data, 3);</span>

        Source读取Buffer
        

<span style="font-size:14px;"> InputStream in = new ByteArrayInputStream(("a" + repeat('b', Segment.SIZE * 2) + "c").getBytes(UTF_8));
           //2.缓冲源
           Source source = Okio.source(in);
           //3.buffer
           Buffer sink = new Buffer();
           //4.将数据读入buffer
           sink.readUtf8(3);</span>

         


四.Okio源码解析

    Sink,Source在Okio中的实现只是对OutputStream和Inp0utStream的简单封装
    Sink->Okio.sink(OutputStream os)方法实现了write(Buffer buffer,long byteCount)方法
    ->Okio.buffer(sink)->RealBufferedSinked.writeUtf8(String string)->buffer.writeUtf8();sink.write(buffer,bytCount);
    
    Buffer就相当于一个存储数据的缓冲区, 当调用Okio.buffer(Okio.sink(file));写数据操作时,会写调用buffer.write方法将数据存到Segment双向链表中
    然后调用sink.write(buffer,byteCount);传入buffer,将数据从链表取出,完成真正的io操作
    
    Okio的使用和源码解析「建议收藏」
五.Okio高效在哪里?
   Okio之所以高效是因为在底层的数据结构上,它维护了一个由Segment构成的链表循环队列,一个Segment相当于一个数据块。这样的好处很明显。
 因为在一块数据块的进行IO的过程中是没有中断的,相比于每次只读一个byte,单位时间内IO的数据量当然更高。那是不是Segment越大越好?
 当然不是。因为Segment内数据的IO还是以byte为单位的,如果Segment过大的话,数据就不能很好的进行分块。想象下把数据只分为一个大的Segment,
 那每次IO不就是以byte为单位了吗?那一个Segment的大小为多少比较合适,在我看来,最好和计算机中的一个页面大小一致。

 

 

                      

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/143979.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 稳压管稳压电路

    稳压管稳压电路一、稳压管稳压电路:整流滤波电路的输出电压会随着电网电压的波动而波动,随着负载电阻的变化而变化。为了获得稳定性好的直流电压,必须采取稳压措施。二、稳压原理:对于任何稳压电路而言,都应该从两方面来考虑:电网电压波动、负载变化,研究其输出电压是否稳定。(1)、电网电压波动:(2)、负载变化:…

  • Linux系统内核笔记[通俗易懂]

    Linux系统内核笔记[通俗易懂]一、课程介绍UNIX/Linux环境C语言,借助学习操作系统的接口的方法来学习、理解操作系统的运行机制以及一些网络协议C/C++、数据结构和算法与平台无关,重点是算法逻辑Uinx/Linux/Android/IOS平台相关,系统接口嵌入式/驱动/移植硬件相关,硬件接口 环境介绍 内存管理 文件操作 文件管理 信号处理 进程管理 进程通信 网络通信 线程管理 线程…

  • 改写String类别

    改写String类别

  • linux awk 数组和循环[通俗易懂]

    linux awk 数组和循环[通俗易懂]awk作为强大的文本处理工具,少不了数组处理。awk中数组叫做关联数组(associativearrays),下标可以是数字也可以是字符串。awk中的数组不必提前声明,也不必声明大小,初始化数组元素用0或空串,这根据上下文而定。一语法语法: awk'{pattern+action}’  或 awk’pattern{action}’其中pattern表示AWK

  • BeanUtils.copyProperties 用法

    BeanUtils.copyProperties 用法BeanUtils.copyProperties方法不用操作过多的set/get方法,两个类字段相同的时候我们可以通过此方法来进行复制,如有不想复制的属性则用第三个构造参数来进行,如果你只需要改其中的一个属性或者两个属性没必要重新get/set一边直接复制原来的类,付给新类属性名相同即可赋值。…

  • pycharm删除的文件 找回_pycharm重命名

    pycharm删除的文件 找回_pycharm重命名1、打开pycharm后,点击项目文件夹右键2、在弹出的菜单中,点击LocalHistory,会自动出现子菜单,点击showhistoy功能;3、弹出本地历史窗口后,左侧显示删除的文件列表及信息(文件名及删除时间;4、选中需要找回的文件后,点击右键,选择Revertselection…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号