国产 无码 综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

【轉(zhuǎn)】值得一用的 IO 神器 Okio

這篇具有很好參考價值的文章主要介紹了【轉(zhuǎn)】值得一用的 IO 神器 Okio。希望對大家有所幫助。如果存在錯誤或未考慮完全的地方,請大家不吝賜教,您也可以點擊"舉報違法"按鈕提交疑問。

IO 神器 Okio

官方 是這么介紹 Okio 的:

Okio is a library that complements java.io and java.nio to make it much easier to access, store, and process your data. It started as a component of OkHttp, the capable HTTP client included in Android. It’s well-exercised and ready to solve new problems.

重點是這一句它使訪問,存儲和處理數(shù)據(jù)變得更加容易,既然 Okio 是對 java.io 的補充,那是否比傳統(tǒng) IO 好用呢?

看下 Okio 這么使用的,用它讀寫一個文件試試:

    // OKio寫文件 
    private static void writeFileByOKio() {
        try (Sink sink = Okio.sink(new File(path));
             BufferedSink bufferedSink = Okio.buffer(sink)) {
            bufferedSink.writeUtf8("write" + "\n" + "success!");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    //OKio讀文件
    private static void readFileByOKio() {
        try (Source source = Okio.source(new File(path));
             BufferedSource bufferedSource = Okio.buffer(source)) {
            for (String line; (line = bufferedSource.readUtf8Line()) != null; ) {
                System.out.println(line);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

從代碼中可以看出,讀寫文件關鍵一步要創(chuàng)建出 BufferedSourceBufferedSink 對象。有了這兩個對象,就可以直接讀寫文件了。

Okio為我們提供的 BufferedSink 和 BufferedSource 就具有以下基本所有的功能,不需要再串上一系列的裝飾類
【轉(zhuǎn)】值得一用的 IO 神器 Okio

現(xiàn)在開始好奇Okio是怎么設計成這么好用的?看一下它的類設計:
【轉(zhuǎn)】值得一用的 IO 神器 Okio

在Okio讀寫使用中,比較關鍵的類有 Source、Sink、BufferedSource、BufferedSink。

Source 和 Sink

SourceSink 是接口,類似傳統(tǒng) IO 的 InputStreamOutputStream,具有輸入、輸出流功能。

Sourec 接口主要用來讀取數(shù)據(jù),而數(shù)據(jù)的來源可以是磁盤,網(wǎng)絡,內(nèi)存等。

public interface Source extends Closeable {
  long read(Buffer sink, long byteCount) throws IOException;
  Timeout timeout();
  @Override void close() throws IOException;
}

Sink 接口主要用來寫入數(shù)據(jù)。

public interface Sink extends Closeable, Flushable {
  void write(Buffer source, long byteCount) throws IOException;
  @Override void flush() throws IOException;
  Timeout timeout();
  @Override void close() throws IOException;
}

BufferedSource 和 BufferedSink

BufferedSourceBufferedSink 是對 SourceSink 接口的擴展處理。Okio 將常用方法封裝在 BufferedSource/BufferedSink 接口中,把底層字節(jié)流直接加工成需要的數(shù)據(jù)類型,摒棄 Java IO 中各種輸入流和輸出流的嵌套,并提供了很多方便的 api,比如 readInt()readString()

public interface BufferedSource extends Source, ReadableByteChannel {
  Buffer getBuffer();
  int readInt() throws IOException;
  String readString(long byteCount, Charset charset) throws IOException;
}
public interface BufferedSink extends Sink, WritableByteChannel {
  Buffer buffer();
  BufferedSink writeInt(int i) throws IOException;
  BufferedSink writeString(String string, int beginIndex, int endIndex, Charset charset)
      throws IOException;
}

RealBufferedSink 和 RealBufferedSource

上面的 BufferedSourceBufferedSink 都還是接口,它們對應的實現(xiàn)類就是 RealBufferedSinkRealBufferedSource 了。

final class RealBufferedSource implements BufferedSource {
  public final Buffer buffer = new Buffer();
  
  @Override public String readString(Charset charset) throws IOException {
    if (charset == null) throw new IllegalArgumentException("charset == null");
    buffer.writeAll(source);
    return buffer.readString(charset);
  }
  
  //...
}
final class RealBufferedSink implements BufferedSink {
  public final Buffer buffer = new Buffer();
  
  @Override public BufferedSink writeString(String string, int beginIndex, int endIndex,
      Charset charset) throws IOException {
    if (closed) throw new IllegalStateException("closed");
    buffer.writeString(string, beginIndex, endIndex, charset);
    return emitCompleteSegments();
  }
  //...
}

RealBufferedSourceRealBufferedSink 內(nèi)部都維護一個 Buffer 對象。里面的實現(xiàn)方法,最終實現(xiàn)都轉(zhuǎn)到 Buffer 對象處理。所以這個 Buffer 類可以說是 Okio 的靈魂所在。下面會詳細介紹。

Buffer

Buffer 的好處是以數(shù)據(jù)塊 SegmentInputStream 讀取數(shù)據(jù)的,相比單個字節(jié)讀取來說,效率提高了,是一種空間換時間的策略。

public final class Buffer implements BufferedSource, BufferedSink, Cloneable, ByteChannel {
  Segment head;
  @Override public Buffer getBuffer() {
    return this;
  }
  
  @Override public String readString(long byteCount, Charset charset) throws EOFException {
    checkOffsetAndCount(size, 0, byteCount);
    if (charset == null) throw new IllegalArgumentException("charset == null");
    if (byteCount > Integer.MAX_VALUE) {
      throw new IllegalArgumentException("byteCount > Integer.MAX_VALUE: " + byteCount);
    }
    if (byteCount == 0) return "";
    Segment s = head;
    if (s.pos + byteCount > s.limit) {
      // If the string spans multiple segments, delegate to readBytes().
      return new String(readByteArray(byteCount), charset);
    }
    String result = new String(s.data, s.pos, (int) byteCount, charset);
    s.pos += byteCount;
    size -= byteCount;
    if (s.pos == s.limit) {
      head = s.pop();
      SegmentPool.recycle(s);
    }
    return result;
  }
  //...
}

從代碼中可以看出,這個 Buffer 是個集大成者,實現(xiàn)了 BufferedSinkBufferedSource 的接口,也就是意味著它同時具有讀和寫的功能。

Buffer 包含了指向第一個和最后一個 Segment 的引用,以及當前讀寫位置等信息。當進行讀寫操作時,Buffer 會在 Segment 之間移動,而不需要進行數(shù)據(jù)的實際拷貝。那 Segment ,又是什么呢?

final class Segment {
  //大小是8kb
  static final int SIZE = 8192;
  //讀取數(shù)據(jù)的起始位置
  int pos;
  //寫數(shù)據(jù)的起始位置
  int limit;
  //后繼
  Segment next;
  //前繼
  Segment prev;
  
  //將當前的Segment對象從雙向鏈表中移除,并返回鏈表中的下一個結(jié)點作為頭結(jié)點
  public final @Nullable Segment pop() {
    Segment result = next != this ? next : null;
    prev.next = next;
    next.prev = prev;
    next = null;
    prev = null;
    return result;
  }
  //向鏈表中當前結(jié)點的后面插入一個新的Segment結(jié)點對象,并移動next指向新插入的結(jié)點
  public final Segment push(Segment segment) {
    segment.prev = this;
    segment.next = next;
    next.prev = segment;
    next = segment;
    return segment;
  }
  //單個Segment空間不足以存儲寫入的數(shù)據(jù)時,就會嘗試拆分為兩個Segment
  public final Segment split(int byteCount) {
   //...
  }
  //合并一些鄰近的Segment
  public final void compact() {
     
  }
}

poppush 方法可以看出 Segment 是一個雙向鏈表的數(shù)據(jù)結(jié)構(gòu)。一個 Segment 大小是 8kb。正是由于 Segment 使 IO 讀寫操作能如此高效。

Segment 緊密相關的還有一個 `SegmentPoll 。

final class SegmentPool {
  static final long MAX_SIZE = 64 * 1024;
  static @Nullable Segment next;
  
  //當池子里面有空閑的 Segment 就直接復用,否則就創(chuàng)建一個新的 Segment
  static Segment take() {
    synchronized (SegmentPool.class) {
      if (next != null) {
        Segment result = next;
        next = result.next;
        result.next = null;
        byteCount -= Segment.SIZE;
        return result;
      }
    }
    return new Segment(); // Pool is empty. Don't zero-fill while holding a lock.
  }
  //回收 segment 進行復用,提高效率
  static void recycle(Segment segment) {
    if (segment.next != null || segment.prev != null) throw new IllegalArgumentException();
    if (segment.shared) return; // This segment cannot be recycled.
    synchronized (SegmentPool.class) {
      if (byteCount + Segment.SIZE > MAX_SIZE) return; // Pool is full.
      byteCount += Segment.SIZE;
      segment.next = next;
      segment.pos = segment.limit = 0;
      next = segment;
    }
  }
}

SegmentPool 是一個緩存 Segment 的池,它有 64kb 大小也就是 8Segment 的長度。既然作為一個池,就和線程池的作用類似,為了復用前面被回收的 Segment。recycle() 方法的作用則是回收一個 Segment 對象。被回收的 Segment 對象將會被插入到 SegmentPool 中的單鏈表的頭部,以便后面繼續(xù)復用。

SegmentPool 的作用防止已申請的資源被回收,增加資源的重復利用,減少 GC,過于頻繁的 GC 是會降低性能的

可以看到 Okio 在內(nèi)存優(yōu)化上下了很大的功夫,提升了資源的利用率,從而提升了性能。

總結(jié)

不僅如此,Okio還提供其他很有用的功能:

比如提供了一系列的方便工具

  • GZip的透明處理
  • 對數(shù)據(jù)計算md5、sha1等都提供了支持,對數(shù)據(jù)校驗非常方便



作者:樹獺非懶

鏈接:https://juejin.cn/post/6923902848908394510文章來源地址http://www.zghlxwxcb.cn/news/detail-673413.html

到了這里,關于【轉(zhuǎn)】值得一用的 IO 神器 Okio的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章,希望大家以后多多支持TOY模板網(wǎng)!

本文來自互聯(lián)網(wǎng)用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。如若轉(zhuǎn)載,請注明出處: 如若內(nèi)容造成侵權/違法違規(guī)/事實不符,請點擊違法舉報進行投訴反饋,一經(jīng)查實,立即刪除!

領支付寶紅包贊助服務器費用

相關文章

  • 這么全的權限系統(tǒng)設計方案,不值得收藏嗎?

    這么全的權限系統(tǒng)設計方案,不值得收藏嗎?

    日常工作中權限的問題時時刻刻伴隨著我們,程序員新入職一家公司需要找人開通各種權限,比如網(wǎng)絡連接的權限、編碼下載提交的權限、監(jiān)控平臺登錄的權限、運營平臺查數(shù)據(jù)的權限等等。 在很多時候我們會覺得這么多繁雜的申請給工作帶來不便,并且如果突然想要查一些

    2024年04月28日
    瀏覽(16)
  • 程序員必用的6個代碼對比神器附下載地址

    程序員必用的6個代碼對比神器附下載地址

    一、WinMerge WinMerge是一款基于Windows系統(tǒng)下的文件比較和合并工具,使用它可以非常方便地比較多個文檔內(nèi)容,適合程序員或經(jīng)常需要撰寫文稿的朋友使用。WinMerge會將兩個文件內(nèi)容做對比,并在相異之處以高亮度的方式顯示,讓使用者可以很快的查知;可以直接讓左方的文件

    2024年02月12日
    瀏覽(15)
  • 小白和設計師都能用的 3D 渲染神器 #Rotato

    小白和設計師都能用的 3D 渲染神器 #Rotato

    “我非常喜歡它。它為我節(jié)省了很多時間, 而不必在 Adobe After Effects 等應用程序中掙扎?!?——Dominik Sobe on Product Hunt Rotato 是什么? Rotato 是一款功能強大的 3D 樣機渲染神器,支持 PNG 、JPG 、 avi、mov 、mp4 等多種格式。不僅能讓 0 基礎小白快速制作出 3D 動畫視頻,也能幫助

    2024年02月05日
    瀏覽(24)
  • 視頻剪輯軟件哪個好用?5款值得一試的神器!

    視頻剪輯軟件哪個好用?5款值得一試的神器!

    隨著數(shù)字化時代的到來,視頻已成為一種重要的溝通工具,越來越多的人需要使用電腦剪輯軟件來處理和編輯視頻。但是,市場上有很多電腦剪輯軟件,那么哪一個是最好的呢?在這篇文章中,我們將介紹五款電腦剪輯軟件,并詳細介紹它們的功能特點和適用人群。 1、 Ado

    2024年02月13日
    瀏覽(26)
  • 不到1分鐘,幫你剪完旅行vlog,火山引擎全新 AI「神器」真的這么絕?

    不到1分鐘,幫你剪完旅行vlog,火山引擎全新 AI「神器」真的這么絕?

    旅行時,想在社交平臺發(fā)布一支精美的旅行 vlog,拍攝剪輯需要花費多長時間? 20 分鐘?一小時?半天? 在火山引擎算法工程師眼里,可能 1 分鐘都用不了,因為會有 AI 替你完成。 沒錯,火山引擎近期推出了一款「創(chuàng)意互動 vlog」產(chǎn)品,你只需要在進入景區(qū)時注冊授權,A

    2024年02月16日
    瀏覽(21)
  • 微軟官方推出的四款工具,太實用了,值得收藏

    微軟官方推出的四款工具,太實用了,值得收藏

    目錄 一、Officeplus——豐富的辦公資源庫 二、微軟數(shù)學求解器 三、微軟內(nèi)置edge瀏覽器 四、Microsoft To-Do 辦公待辦神器 所以今天小編給大家分享4個微軟官方推出的實用工具,每一個都非常好用,對于大家日常辦公,非常有必要,感興趣的朋友可以下載試試! 網(wǎng)址 : (復制到

    2024年02月07日
    瀏覽(20)
  • YOLOv5、v7改進之二十八:ICLR 2022漲點神器——即插即用的動態(tài)卷積ODConv

    YOLOv5、v7改進之二十八:ICLR 2022漲點神器——即插即用的動態(tài)卷積ODConv

    前 言: 作為當前先進的深度學習目標檢測算法YOLOv5、v7系列算法,已經(jīng)集合了大量的trick,但是在處理一些復雜背景問題的時候,還是容易出現(xiàn)錯漏檢的問題。此后的系列文章,將重點對YOLO系列算法的如何改進進行詳細的介紹,目的是為了給那些搞科研的同學需要創(chuàng)新點或者

    2024年02月05日
    瀏覽(25)
  • SpringBoot官方筆記7IO

    Spring Boot auto-configures the cache infrastructure as long as caching support is enabled by using the? @EnableCaching ?annotation. Before invoking? computePiDecimal , the abstraction looks for an entry in the? piDecimals ?cache that matches the? i ?argument. If an entry is found, the content in the cache is immediately returned to the caller, and th

    2024年02月16日
    瀏覽(14)
  • 目標檢測算法——YOLOv5/v7/v8改進結(jié)合即插即用的動態(tài)卷積ODConv(小目標漲點神器)

    目標檢測算法——YOLOv5/v7/v8改進結(jié)合即插即用的動態(tài)卷積ODConv(小目標漲點神器)

    作者將CondConv中一個維度上的動態(tài)特性進行了擴展,同時了考慮了空域、輸入通道、輸出通道等維度上的動態(tài)性,故稱之為 全維度動態(tài)卷積 。ODConv通過并行策略采用多維注意力機制沿核空間的四個維度學習互補性注意力。 作為一種“即插即用”的操作,它可以輕易的嵌入到

    2024年01月19日
    瀏覽(28)
  • 重磅來襲,ChatGPT官方的掌上神器目前僅支持IOS

    重磅來襲,ChatGPT官方的掌上神器目前僅支持IOS

    今天凌晨,OpenAI 推出了 ChatGPT 的 iOS app,在這個開放的世界里,智能化的 AI 功能早已經(jīng)突破了人類的想象力。而 ChatGPT 確實不會讓我們失望,它的真「iPhone 時刻」來了!從現(xiàn)在起,我們可以在 iPhone 上使用 ChatGPT 了。 ? 編輯切換為居中 添加圖片注釋,不超過 140 字(可選)

    2024年02月05日
    瀏覽(24)

覺得文章有用就打賞一下文章作者

支付寶掃一掃打賞

博客贊助

微信掃一掃打賞

請作者喝杯咖啡吧~博客贊助

支付寶掃一掃領取紅包,優(yōu)惠每天領

二維碼1

領取紅包

二維碼2

領紅包