?

趙東陽

OpenHarmony TPC

一、okio的產生背景
?

二、兩個基本概念
?

三、okio的工作原理
?

如果Segment1的可讀數據比Segment2的剩余容量小，則把Segment1的數據復制到Segment2，然后回收Segment1到SegmentPool。

如果Segment1的可讀數據比Segment2的剩余容量大，那么直接修改Segment1的prev和next信息，將其添加到Segment2的后面。

（3） 從輸入流緩沖區獲取到Segment（假設為Segment3），如果只需要傳遞部分數據（比如總數據為4096字節，只傳遞1024字節），okio會通過split接口將Segment3拆分成含3072字節數據的Segment3-1和含1024字節數據的Segment3-2，然后按照（2）的邏輯將Segment3-2的數據寫入輸出流緩沖區。

?

?

拆分Segment的時候，可以通過參數指定拆分后的第一個Segment含有的未讀字節數（byteCount）。拆分后，第一個Segment包含的數據范圍是[pos,pos+byteCount)，第二個Segment包含的數據范圍是[pos+byteCount,limit)。拆分Segment時也遵循大塊數據移動、小塊數據復制的原則。當byteCount大于1024時，使用共享的Segment，否則復制數據。

（注：文件、流、socket相關的IO優化需要系統支持，待后續版本優化提供。）

?

2. Segment的回收與復用

接下來，我們再來看看SegmentPool是如何回收和復用Segment的。

每次okio想要獲取Segment就從SegmentPool中獲取，使用完畢后又會放回到SegmentPool中復用，核心方法為take()和recycle()。

（1）take()方法

take()方法負責從對象池單鏈表的頭部獲取可以使用的Segment。如果獲取不到，說明單鏈表是空的，此時新創建一個Segment給緩沖區使用。如果能獲取到，則取出單鏈表的頭部節點，再將下一個節點置為單鏈表的頭部節點，并將取出來的Segment的next置空，同時更新對象池大小。

（2）recycle()方法

recycle()方法負責回收緩沖區里面使用完畢的Segment?；厥臻_始時，首先更新對象池大小，然后把回收對象Segment添加到單鏈表頭部，接著重置Segment的pos和limit為0。注意，以下情況不會回收Segment：

●?當前Segment的prev和next不為空

●?當前Segment是共享的

●?對象池已經有8個Segment了

?

3. 字符串處理

除了Segment和SegmentPool外，okio還封裝了ByteString類來進行字符串處理。ByteString提供Base64編解碼、utf-8編碼、十六進制編解碼、大小寫轉換、內容比較等豐富的API，可以很方便地處理字符串。

在進行字符串處理時，由于ByteString同時持有原始字符串和對應的字節數組，可以直接使用字節數組里面的數據進行操作，不需要先將字符串轉換為字節數組。特別是在頻繁轉換編碼的場景下，通過這種以空間換時間的方式，可以避免字符串與字節數組的多次轉換，減少了時間和系統性能消耗。

?

四、okio的使用及示例

步驟一：在entry 的package.json文件中添加以下依賴項。

• ?
• ?
• ?

"dependencies": {    "okio": "^1.0.0"??}

• ?

npm config set @ohos:registry=https://repo.harmonyos.com/npm/

• ?
• ?

cd entrynpm?install?@ohos/okio

• ?

 import okio from '@ohos/okio';

• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?

 "reqPermissions": [      {        "name": "ohos.permission.WRITE_USER_STORAGE", //寫入用戶存儲的權限        "reason": "Storage",        "usedScene": {          "when": "always",          "ability": [            "com.example.okioapplication.MainAbility"
        }      },      {        "name": "ohos.permission.READ_USER_STORAGE", //讀取用戶存儲的權限        "reason": "Storage",        "usedScene": {          "when": "always",          "ability": [            "com.example.okioapplication.MainAbility"          ]        }      },      {        "name": "ohos.permission.WRITE_EXTERNAL_MEDIA_MEMORY", //寫入外部存儲的權限        "reason": "Storage",        "usedScene": {          "when": "always",          "ability": [            "com.example.okioapplication.MainAbility"          ]        }      }????]

2. 代碼實現

執行完上面的配置操作后，就可以進入代碼編寫階段了。開發者可以使用okio提供的豐富的API接口來實現功能。下面為大家展示四個實現示例，供大家參考學習。

示例1：文件寫入和讀取

?

?

本示例通過sink將內容寫入文件，通過source從文件讀取內容。代碼如下：

• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?
• ?

//通過sink將內容寫入文件var sink = new okio.Sink(this.fileUri);sink.write(this.Value,false); //通過source從文件讀取內容var source = new okio.Source(this.fileUri);source.read().then(function (data) { context.readValue = data;    }).catch(function (error) {console.log("error=>"+error);????});

示例2：Base64解碼?

?

?

本示例通過ByteString實現Base64解碼功能，代碼如下：

• ?
• ?
• ?

let byteStringObj = new okio.ByteString.ByteString(''); //生成ByteString對象let decodeBase64 = byteStringObj.decodeBase64('SGVsbG8gd29ybGQ='); //解碼Base64字符串this.decodeBase64Value?=?JSON.stringify(decodeBase64);?//顯示解碼結果

示例3：十六進制解碼

?

?

本示例通過ByteString實現十六進制解碼功能，代碼如下：

• ?
• ?
• ?

let byteStringObj = new okio.ByteString.ByteString('');let decodehex = byteStringObj.decodeHex('48656C6C6F20776F726C640D0A');this.decodeHexValue?=?JSON.stringify(decodehex);

示例4：Utf8編碼

?

?

本示例通過ByteString實現Utf8編碼功能，代碼如下：

• ?
• ?
• ?

let byteStringObj = new okio.ByteString.ByteString('');let encodeUtf8 = byteStringObj.encodeUtf8('Hello world #4  ( ????? ??)');this.encodeUtf8Value?=?JSON.stringify(encodeUtf8);

本期okio組件就為大家介紹到這里了。okio組件已開源，歡迎大家參與貢獻，開源地址如下：

https://gitee.com/openharmony-tpc/okio