一文瞭解io.ReadAtLeast函數

来源:https://www.cnblogs.com/chenjiazhan/archive/2023/07/14/17552655.html
-Advertisement-
Play Games

[toc] # 一、爬取目標 您好,我是[@馬哥python說](https://www.zhihu.com/people/13273183132),一名10年程式猿。 本次爬取的目標是:[知乎熱榜](https://www.zhihu.com/hot) ![知乎熱榜頁面](https://img2 ...


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函數的介紹,希望對你有所幫助。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 摘要:GaussDB (for Redis)通過賬號管理、許可權隔離、高危命令禁刪/重命名、安全IP免密登錄、實例回收站等企業級特性,保障用戶資料庫數據和信息安全。 本文分享自華為雲社區《數據安全沒保證?GaussDB(for Redis)為你保駕護航》,作者: GaussDB 資料庫。 近日,一些用 ...
  • 總結一下Hive面試寶典中的要點,方便讀者快速過一遍Hive面試所需要的知識點。本文請搭配 2023 Hive 面試寶典 來食用更美味喲 ...
  • #### 先說一些廢話 總結一下Hive面試寶典,方便讀者快速過一遍Hive面試所需要的知識點 ## Hive的介紹 ### Hive和Hadoop的關係 1. Hive利用hdfs存儲數據,利用MapReduce查詢數據 2. Hive的數據存儲在hdfs上,簡單的說Hive就是hdfs的簡單一種 ...
  • 基於tauri+vite4+pinia2跨端後臺管理系統應用實例TauriAdmin。 tauri-admin 基於最新跨端技術 Tauri Rust webview2 整合 Vite4 構建桌面端通用後臺管理解決方案。搭載輕量級ve-plus組件庫、支持多視窗切換管理、vue-i18n多語言包、動 ...
  • 數組的32中方法=>{ 1.push(): 在數組末尾添加一個或多個元素,並返回修改後的數組。 let fruits = ['apple', 'banana', 'orange']; fruits.push('mango'); console.log(fruits); // 輸出: ['apple' ...
  • Flutter是Google推出的一個開源的、高性能的移動應用開發框架,可以用一套代碼庫開發Android和iOS應用。Dart則是Flutter所使用的編程語言。讓我們來看看如何搭建Flutter開發環境,並瞭解Dart語言的基礎知識。 ...
  • # flex佈局 ## 上節複習 選擇器進階: 偽類選擇器: 當滿足特定條件時,激活對應的樣式 元素:hover{} 當滑鼠經過元素時,激活樣式 偽元素選擇器: 創建一個虛假的元素.不能被選中.不存在網頁dom中(安全性/性能) 元素::before{content:'內容'} 在元素前面添加內容 ...
  • 1.頁面結構 <!DOCTYPE html> <html> <head> <meta charset="UTF-8"> <title></title> </head> <body> </body> </html> 編碼:charset=“gbk” ;gbk2312,utf-8 註釋:<!-- 註釋內 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...