------------------------------------------------------------// bufio 包實(shí)現(xiàn)了帶緩存的 I/O 操作------------------------------------------------------------type Reader struct { ... }// NewReaderSize 將 rd 封裝成一個(gè)帶緩存的 bufio.Reader 對(duì)象， // 緩存大小由 size 指定（如果小于 16 則會(huì)被設(shè)置為 16）。 // 如果 rd 的基類型就是有足夠緩存的 bufio.Reader 類型，則直接將 // rd 轉(zhuǎn)換為基類型返回。 func NewReaderSize(rd io.Reader, size int) *Reader// NewReader 相當(dāng)于 NewReaderSize(rd, 4096) func NewReader(rd io.Reader) *Reader// bufio.Reader 實(shí)現(xiàn)了如下接口： // io.Reader // io.WriterTo // io.ByteScanner // io.RuneScanner// Peek 返回緩存的一個(gè)切片，該切片引用緩存中前 n 個(gè)字節(jié)的數(shù)據(jù)， // 該操作不會(huì)將數(shù)據(jù)讀出，只是引用，引用的數(shù)據(jù)在下一次讀取操作之 // 前是有效的。如果切片長(zhǎng)度小于 n，則返回一個(gè)錯(cuò)誤信息說(shuō)明原因。 // 如果 n 大于緩存的總大小，則返回 ErrBufferFull。 func (b *Reader) Peek(n int) ([]byte, error)// Read 從 b 中讀出數(shù)據(jù)到 p 中，返回讀出的字節(jié)數(shù)和遇到的錯(cuò)誤。 // 如果緩存不為空，則只能讀出緩存中的數(shù)據(jù)，不會(huì)從底層 io.Reader // 中提取數(shù)據(jù)，如果緩存為空，則： // 1、len(p) >= 緩存大小，則跳過緩存，直接從底層 io.Reader 中讀 // 出到 p 中。 // 2、len(p) < 緩存大小，則先將數(shù)據(jù)從底層 io.Reader 中讀取到緩存 // 中，再?gòu)木彺孀x取到 p 中。 func (b *Reader) Read(p []byte) (n int, err error)// Buffered 返回緩存中未讀取的數(shù)據(jù)的長(zhǎng)度。 func (b *Reader) Buffered() int// Discard 跳過后續(xù)的 n 個(gè)字節(jié)的數(shù)據(jù)，返回跳過的字節(jié)數(shù)。 // 如果結(jié)果小于 n，將返回錯(cuò)誤信息。 // 如果 n 小于緩存中的數(shù)據(jù)長(zhǎng)度，則不會(huì)從底層提取數(shù)據(jù)。 func (b *Reader) Discard(n int) (discarded int, err error)// ReadSlice 在 b 中查找 delim 并返回 delim 及其之前的所有數(shù)據(jù)。 // 該操作會(huì)讀出數(shù)據(jù)，返回的切片是已讀出的數(shù)據(jù)的引用，切片中的數(shù)據(jù) // 在下一次讀取操作之前是有效的。 // // 如果找到 delim，則返回查找結(jié)果，err 返回 nil。 // 如果未找到 delim，則： // 1、緩存不滿，則將緩存填滿后再次查找。 // 2、緩存是滿的，則返回整個(gè)緩存，err 返回 ErrBufferFull。 // // 如果未找到 delim 且遇到錯(cuò)誤（通常是 io.EOF），則返回緩存中的所 // 有數(shù)據(jù)和遇到的錯(cuò)誤。 // // 因?yàn)榉祷氐臄?shù)據(jù)有可能被下一次的讀寫操作修改，所以大多數(shù)操作應(yīng)該 // 使用 ReadBytes 或 ReadString，它們返回的是數(shù)據(jù)的拷貝。 func (b *Reader) ReadSlice(delim byte) (line []byte, err error)// ReadLine 是一個(gè)低水平的行讀取原語(yǔ)，大多數(shù)情況下，應(yīng)該使用 // ReadBytes('\n') 或 ReadString('\n')，或者使用一個(gè) Scanner。 // // ReadLine 通過調(diào)用 ReadSlice 方法實(shí)現(xiàn)，返回的也是緩存的切片。用于 // 讀取一行數(shù)據(jù)，不包括行尾標(biāo)記（\n 或 \r\n）。 // // 只要能讀出數(shù)據(jù)，err 就為 nil。如果沒有數(shù)據(jù)可讀，則 isPrefix 返回 // false，err 返回 io.EOF。 // // 如果找到行尾標(biāo)記，則返回查找結(jié)果，isPrefix 返回 false。 // 如果未找到行尾標(biāo)記，則： // 1、緩存不滿，則將緩存填滿后再次查找。 // 2、緩存是滿的，則返回整個(gè)緩存，isPrefix 返回 true。 // // 整個(gè)數(shù)據(jù)尾部“有一個(gè)換行標(biāo)記”和“沒有換行標(biāo)記”的讀取結(jié)果是一樣。 // // 如果 ReadLine 讀取到換行標(biāo)記，則調(diào)用 UnreadByte 撤銷的是換行標(biāo)記， // 而不是返回的數(shù)據(jù)。 func (b *Reader) ReadLine() (line []byte, isPrefix bool, err error)// ReadBytes 功能同 ReadSlice，只不過返回的是緩存的拷貝。 func (b *Reader) ReadBytes(delim byte) (line []byte, err error)// ReadString 功能同 ReadBytes，只不過返回的是字符串。 func (b *Reader) ReadString(delim byte) (line string, err error)// Reset 將 b 的底層 Reader 重新指定為 r，同時(shí)丟棄緩存中的所有數(shù)據(jù)，復(fù)位 // 所有標(biāo)記和錯(cuò)誤信息。 bufio.Reader。 func (b *Reader) Reset(r io.Reader)------------------------------// 示例：Peek、Read、Discard、Buffered func main() {sr := strings.NewReader("ABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890")buf := bufio.NewReaderSize(sr, 0)b := make([]byte, 10)fmt.Println(buf.Buffered()) // 0s, _ := buf.Peek(5)s[0], s[1], s[2] = 'a', 'b', 'c'fmt.Printf("%d %q\n", buf.Buffered(), s) // 16 "abcDE"buf.Discard(1)for n, err := 0, error(nil); err == nil; {n, err = buf.Read(b)fmt.Printf("%d %q %v\n", buf.Buffered(), b[:n], err)}// 5 "bcDEFGHIJK" <nil>// 0 "LMNOP" <nil>// 6 "QRSTUVWXYZ" <nil>// 0 "123456" <nil>// 0 "7890" <nil>// 0 "" EOF }------------------------------// 示例：ReadLine func main() {sr := strings.NewReader("ABCDEFGHIJKLMNOPQRSTUVWXYZ\n1234567890")buf := bufio.NewReaderSize(sr, 0)for line, isPrefix, err := []byte{0}, false, error(nil); len(line) > 0 && err == nil; {line, isPrefix, err = buf.ReadLine()fmt.Printf("%q %t %v\n", line, isPrefix, err)}// "ABCDEFGHIJKLMNOP" true <nil>// "QRSTUVWXYZ" false <nil>// "1234567890" false <nil>// "" false EOFfmt.Println("----------")// 尾部有一個(gè)換行標(biāo)記buf = bufio.NewReaderSize(strings.NewReader("ABCDEFG\n"), 0)for line, isPrefix, err := []byte{0}, false, error(nil); len(line) > 0 && err == nil; {line, isPrefix, err = buf.ReadLine()fmt.Printf("%q %t %v\n", line, isPrefix, err)}// "ABCDEFG" false <nil>// "" false EOFfmt.Println("----------")// 尾部沒有換行標(biāo)記buf = bufio.NewReaderSize(strings.NewReader("ABCDEFG"), 0)for line, isPrefix, err := []byte{0}, false, error(nil); len(line) > 0 && err == nil; {line, isPrefix, err = buf.ReadLine()fmt.Printf("%q %t %v\n", line, isPrefix, err)}// "ABCDEFG" false <nil>// "" false EOF }------------------------------// 示例：ReadSlice func main() {// 尾部有換行標(biāo)記buf := bufio.NewReaderSize(strings.NewReader("ABCDEFG\n"), 0)for line, err := []byte{0}, error(nil); len(line) > 0 && err == nil; {line, err = buf.ReadSlice('\n')fmt.Printf("%q %v\n", line, err)}// "ABCDEFG\n" <nil>// "" EOFfmt.Println("----------")// 尾部沒有換行標(biāo)記buf = bufio.NewReaderSize(strings.NewReader("ABCDEFG"), 0)for line, err := []byte{0}, error(nil); len(line) > 0 && err == nil; {line, err = buf.ReadSlice('\n')fmt.Printf("%q %v\n", line, err)}// "ABCDEFG" EOF }------------------------------------------------------------type Writer struct { ... }// NewWriterSize 將 wr 封裝成一個(gè)帶緩存的 bufio.Writer 對(duì)象， // 緩存大小由 size 指定（如果小于 4096 則會(huì)被設(shè)置為 4096）。 // 如果 wr 的基類型就是有足夠緩存的 bufio.Writer 類型，則直接將 // wr 轉(zhuǎn)換為基類型返回。 func NewWriterSize(wr io.Writer, size int) *Writer// NewWriter 相當(dāng)于 NewWriterSize(wr, 4096) func NewWriter(wr io.Writer) *Writer// bufio.Writer 實(shí)現(xiàn)了如下接口： // io.Writer // io.ReaderFrom // io.ByteWriter// WriteString 功能同 Write，只不過寫入的是字符串 func (b *Writer) WriteString(s string) (int, error)// WriteRune 向 b 寫入 r 的 UTF-8 編碼，返回 r 的編碼長(zhǎng)度。 func (b *Writer) WriteRune(r rune) (size int, err error)// Flush 將緩存中的數(shù)據(jù)提交到底層的 io.Writer 中 func (b *Writer) Flush() error// Available 返回緩存中未使用的空間的長(zhǎng)度 func (b *Writer) Available() int// Buffered 返回緩存中未提交的數(shù)據(jù)的長(zhǎng)度 func (b *Writer) Buffered() int// Reset 將 b 的底層 Writer 重新指定為 w，同時(shí)丟棄緩存中的所有數(shù)據(jù)，復(fù)位 // 所有標(biāo)記和錯(cuò)誤信息。相當(dāng)于創(chuàng)建了一個(gè)新的 bufio.Writer。 func (b *Writer) Reset(w io.Writer)------------------------------// 示例：Available、Buffered、WriteString、Flush func main() {buf := bufio.NewWriterSize(os.Stdout, 0)fmt.Println(buf.Available(), buf.Buffered()) // 4096 0buf.WriteString("ABCDEFGHIJKLMNOPQRSTUVWXYZ")fmt.Println(buf.Available(), buf.Buffered()) // 4070 26// 緩存后統(tǒng)一輸出，避免終端頻繁刷新，影響速度buf.Flush() // ABCDEFGHIJKLMNOPQRSTUVWXYZ }------------------------------------------------------------// ReadWriter 集成了 bufio.Reader 和 bufio.Writer type ReadWriter struct {*Reader*Writer }// NewReadWriter 將 r 和 w 封裝成一個(gè) bufio.ReadWriter 對(duì)象 func NewReadWriter(r *Reader, w *Writer) *ReadWriter------------------------------------------------------------// Scanner 提供了一個(gè)方便的接口來(lái)讀取數(shù)據(jù)，例如遍歷多行文本中的行。Scan 方法會(huì)通過 // 一個(gè)“匹配函數(shù)”讀取數(shù)據(jù)中符合要求的部分，跳過不符合要求的部分。“匹配函數(shù)”由調(diào) // 用者指定。本包中提供的匹配函數(shù)有“行匹配函數(shù)”、“字節(jié)匹配函數(shù)”、“字符匹配函數(shù)” // 和“單詞匹配函數(shù)”，用戶也可以自定義“匹配函數(shù)”。默認(rèn)的“匹配函數(shù)”為“行匹配函 // 數(shù)”，用于獲取數(shù)據(jù)中的一行內(nèi)容（不包括行尾標(biāo)記） // // Scanner 使用了緩存，所以匹配部分的長(zhǎng)度不能超出緩存的容量。默認(rèn)緩存容量為 4096 - // bufio.MaxScanTokenSize，用戶可以通過 Buffer 方法指定自定義緩存及其最大容量。 // // Scan 在遇到下面的情況時(shí)會(huì)終止掃描并返回 false（掃描一旦終止，將無(wú)法再繼續(xù)）： // 1、遇到 io.EOF // 2、遇到讀寫錯(cuò)誤 // 3、“匹配部分”的長(zhǎng)度超過了緩存的長(zhǎng)度 // // 如果需要對(duì)錯(cuò)誤進(jìn)行更多的控制，或“匹配部分”超出緩存容量，或需要連續(xù)掃描，則應(yīng)該 // 使用 bufio.Reader type Scanner struct { ... }// NewScanner 創(chuàng)建一個(gè) Scanner 來(lái)掃描 r，默認(rèn)匹配函數(shù)為 ScanLines。 func NewScanner(r io.Reader) *Scanner// Buffer 用于設(shè)置自定義緩存及其可擴(kuò)展范圍，如果 max 小于 len(buf)，則 buf 的尺寸將 // 固定不可調(diào)。Buffer 必須在第一次 Scan 之前設(shè)置，否則會(huì)引發(fā) panic。 // 默認(rèn)情況下，Scanner 會(huì)使用一個(gè) 4096 - bufio.MaxScanTokenSize 大小的內(nèi)部緩存。 func (s *Scanner) Buffer(buf []byte, max int)// Split 用于設(shè)置“匹配函數(shù)”，這個(gè)函數(shù)必須在調(diào)用 Scan 前執(zhí)行。 func (s *Scanner) Split(split SplitFunc)// SplitFunc 用來(lái)定義“匹配函數(shù)”，data 是緩存中的數(shù)據(jù)。atEOF 標(biāo)記數(shù)據(jù)是否讀完。 // advance 返回 data 中已處理的數(shù)據(jù)的長(zhǎng)度。token 返回找到的“匹配部分”，“匹配 // 部分”可以是緩存的切片，也可以是自己新建的數(shù)據(jù)（比如 bufio.errorRune）。“匹 // 配部分”將在 Scan 之后通過 Bytes 和 Text 反饋給用戶。err 返回錯(cuò)誤信息。 // // 如果在 data 中無(wú)法找到一個(gè)完整的“匹配部分”則應(yīng)返回 (0, nil, nil)，以便告訴 // Scanner 向緩存中填充更多數(shù)據(jù)，然后再次掃描（Scan 會(huì)自動(dòng)重新掃描）。如果緩存已 // 經(jīng)達(dá)到最大容量還沒有找到，則 Scan 會(huì)終止并返回 false。 // 如果 data 為空，則“匹配函數(shù)”將不會(huì)被調(diào)用，意思是在“匹配函數(shù)”中不必考慮 // data 為空的情況。 // // 如果 err != nil，掃描將終止，如果 err == ErrFinalToken，則 Scan 將返回 true， // 表示掃描正常結(jié)束，如果 err 是其它錯(cuò)誤，則 Scan 將返回 false，表示掃描出錯(cuò)。錯(cuò)誤 // 信息可以在 Scan 之后通過 Err 方法獲取。 // // SplitFunc 的作用很簡(jiǎn)單，從 data 中找出你感興趣的數(shù)據(jù)，然后返回，同時(shí)返回已經(jīng)處理 // 的數(shù)據(jù)的長(zhǎng)度。 type SplitFunc func(data []byte, atEOF bool) (advance int, token []byte, err error)// Scan 開始一次掃描過程，如果匹配成功，可以通過 Bytes() 或 Text() 方法取出結(jié)果， // 如果遇到錯(cuò)誤，則終止掃描，并返回 false。 func (s *Scanner) Scan() bool// Bytes 將最后一次掃描出的“匹配部分”作為一個(gè)切片引用返回，下一次的 Scan 操作會(huì)覆 // 蓋本次引用的內(nèi)容。 func (s *Scanner) Bytes() []byte// Text 將最后一次掃描出的“匹配部分”作為字符串返回（返回副本）。 func (s *Scanner) Text() string// Err 返回掃描過程中遇到的非 EOF 錯(cuò)誤，供用戶調(diào)用，以便獲取錯(cuò)誤信息。 func (s *Scanner) Err() error// ScanBytes 是一個(gè)“匹配函數(shù)”用來(lái)找出 data 中的單個(gè)字節(jié)并返回。 func ScanBytes(data []byte, atEOF bool) (advance int, token []byte, err error)// ScanRunes 是一個(gè)“匹配函數(shù)”，用來(lái)找出 data 中單個(gè) UTF8 字符的編碼。如果 UTF8 編 // 碼錯(cuò)誤，則 token 會(huì)返回 "\xef\xbf\xbd"（即：U+FFFD），但只消耗 data 中的一個(gè)字節(jié)。 // 這使得調(diào)用者無(wú)法區(qū)分“真正的U+FFFD字符”和“解碼錯(cuò)誤的返回值”。 func ScanRunes(data []byte, atEOF bool) (advance int, token []byte, err error)// ScanLines 是一個(gè)“匹配函數(shù)”，用來(lái)找出 data 中的單行數(shù)據(jù)并返回（包括空行）。 // 行尾標(biāo)記可以是 \n 或 \r\n（返回值不包含行尾標(biāo)記） func ScanLines(data []byte, atEOF bool) (advance int, token []byte, err error)// ScanWords 是一個(gè)“匹配函數(shù)”，用來(lái)找出 data 中以空白字符分隔的單詞。 // 空白字符由 unicode.IsSpace 定義。 func ScanWords(data []byte, atEOF bool) (advance int, token []byte, err error)------------------------------// 示例：掃描 func main() {// 逗號(hào)分隔的字符串，最后一項(xiàng)為空const input = "1,2,3,4,"scanner := bufio.NewScanner(strings.NewReader(input))// 定義匹配函數(shù)（查找逗號(hào)分隔的字符串）onComma := func(data []byte, atEOF bool) (advance int, token []byte, err error) {for i := 0; i < len(data); i++ {if data[i] == ',' {return i + 1, data[:i], nil}}if atEOF {// 告訴 Scanner 掃描結(jié)束。return 0, data, bufio.ErrFinalToken} else {// 告訴 Scanner 沒找到匹配項(xiàng)，讓 Scan 填充緩存后再次掃描。return 0, nil, nil}}// 指定匹配函數(shù)scanner.Split(onComma)// 開始掃描for scanner.Scan() {fmt.Printf("%q ", scanner.Text())}// 檢查是否因?yàn)橛龅藉e(cuò)誤而結(jié)束if err := scanner.Err(); err != nil {fmt.Fprintln(os.Stderr, "reading input:", err)} }------------------------------// 示例：帶檢查掃描 func main() {const input = "1234 5678 1234567901234567890 90"scanner := bufio.NewScanner(strings.NewReader(input))// 自定義匹配函數(shù)split := func(data []byte, atEOF bool) (advance int, token []byte, err error) {// 獲取一個(gè)單詞advance, token, err = bufio.ScanWords(data, atEOF)// 判斷其能否轉(zhuǎn)換為整數(shù)，如果不能則返回錯(cuò)誤if err == nil && token != nil {_, err = strconv.ParseInt(string(token), 10, 32)}// 這里包含了 return 0, nil, nil 的情況return}// 設(shè)置匹配函數(shù)scanner.Split(split)// 開始掃描for scanner.Scan() {fmt.Printf("%s\n", scanner.Text())}if err := scanner.Err(); err != nil {fmt.Printf("Invalid input: %s", err)} }------------------------------------------------------------

轉(zhuǎn)載于:https://www.cnblogs.com/golove/p/3282667.html

總結(jié)

以上是生活随笔為你收集整理的Golang学习 - bufio 包的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。