GO語言的IO方法實(shí)例小結(jié)
type PipeWriter
type PipeWriter struct {
// contains filtered or unexported fields
}
(1)func (w *PipeWriter) Close() error關(guān)閉管道，關(guān)閉時(shí)正在進(jìn)行的Read操作將返回EOF，若管道內(nèi)仍有未讀取的數(shù)據(jù)，后續(xù)仍可正常讀取
import (
"fmt"
"io"
)
func main() {
r, w := io.Pipe()
go w.Write([]byte("hello word"))
data := make([]byte, 10)
n, err := r.Read(data)
w.Close()
if err == io.EOF {
fmt.Println("executing read return EOF")
fmt.Println("executing read reads number", n)
}
n, _ = r.Read(data)
fmt.Println(string(data)) //hello word
fmt.Println("next read number", n) //next read number 0
}
(2)func (w *PipeWriter) CloseWithError(err error) error這個(gè)函數(shù)和read里邊的CloseWithError是大同小異的，關(guān)閉管道，關(guān)閉時(shí)正在進(jìn)行的Read操作將返回參數(shù)傳入的異常，若管道內(nèi)仍有未讀取的數(shù)據(jù)，后續(xù)仍可正常讀取
import (
"errors"
"fmt"
"io"
)
func main() {
r, w := io.Pipe()
go w.Write([]byte("hello widuu"))
newerr := errors.New("your daye 突然關(guān)閉了")
w.CloseWithError(newerr)
data := make([]byte, 10)
_, err := r.Read(data)
if err != nil {
fmt.Println(err) //your daye 突然關(guān)閉了
}
}
(3)func (w *PipeWriter) Write(data []byte) (n int, err error)終于來打write了，這個(gè)是把字節(jié)切片寫入管道，返回的是寫入字節(jié)數(shù)和error,前邊用到的太多了，隨便哪一個(gè)吧
import (
"fmt"
"io"
)
func main() {
r, w := io.Pipe()
go w.Write([]byte("hello widuu")) //寫入的是[]byte,注意官方文檔寫的是，寫入管道阻塞，一直到所有數(shù)據(jù)的讀取結(jié)束
data := make([]byte, 11)
n, _ := r.Read(data)
fmt.Println(string(data)) //hello widuu
fmt.Println("read number", n) //read number 10
}
type Reader
type Reader interface {
Read(p []byte) (n int, err error)
}
(1)func LimitReader(r Reader, n int64) Reader，我們之前就說了Reader這個(gè)結(jié)構(gòu)，其實(shí)這就是對(duì)Reader的一次封裝，限定了它讀取字節(jié)數(shù)，其實(shí)他實(shí)現(xiàn)的就是io.LimitedReader{}這個(gè)結(jié)構(gòu)
import (
"fmt"
"io"
"os"
"reflect"
)
func main() {
f, _ := os.Open("test.txt")
defer f.Close()
reader := io.LimitReader(f, 5)
p := make([]byte, 5)
fmt.Println(reflect.TypeOf(reader)) //*io.LimitedReader
var total int
for {
n, err := reader.Read(p)
if err == io.EOF {
fmt.Println("read value", string(p[:total])) //read value hello
fmt.Println(total) //5
break
}
total = total + n
}
}
(2)func MultiReader(readers ...Reader) Reader這個(gè)函數(shù)一看就知道是封裝了多個(gè)readers,跟上邊的方法差不多，只是封裝了多個(gè)而已，當(dāng)然還去除了讀取的限制，我們代碼給大家測(cè)試一下
import (
"fmt"
"io"
"os"
"reflect"
)
func main() {
f1, _ := os.Open("test1.txt")
f2, _ := os.Open("test.txt")
defer f1.Close()
defer f2.Close()
reader := io.MultiReader(f1, f2) //*io.multiReader
fmt.Println(reflect.TypeOf(reader))
p := make([]byte, 10)
var total int
var data string
for {
n, err := reader.Read(p)
if err == io.EOF {
fmt.Println("read end", total) //read end 17
break
}
total = total + n
data = data + string(p[:n])
}
fmt.Println("read value", data) //read value widuu2hello widuu
fmt.Println("read count", total) // read count 17
}
(3)既然上邊介紹讀了，我這介紹個(gè)寫吧type Write`func MultiWriter(writers ...Writer) Writer一樣的作用只不過是這次換成寫了
import (
"fmt"
"io"
"io/ioutil"
"os"
)
func main() {
f1, _ := os.Create("1.txt")
f2, _ := os.Create("2.txt")
writer := io.MultiWriter(f1, f2)
writer.Write([]byte("widuu"))
//千萬別這么邏輯來 ，我這是測(cè)試用的哈
r1, _ := ioutil.ReadFile("1.txt")
r2, _ := ioutil.ReadFile("2.txt")
fmt.Println(string(r1)) //widuu
fmt.Println(string(r2)) //widuu
}
(4)func TeeReader(r Reader, w Writer) Reader這個(gè)方法有意思是從r中讀取數(shù)據(jù)然后寫入到w中，這個(gè)沒有內(nèi)部緩沖區(qū)，看下代碼
import (
"fmt"
"io"
"os"
"reflect"
)
func main() {
r, _ := os.Open("test.txt")
w, _ := os.Create("test2.txt")
reader := io.TeeReader(r, w)
fmt.Println(reflect.TypeOf(reader)) //*io.teeReader
p := make([]byte, 10)
n, _ := reader.Read(p)
fmt.Println(string(p[:n])) //hello widu
}
type SectionReader{}
type SectionReader struct {
// contains filtered or unexported fields
}
(1)func NewSectionReader(r ReaderAt, off int64, n int64) *SectionReader，你一看就知道了，其實(shí)就是通過這個(gè)方法獲取到io.SectionReader,第一個(gè)參數(shù)讀取器，第二個(gè)參數(shù)偏移量，第三個(gè)參數(shù)是讀取多少
import (
"fmt"
"io"
"os"
"reflect"
)
func main() {
f, _ := os.Open("test.txt")
sr := io.NewSectionReader(f, 2, 5)
fmt.Println(reflect.TypeOf(sr)) //*io.SectionReader
}
(2)func (s *SectionReader) Read(p []byte) (n int, err error)熟悉的read()其實(shí)就是讀取數(shù)據(jù)用的，大家看函數(shù)就可以理解了，因?yàn)樵蹅兘?jīng)常遇到這個(gè)上兩個(gè)都寫這個(gè)了~~
import (
"fmt"
"io"
"os"
)
func main() {
f, _ := os.Open("test.txt")
defer f.Close()
sr := io.NewSectionReader(f, 2, 5)
p := make([]byte, 10)
n, err := sr.Read(p)
if err != nil {
fmt.Println(err)
}
fmt.Println(string(p[:n])) //llo w
}
(3)func (s *SectionReader) ReadAt(p []byte, off int64) (n int, err error)額這個(gè)跟之前的ReadAt是一樣的，只不過只有一個(gè)偏移量，少了截取數(shù)，但是你要知道SectionReader做的是什么就把數(shù)據(jù)截取了，所以就不需要截取數(shù)了
import (
"fmt"
"io"
"os"
)
func main() {
f, _ := os.Open("test.txt")
defer f.Close()
sr := io.NewSectionReader(f, 2, 5)
p := make([]byte, 10)
n, err := sr.ReadAt(p, 1)
if err == io.EOF {
fmt.Println(string(p[:n])) // lo w
}
}
(4)func (s *SectionReader) Seek(offset int64, whence int) (int64, error)這個(gè)是設(shè)置文件指針的便宜量的，之前我們的os里邊也是有個(gè)seek的，對(duì)SectionReader的讀取起始點(diǎn)、當(dāng)前讀取點(diǎn)、結(jié)束點(diǎn)進(jìn)行偏移，offset 偏移量，whence 設(shè)定選項(xiàng) 0:讀取起始點(diǎn)，1:當(dāng)前讀取點(diǎn)，2:結(jié)束點(diǎn)(不好用)，其他：將拋出Seek: invalid whence異常
import (
"fmt"
"io"
"os"
)
func main() {
f, _ := os.Open("test.txt")
defer f.Close()
sr := io.NewSectionReader(f, 2, 5)
p := make([]byte, 10)
sr.Seek(1, 0) //相當(dāng)于起始的地址偏移1
n, err := sr.Read(p)
if err != nil {
fmt.Println(err)
}
fmt.Println(string(p[:n])) //lo w 是不是達(dá)到了前邊的ReadAt()
}
(5)func (s *SectionReader) Size() int64返回的是可以讀取的字節(jié)數(shù)，這個(gè)不受偏移指針的影響，也不受當(dāng)前讀取的影響，我們具體看下代碼
import (
"fmt"
"io"
"os"
)
func main() {
f, _ := os.Open("test.txt")
defer f.Close()
sr := io.NewSectionReader(f, 2, 5)
fmt.Println(sr.Size()) //5
p := make([]byte, 10)
sr.Seek(1, 0) //相當(dāng)于起始的地址偏移1
n, err := sr.Read(p)
if err != nil {
fmt.Println(err)
}
fmt.Println(string(p[:n])) //lo w
fmt.Println(sr.Size()) //5
}
相關(guān)文章
golang實(shí)現(xiàn)命令行程序的使用幫助功能
這篇文章介紹了golang實(shí)現(xiàn)命令行程序使用幫助的方法，文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-07-07
這篇文章主要為大家詳細(xì)介紹了Golang進(jìn)行單元測(cè)試時(shí)的一些技巧和科技，文中的示例代碼講解詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴可以了解一下2023-03-03
隨著業(yè)務(wù)的發(fā)展,自己對(duì)代碼的審美的改變,我們不斷的迭代這些代碼,代碼量可以說是與日俱增,代碼的某些結(jié)構(gòu)也會(huì)發(fā)生大大小的改變,這些都要求我們?cè)陂喿x代碼的時(shí)候,需要更快的效率和技巧2024-01-01
go語言題解LeetCode674最長(zhǎng)連續(xù)遞增序列
這篇文章主要為大家介紹了go語言題解LeetCode674最長(zhǎng)連續(xù)遞增序列示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-12-12
詳解Go語言如何實(shí)現(xiàn)類似Python中的with上下文管理器
熟悉?Python?的同學(xué)應(yīng)該知道?Python?中的上下文管理器非常好用，那么在?Go?中是否也能實(shí)現(xiàn)上下文管理器呢，下面小編就來和大家仔細(xì)講講吧2023-07-07
在?Go?語言中,雖然沒有像?Java?或?Python?那樣的傳統(tǒng)集合框架,但也可以非常高效地處理集合操作,下面小編就來和大家講講具體處理方法吧2025-01-01
golang類型轉(zhuǎn)換之interface轉(zhuǎn)字符串string簡(jiǎn)單示例
在我們使用Golang進(jìn)行開發(fā)過程中,總是繞不開對(duì)字符或字符串的處理,這篇文章主要給大家介紹了關(guān)于golang類型轉(zhuǎn)換之interface轉(zhuǎn)字符串string的相關(guān)資料,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2024-01-01
這篇文章主要為大家詳細(xì)介紹了如何在Go語言中生成隨機(jī)種子,文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,有需要的小伙伴可以參考一下2024-04-04
在Go語言中，Context（上下文）是一個(gè)類型，用于在程序中傳遞請(qǐng)求范圍的值、截止時(shí)間、取消信號(hào)和其他與請(qǐng)求相關(guān)的上下文信息,它在多個(gè)goroutine之間傳遞這些值，使得并發(fā)編程更加可靠和簡(jiǎn)單,本文詳細(xì)介紹go語言的Context,需要的朋友可以參考下2023-05-05
golang中cache組件的使用及groupcache源碼解析
本篇主要解析groupcache源碼中的關(guān)鍵部分， lru的定義以及如何做到同一個(gè)key只加載一次。緩存填充以及加載抑制的實(shí)現(xiàn)方法，本文重點(diǎn)給大家介紹golang中cache組件的使用及groupcache源碼解析，感興趣的朋友一起看看吧2021-06-06