io包 copy

io包 copy - golang

在io包中主要是操作流的一些方法,今天主要學習一下copy。

在io包(golang 版本 1.12)中,提供了3個公開的copy方法:CopyN(),Copy(),CopyBuffer().

CopyN(dst,src,n) 為複製src 中 n 個字節到 dst。

Copy(dst,src) 為複製src 全部到 dst 中。

CopyBuffer(dst,src,buf)為指定一個buf緩存區,以這個大小完全複製。

他們的關係如下:

io包 copy - golang

從圖可以看出,無論是哪個copy方法最終都是由copyBuffer()這個私有方法實現的。下面我們看看這個方法的源碼。

 func copyBuffer(dst Writer, src Reader, buf []byte) (written int64, err error) {

\t// If the reader has a WriteTo method, use it to do the copy.

\t// Avoids an allocation and a copy.

\tif wt, ok := src.(WriterTo); ok {

\t\treturn wt.WriteTo(dst)

\t}

\t// Similarly, if the writer has a ReadFrom method, use it to do the copy.

\tif rt, ok := dst.(ReaderFrom); ok {

\t\treturn rt.ReadFrom(src)

\t}

\tif buf == nil {

\t\tsize := 32 * 1024

\t\tif l, ok := src.(*LimitedReader); ok && int64(size) > l.N {

\t\t\tif l.N < 1 {

\t\t\t\tsize = 1

\t\t\t} else {

\t\t\t\tsize = int(l.N)

\t\t\t}

\t\t}

\t\tbuf = make([]byte, size)

\t}

\tfor {

\t\tnr, er := src.Read(buf)

\t\tif nr > 0 {

\t\t\tnw, ew := dst.Write(buf[0:nr])

\t\t\tif nw > 0 {

\t\t\t\twritten += int64(nw)

\t\t\t}

\t\t\tif ew != nil {

\t\t\t\terr = ew

\t\t\t\tbreak

\t\t\t}

\t\t\tif nr != nw {

\t\t\t\terr = ErrShortWrite

\t\t\t\tbreak

\t\t\t}

\t\t}

\t\tif er != nil {

\t\t\tif er != EOF {

\t\t\t\terr = er

\t\t\t}

\t\t\tbreak

\t\t}

\t}

\treturn written, err

}

從這部分代碼可以看出,複製主要分為3種。

1.如果被複制的Reader(src)會嘗試能否斷言成writerTo,如果可以則直接調用下面的writerTo方法

2.如果 Writer(dst) 會嘗試能否斷言成ReadFrom ,如果可以則直接調用下面的readfrom方法

3.如果都木有實現,則調用底層read實現複製。

其中,有這麼一段代碼:

if buf == nil {

\t\tsize := 32 * 1024

\t\tif l, ok := src.(*LimitedReader); ok && int64(size) > l.N {

\t\t\tif l.N < 1 {

\t\t\t\tsize = 1

\t\t\t} else {

\t\t\t\tsize = int(l.N)

\t\t\t}

\t\t}

\t\tbuf = make([]byte, size)

\t}

這部分主要是實現了對Copy和CopyN的處理。通過上面的調用關係圖,我們看出CopyN在調用後,會把Reader轉成LimiteReader。

區別是如果Copy,直接建立一個緩存區默認大小為 32* 1024 的buf,如果是CopyN 會先判斷 要複製的字節數 如果小於默認大小,會創建一個等於要複製字節數的buf。


分享到:


相關文章: