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)
blank

相关推荐

  • 报关员计算机知识,报关员的计算机水平要多少[通俗易懂]

    报关员计算机知识,报关员的计算机水平要多少[通俗易懂]baijuantie新兵答主12-12TA获得超过3110个赞什么是报关员报关员(Customsbroker)又称企业海关经纪人、企业报关人员。报关员是指代表所属企业/单位向海关办理进出口货物报关纳税、在海关备案登记等通关手续的人员。报关员不是自由职业者,只能受雇于一个依法向海关注册登记的进出口货物收发货人或者企业,并代表该企业向海关办理业务。报关员的主要工作内容1.按照海关及规定要求在报关期限…

  • Python如何生成随机数_产生随机数的常用方法

    Python如何生成随机数_产生随机数的常用方法Python生成随机数的方法这篇文章主要介绍了Python生成随机数的方法,有需要的朋友可以参考一下如果你对在Python生成随机数与random模块中最常用的几个函数的关系与不懂之处,下面的文章就是对Python生成随机数与random模块中最常用的几个函数的关系,希望你会有所收获,以下就是这篇文章的介绍。random.random()用于生成用于生成一个指定范围内的随机符点数,两个参数其中一个是上限,一个是下限。如果a>b,则生成随机数 1 n:

  • 解决SecureCRTPortable和SecureFXPortable的中文乱码问题

    解决SecureCRTPortable和SecureFXPortable的中文乱码问题平时学习或者工作中,我们会发现Linux客户端SecureCRTPortable、SecureFXPortable连接Linux服务器时会出现中文乱码问题。通过修改配置可以解决这个问题。一、修改SecureCRTPortable的相关配置步骤一:【选项】→【全局选项】步骤二:【常规】→【默认会话】,点击【编辑默认设置】,点击【确定】步骤三:【外观】,把【字符编码】改成"UTF-8",点击…

  • visio2010最新密钥

    2V3PD-3YMPX-FJG7R-4W49V-M92KH截止2011年6月22日16点,此KEY还有最后110 次可激活。MKBGD-BWJMW-TJQR6-J8DH6-Q8M6B截止2011年6月22日16点,此KEY还有最后 131 次可激活。 892K6-6VDJR-67BCX-V26YV-K2T2K截止2011年6月22日16点,此KEY还有最后 4328 次可激

  • smalldatetime java,如何在数据导入期间将平面文件中的dd-mmm-yy值格式化为smalldatetime?…[通俗易懂]

    smalldatetime java,如何在数据导入期间将平面文件中的dd-mmm-yy值格式化为smalldatetime?…[通俗易懂]IhaveaflatfilewhichisimportedintoSQLServerviaanexistingSSISpackage.Ineedtomakeachangetothepackagetoaccommodateanewfieldintheflatfile.Thenewfieldisadatefieldwhi…

  • 字符串的匹配算法_多字符串匹配

    字符串的匹配算法_多字符串匹配目录需求基础知识逻辑解析源码实现需求先简单描述溪源曾经遇到的需求:需求一:项目结果文件中实验结论可能会存在未知类型、转换错误、空指针、超过索引长度等等。这里是类比需求,用日常开发中常出现的错误类型作为需求,如果要以上结论则判断这个项目检测失败;解决方案一:大家常用的方式可能是if(){continue;}esleif(){continue;}…或者switch-case等;方案二:可能会使用集合contain()方法;方案三:依次匹配字符串中字符(暴力匹配);以上两种方案都能解决;然

发表回复

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

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