一文了解io.ReadAtLeast函數

2023-07-14 09:00:59

1. 引言

io.ReadAtLeast 函數是Go標準庫提供的一個非常好用的函數,能夠指定從資料來源最少讀取到的位元組數。本文我們將從io.ReadAtLeast 函數的基本定義出發,講述其基本使用和實現原理,以及一些注意事項,基於此完成對io.ReadAtLeast 函數的介紹。

2. 基本說明

2.1 基本定義

io.ReadAtLeast 函數用於從讀取器(io.Reader)讀取至少指定數量的位元組資料到緩衝區中。函數定義如下:

func ReadAtLeast(r Reader, buf []byte, min int) (n int, err error)

其中r 是資料來源,從它讀取資料,而buf是用於接收讀取到的資料的位元組切片,min是要讀取的最小位元組數。io.ReadAtLeast 函數會嘗試從讀取器中最少讀取 min 個位元組的資料,並將其儲存在 buf 中。

2.2 使用範例

下面是一個範例程式碼,演示如何使用 io.ReadAtLeast 函數從標準輸入讀取至少 5 個位元組的資料:

package main

import (
        "fmt"
        "io"
        "os"
)

func main() {
        buffer := make([]byte, 10)

        n, err := io.ReadAtLeast(os.Stdin, buffer, 5)
        if err != nil {
                fmt.Println("讀取過程中發生錯誤:", err)
                return
        }

        fmt.Printf("成功讀取了 %d 個位元組:%s\n", n, buffer)
}

在這個例子中,我們建立了一個長度為 10 的位元組切片 buffer,並使用 io.ReadAtLeast 函數從標準輸入讀取至少 5 個位元組的資料到 buffer 中。下面是一個可能的輸出,具體如下:

hello,world
成功讀取了 10 個位元組:hello,worl

這裡其指定 min 為5,也就是最少讀取5個位元組的資料,此時呼叫io.ReadAtLeast函數一次性讀取到了10個位元組的資料,此時也滿足要求。這裡也間接說明了io.ReadAtLeast只保證最少要讀取min個位元組的資料,但是並不限制更多資料的讀取。

3. 實現原理

在瞭解了io.ReadAtLeast 函數的基本定義和使用後,這裡我們來對io.ReadAtLeast 函數的實現來進行基本的說明,加深對io.ReadAtLeast 函數的理解。

其實 io.ReadAtLeast 的實現非常簡單,其定義一個變數n, 儲存了讀取到的位元組數,然後不斷呼叫資料來源Reader中的 Read 方法讀取資料,然後自增變數n 的值,直到 n 大於 最小讀取位元組數為止。下面來看具體程式碼的實現:

func ReadAtLeast(r Reader, buf []byte, min int) (n int, err error) {
   // 傳入的緩衝區buf長度 小於 最小讀取位元組數min的值,此時直接返回錯誤
   if len(buf) < min {
      return 0, ErrShortBuffer
   }
   // 在 n < min 時,不斷呼叫Read方法讀取資料
   // 最多讀取 len(buf) 位元組的資料
   for n < min && err == nil {
      var nn int
      nn, err = r.Read(buf[n:])
      // 自增 n 的值
      n += nn
   }
   if n >= min {
      err = nil
   } else if n > 0 && err == EOF {
      // 讀取到的資料位元組數 小於 min值,同時資料已經全部讀取完了,此時返回 ErrUnexpectedEOF
      err = ErrUnexpectedEOF
   }
   return
}

4. 注意事項

4.1 注意無限等待情況的出現

從上面io.ReadAtLeast 的實現可以看出來,如果一直沒有讀取到指定數量的資料,同時也沒有發生錯誤,將一直等待下去,直到讀取到至少指定數量的位元組資料,或者遇到錯誤為止。下面舉個程式碼範例來展示下效果:

func main() {
   buffer := make([]byte, 5)
   n, err := io.ReadAtLeast(os.Stdin, buffer, 5)
   if err != nil {
      fmt.Println("讀取過程中發生錯誤:", err)
      return
   }

   fmt.Printf("成功讀取了 %d 個位元組:%s\n", n, buffer)
}

在上面程式碼的例子中,會呼叫io.ReadAtLeast 函數從標準輸入中讀取 5 個位元組的資料,如果標準輸入一直沒有輸夠5個位元組,此時這個函數將會一直等待下去。比如下面的這個輸入,首先輸入了he兩個字元,然後回車,由於還沒有達到5個字元,此時io.ReadAtLeast函數一直不會返回,只有再輸入llo這幾個字元后,才滿足5個字元,才能夠繼續執行,所以在使用io.ReadAtLeast函數時,需要注意無限等待的情況。

he
llo
成功讀取了 5 個位元組:he
ll

4.2 確保 buf 的大小足夠容納至少 min 個位元組的資料

在呼叫io.ReadAtLeast函數時,需要保證緩衝區buf的大小需要滿足min,如果緩衝區的大小比 min 引數還小的話,此時將永遠滿足不了 最少讀取 min個位元組資料的要求。

從上面io.ReadAtLeast 的實現可以看出來,如果其發現buf的長度小於 min,其也不會嘗試去讀取資料,其會直接返回一個ErrShortBuffer 的錯誤,下面通過一個程式碼展示下效果:

func main() {
   buffer := make([]byte, 3)
   n, err := io.ReadAtLeast(os.Stdin, buffer, 5)
   if err != nil {
      fmt.Println("讀取過程中發生錯誤:", err)
      return
   }

   fmt.Printf("成功讀取了 %d 個位元組:%s\n", n, buffer)
}

比如上述函數中,指定的buffer的長度為3,但是io.ReadAtLeast要求最少讀取5個位元組,此時buffer並不能容納5個位元組的資料,此時將會直接ErrShortBuffer錯誤,如下:

讀取過程中發生錯誤: short buffer

5. 總結

io.ReadAtLeast函數是Go語言標準庫提供的一個工具函數,能夠從資料來源讀取至少指定數量的位元組資料到緩衝區中。 我們先從 io.ReadAtLeast 函數的基本定義出發,之後通過一個簡單的範例,展示如何使用io.ReadAtLeast函數實現至少讀取指定位元組資料。

接著我們講述了io.ReadAtLeast函數的實現原理,其實就是不斷呼叫源Reader的Read方法,直接讀取到的資料數滿足要求。

在注意事項方面,則強調了呼叫io.ReadAtLeast 可能出現無限等待的問題,以及需要確保 buf 的大小足夠容納至少 min 個位元組的資料。

基於此,完成了對io.ReadAtLeast函數的介紹,希望對你有所幫助。