1. 程式人生 > 其它 >Golang讀寫檔案操作

Golang讀寫檔案操作

最近在使用Golang進行檔案讀寫的過程中,遇到幾個細節問題導致程式寫入資料時有一定髒資料的殘留,最後發現是使用os.OpenFile在進行檔案操作的時候沒有使用正確的flag造成的。因此專門去學習了下Golang中讀寫檔案的幾種方式方法,在此記錄下一些簡單的操作,防止以後遺忘。

讀檔案

使用golang語言去讀取一個檔案預設會有多種方式,這裡主要介紹以下幾種。

使用ioutil直接讀取

需要引入io/ioutil包,該包預設擁有以下函式供使用者呼叫。

func NopCloser(r io.Reader) io.ReadCloser
func ReadAll(r io.Reader) ([]byte, error)
func ReadDir(dirname string) ([]os.FileInfo, error)
func ReadFile(filename string) ([]byte, error)
func TempDir(dir, prefix string) (name string, err error)
func TempFile(dir, prefix string) (f *os.File, err error)
func WriteFile(filename string, data []byte, perm os.FileMode) error

讀檔案,我們可以看以下三個函式:

//從一個io.Reader型別中讀取內容直到返回錯誤或者EOF時返回讀取的資料,當err == nil時,資料成功讀取到[]byte中
//ReadAll函式被定義為從源中讀取資料直到EOF,它是不會去從返回資料中去判斷EOF來作為讀取成功的依據
func ReadAll(r io.Reader) ([]byte, error)

//讀取一個目錄,並返回一個當前目錄下的檔案物件列表和錯誤資訊
func ReadDir(dirname string) ([]os.FileInfo, error)

//讀取檔案內容,並返回[]byte資料和錯誤資訊。err == nil時,讀取成功
func ReadFile(filename string) ([]byte, error)

讀取檔案示例:

$ cat readfile.go
package main
import (
    "fmt"
    "io/ioutil"
    "strings"
)
func main() {
   Ioutil("mytestfile.txt")
    }

func Ioutil(name string) {
    if contents,err := ioutil.ReadFile(name);err == nil {
        //因為contents是[]byte型別,直接轉換成string型別後會多一行空格,需要使用strings.Replace替換換行符
        result := strings.Replace(string(contents),"n","",1)
        fmt.Println(result)
        }
    }

$ go run readfile.go
xxbandy.github.io @by Andy_xu

藉助os.Open進行讀取檔案

由於os.Open是開啟一個檔案並返回一個檔案物件,因此其實可以結合ioutil.ReadAll(r io.Reader)來進行讀取。 io.Reader其實是一個包含Read方法的介面型別,而檔案物件本身是實現了了Read方法的。

我們先來看下os.Open家族的相關函式

//開啟一個需要被讀取的檔案,如果成功讀取,返回的檔案物件將可用被讀取,該函式預設的許可權為O_RDONLY,也就是隻對檔案有隻讀許可權。如果有錯誤,將返回*PathError型別
func Open(name string) (*File, error)

//大部分使用者會選擇該函式來代替Open or Create函式。該函式主要用來指定引數(os.O_APPEND|os.O_CREATE|os.O_WRONLY)以及檔案許可權(0666)來開啟檔案,如果開啟成功返回的檔案物件將被用作I/O操作
func OpenFile(name string, flag int, perm FileMode) (*File, error)

使用os.Open家族函式和ioutil.ReadAll()讀取檔案示例:

func OsIoutil(name string) {
      if fileObj,err := os.Open(name);err == nil {
      //if fileObj,err := os.OpenFile(name,os.O_RDONLY,0644); err == nil {
        defer fileObj.Close()
        if contents,err := ioutil.ReadAll(fileObj); err == nil {
            result := strings.Replace(string(contents),"n","",1)
            fmt.Println("Use os.Open family functions and ioutil.ReadAll to read a file contents:",result)
            }

        }
}

# 在main函式中呼叫OsIoutil(name)函式就可以讀取檔案內容了
$ go run readfile.go
Use os.Open family functions and ioutil.ReadAll to read a file contents: xxbandy.github.io @by Andy_xu

然而上述方式會比較繁瑣一些,因為使用了os的同時藉助了ioutil,但是在讀取大檔案的時候還是比較有優勢的。不過讀取小檔案可以直接使用檔案物件的一些方法。

不論是上邊說的os.Open還是os.OpenFile他們最終都返回了一個*File檔案物件,而該檔案物件預設是有很多方法的,其中讀取檔案的方法有如下幾種:

//從檔案物件中讀取長度為b的位元組,返回當前讀到的位元組數以及錯誤資訊。因此使用該方法需要先初始化一個符合內容大小的空的位元組列表。讀取到檔案的末尾時,該方法返回0,io.EOF
func (f *File) Read(b []byte) (n int, err error)

//從檔案的off偏移量開始讀取長度為b的位元組。返回讀取到位元組數以及錯誤資訊。當讀取到的位元組數n小於想要讀取位元組的長度len(b)的時候,該方法將返回非空的error。當讀到檔案末尾時,err返回io.EOF
func (f *File) ReadAt(b []byte, off int64) (n int, err error)

使用檔案物件的Read方法讀取:

func FileRead(name string) {
    if fileObj,err := os.Open(name);err == nil {
        defer fileObj.Close()
        //在定義空的byte列表時儘量大一些,否則這種方式讀取內容可能造成檔案讀取不完整
        buf := make([]byte, 1024)
        if n,err := fileObj.Read(buf);err == nil {
               fmt.Println("The number of bytes read:"+strconv.Itoa(n),"Buf length:"+strconv.Itoa(len(buf)))
               result := strings.Replace(string(buf),"n","",1)
               fmt.Println("Use os.Open and File's Read method to read a file:",result)
            }
    }
}

使用os.Openbufio.Reader讀取檔案內容

bufio包實現了快取IO,它本身包裝了io.Readerio.Writer物件,建立了另外的Reader和Writer物件,不過該種方式是帶有快取的,因此對於文字I/O來說,該包是提供了一些便利的。

先看下bufio模組下的相關的Reader函式方法:

//首先定義了一個用來緩衝io.Reader物件的結構體,同時該結構體擁有以下相關的方法
type Reader struct {
}

//NewReader函式用來返回一個預設大小buffer的Reader物件(預設大小好像是4096) 等同於NewReaderSize(rd,4096)
func NewReader(rd io.Reader) *Reader

//該函式返回一個指定大小buffer(size最小為16)的Reader物件,如果 io.Reader引數已經是一個足夠大的Reader,它將返回該Reader
func NewReaderSize(rd io.Reader, size int) *Reader


//該方法返回從當前buffer中能被讀到的位元組數
func (b *Reader) Buffered() int

//Discard方法跳過後續的 n 個位元組的資料,返回跳過的位元組數。如果0 <= n <= b.Buffered(),該方法將不會從io.Reader中成功讀取資料。
func (b *Reader) Discard(n int) (discarded int, err error)

//Peekf方法返回快取的一個切片,該切片只包含快取中的前n個位元組的資料
func (b *Reader) Peek(n int) ([]byte, error)

//把Reader快取物件中的資料讀入到[]byte型別的p中,並返回讀取的位元組數。讀取成功,err將返回空值
func (b *Reader) Read(p []byte) (n int, err error)

//返回單個位元組,如果沒有資料返回err
func (b *Reader) ReadByte() (byte, error)

//該方法在b中讀取delimz之前的所有資料,返回的切片是已讀出的資料的引用,切片中的資料在下一次的讀取操作之前是有效的。如果未找到delim,將返回查詢結果並返回nil空值。因為快取的資料可能被下一次的讀寫操作修改,因此一般使用ReadBytes或者ReadString,他們返回的都是資料拷貝
func (b *Reader) ReadSlice(delim byte) (line []byte, err error)

//功能同ReadSlice,返回資料的拷貝
func (b *Reader) ReadBytes(delim byte) ([]byte, error)

//功能同ReadBytes,返回字串
func (b *Reader) ReadString(delim byte) (string, error)

//該方法是一個低水平的讀取方式,一般建議使用ReadBytes('n') 或 ReadString('n'),或者使用一個 Scanner來代替。ReadLine 通過呼叫 ReadSlice 方法實現,返回的也是快取的切片,用於讀取一行資料,不包括行尾標記(n 或 rn)
func (b *Reader) ReadLine() (line []byte, isPrefix bool, err error)

//讀取單個UTF-8字元並返回一個rune和位元組大小
func (b *Reader) ReadRune() (r rune, size int, err error)

示例:

func BufioRead(name string) {
    if fileObj,err := os.Open(name);err == nil {
        defer fileObj.Close()
        //一個檔案物件本身是實現了io.Reader的 使用bufio.NewReader去初始化一個Reader物件,存在buffer中的,讀取一次就會被清空
        reader := bufio.NewReader(fileObj)
        //使用ReadString(delim byte)來讀取delim以及之前的資料並返回相關的字串.
        if result,err := reader.ReadString(byte('@'));err == nil {
            fmt.Println("使用ReadSlince相關方法讀取內容:",result)
        }
        //注意:上述ReadString已經將buffer中的資料讀取出來了,下面將不會輸出內容
        //需要注意的是,因為是將檔案內容讀取到[]byte中,因此需要對大小進行一定的把控
        buf := make([]byte,1024)
        //讀取Reader物件中的內容到[]byte型別的buf中
        if n,err := reader.Read(buf); err == nil {
            fmt.Println("The number of bytes read:"+strconv.Itoa(n))
            //這裡的buf是一個[]byte,因此如果需要只輸出內容,仍然需要將檔案內容的換行符替換掉
            fmt.Println("Use bufio.NewReader and os.Open read file contents to a []byte:",string(buf))
        }


    }
}

讀檔案所有方式示例

/**
 * @File Name: readfile.go
 * @Author:
 * @Email:
 * @Create Date: 2017-12-16 16:12:01
 * @Last Modified: 2017-12-17 12:12:02
 * @Description:讀取指定檔案的幾種方法,需要注意的是[]byte型別在轉換成string型別的時候,都會在最後多一行空格,需要使用result := strings.Replace(string(contents),"n","",1) 方式替換換行符
 */
package main
import (
    "fmt"
    "io/ioutil"
    "strings"
    "os"
    "strconv"
    "bufio"
)

func main() {
   Ioutil("mytestfile.txt")
   OsIoutil("mytestfile.txt")
   FileRead("mytestfile.txt")
   BufioRead("mytestfile.txt")
    }


func Ioutil(name string) {
    if contents,err := ioutil.ReadFile(name);err == nil {
        //因為contents是[]byte型別,直接轉換成string型別後會多一行空格,需要使用strings.Replace替換換行符
        result := strings.Replace(string(contents),"n","",1)
        fmt.Println("Use ioutil.ReadFile to read a file:",result)
        }
    }

func OsIoutil(name string) {
      if fileObj,err := os.Open(name);err == nil {
      //if fileObj,err := os.OpenFile(name,os.O_RDONLY,0644); err == nil {
        defer fileObj.Close()
        if contents,err := ioutil.ReadAll(fileObj); err == nil {
            result := strings.Replace(string(contents),"n","",1)
            fmt.Println("Use os.Open family functions and ioutil.ReadAll to read a file :",result)
            }

        }
}


func FileRead(name string) {
    if fileObj,err := os.Open(name);err == nil {
        defer fileObj.Close()
        //在定義空的byte列表時儘量大一些,否則這種方式讀取內容可能造成檔案讀取不完整
        buf := make([]byte, 1024)
        if n,err := fileObj.Read(buf);err == nil {
               fmt.Println("The number of bytes read:"+strconv.Itoa(n),"Buf length:"+strconv.Itoa(len(buf)))
               result := strings.Replace(string(buf),"n","",1)
               fmt.Println("Use os.Open and File's Read method to read a file:",result)
            }
    }
}

func BufioRead(name string) {
    if fileObj,err := os.Open(name);err == nil {
        defer fileObj.Close()
        //一個檔案物件本身是實現了io.Reader的 使用bufio.NewReader去初始化一個Reader物件,存在buffer中的,讀取一次就會被清空
        reader := bufio.NewReader(fileObj)
        //使用ReadString(delim byte)來讀取delim以及之前的資料並返回相關的字串.
        if result,err := reader.ReadString(byte('@'));err == nil {
            fmt.Println("使用ReadSlince相關方法讀取內容:",result)
        }
        //注意:上述ReadString已經將buffer中的資料讀取出來了,下面將不會輸出內容
        //需要注意的是,因為是將檔案內容讀取到[]byte中,因此需要對大小進行一定的把控
        buf := make([]byte,1024)
        //讀取Reader物件中的內容到[]byte型別的buf中
        if n,err := reader.Read(buf); err == nil {
            fmt.Println("The number of bytes read:"+strconv.Itoa(n))
            //這裡的buf是一個[]byte,因此如果需要只輸出內容,仍然需要將檔案內容的換行符替換掉
            fmt.Println("Use bufio.NewReader and os.Open read file contents to a []byte:",string(buf))
        }


    }
}

寫檔案

那麼上述幾種方式來讀取檔案的方式也支援檔案的寫入,相關的方法如下:

使用ioutil包進行檔案寫入

// 寫入[]byte型別的data到filename檔案中,檔案許可權為perm
func WriteFile(filename string, data []byte, perm os.FileMode) error

示例:

$ cat writefile.go
/**
 * @File Name: writefile.go
 * @Author:
 * @Email:
 * @Create Date: 2017-12-17 12:12:09
 * @Last Modified: 2017-12-17 12:12:30
 * @Description:使用多種方式將資料寫入檔案
 */
package main
import (
    "fmt"
    "io/ioutil"
)

func main() {
      name := "testwritefile.txt"
      content := "Hello, xxbandy.github.io!n"
      WriteWithIoutil(name,content)
}

//使用ioutil.WriteFile方式寫入檔案,是將[]byte內容寫入檔案,如果content字串中沒有換行符的話,預設就不會有換行符
func WriteWithIoutil(name,content string) {
    data :=  []byte(content)
    if ioutil.WriteFile(name,data,0644) == nil {
        fmt.Println("寫入檔案成功:",content)
        }
    }

# 會有換行符
$ go run writefile.go
寫入檔案成功: Hello, xxbandy.github.io!

使用os.Open相關函式進行檔案寫入

因為os.Open系列的函式會開啟檔案,並返回一個檔案物件指標,而該檔案物件是一個定義的結構體,擁有一些相關寫入的方法。

檔案物件結構體以及相關寫入檔案的方法:

//寫入長度為b位元組切片到檔案f中,返回寫入位元組號和錯誤資訊。當n不等於len(b)時,將返回非空的err
func (f *File) Write(b []byte) (n int, err error)
//在off偏移量出向檔案f寫入長度為b的位元組
func (f *File) WriteAt(b []byte, off int64) (n int, err error)
//類似於Write方法,但是寫入內容是字串而不是位元組切片
func (f *File) WriteString(s string) (n int, err error)

注意:使用WriteString()j進行檔案寫入發現經常新內容寫入時無法正常覆蓋全部新內容。(是因為字串長度不一樣)

示例:

//使用os.OpenFile()相關函式開啟檔案物件,並使用檔案物件的相關方法進行檔案寫入操作
func WriteWithFileWrite(name,content string){
    fileObj,err := os.OpenFile(name,os.O_RDWR|os.O_CREATE|os.O_TRUNC,0644)
    if err != nil {
        fmt.Println("Failed to open the file",err.Error())
        os.Exit(2)
    }
    defer fileObj.Close()
    if _,err := fileObj.WriteString(content);err == nil {
        fmt.Println("Successful writing to the file with os.OpenFile and *File.WriteString method.",content)
    }
    contents := []byte(content)
    if _,err := fileObj.Write(contents);err == nil {
        fmt.Println("Successful writing to thr file with os.OpenFile and *File.Write method.",content)
    }
}

注意:使用os.OpenFile(name string, flag int, perm FileMode)開啟檔案並進行檔案內容更改,需要注意flag相關的引數以及含義。

const (
        O_RDONLY int = syscall.O_RDONLY // 只讀開啟檔案和os.Open()同義
        O_WRONLY int = syscall.O_WRONLY // 只寫開啟檔案
        O_RDWR   int = syscall.O_RDWR   // 讀寫方式開啟檔案
        O_APPEND int = syscall.O_APPEND // 當寫的時候使用追加模式到檔案末尾
        O_CREATE int = syscall.O_CREAT  // 如果檔案不存在,此案建立
        O_EXCL   int = syscall.O_EXCL   // 和O_CREATE一起使用, 只有當檔案不存在時才建立
        O_SYNC   int = syscall.O_SYNC   // 以同步I/O方式開啟檔案,直接寫入硬碟.
        O_TRUNC  int = syscall.O_TRUNC  // 如果可以的話,當開啟檔案時先清空檔案
)

使用io包中的相關函式寫入檔案

io包中有一個WriteString()函式,用來將字串寫入一個Writer物件中。

//將字串s寫入w(可以是一個[]byte),如果w實現了一個WriteString方法,它可以被直接呼叫。否則w.Write會再一次被呼叫
func WriteString(w Writer, s string) (n int, err error)

//Writer物件的定義
type Writer interface {
        Write(p []byte) (n int, err error)
}

示例:

//使用io.WriteString()函式進行資料的寫入
func WriteWithIo(name,content string) {
    fileObj,err := os.OpenFile(name,os.O_RDWR|os.O_CREATE|os.O_APPEND,0644)
    if err != nil {
        fmt.Println("Failed to open the file",err.Error())
        os.Exit(2)
    }
    if  _,err := io.WriteString(fileObj,content);err == nil {
        fmt.Println("Successful appending to the file with os.OpenFile and io.WriteString.",content)
    }
}

使用bufio包中的相關函式寫入檔案

bufioio包中很多操作都是相似的,唯一不同的地方是bufio提供了一些緩衝的操作,如果對檔案I/O操作比較頻繁的,使用bufio還是能增加一些效能的。

bufio包中,有一個Writer結構體,而其相關的方法也支援一些寫入操作。

//Writer是一個空的結構體,一般需要使用NewWriter或者NewWriterSize來初始化一個結構體物件
type Writer struct {
        // contains filtered or unexported fields
}

//NewWriterSize和NewWriter函式
//返回預設緩衝大小的Writer物件(預設是4096)
func NewWriter(w io.Writer) *Writer

//指定緩衝大小建立一個Writer物件
func NewWriterSize(w io.Writer, size int) *Writer

//Writer物件相關的寫入資料的方法

//把p中的內容寫入buffer,返回寫入的位元組數和錯誤資訊。如果nn<len(p),返回錯誤資訊中會包含為什麼寫入的資料比較短
func (b *Writer) Write(p []byte) (nn int, err error)
//將buffer中的資料寫入 io.Writer
func (b *Writer) Flush() error

//以下三個方法可以直接寫入到檔案中
//寫入單個位元組
func (b *Writer) WriteByte(c byte) error
//寫入單個Unicode指標返回寫入位元組數錯誤資訊
func (b *Writer) WriteRune(r rune) (size int, err error)
//寫入字串並返回寫入位元組數和錯誤資訊
func (b *Writer) WriteString(s string) (int, error)

注意:如果需要再寫入檔案時利用緩衝的話只能使用bufio包中的Write方法

示例:

//使用bufio包中Writer物件的相關方法進行資料的寫入
func WriteWithBufio(name,content string) {
    if fileObj,err := os.OpenFile(name,os.O_RDWR|os.O_CREATE|os.O_APPEND,0644);err == nil {
        defer fileObj.Close()
        writeObj := bufio.NewWriterSize(fileObj,4096)
        //
       if _,err := writeObj.WriteString(content);err == nil {
              fmt.Println("Successful appending buffer and flush to file with bufio's Writer obj WriteString method",content)
           }

        //使用Write方法,需要使用Writer物件的Flush方法將buffer中的資料刷到磁碟
        buf := []byte(content)
        if _,err := writeObj.Write(buf);err == nil {
            fmt.Println("Successful appending to the buffer with os.OpenFile and bufio's Writer obj Write method.",content)
            if  err := writeObj.Flush(); err != nil {panic(err)}
            fmt.Println("Successful flush the buffer data to file ",content)
        }
        }
}

寫檔案全部示例

/**
 * @File Name: writefile.go
 * @Author:
 * @Email:
 * @Create Date: 2017-12-17 12:12:09
 * @Last Modified: 2017-12-17 23:12:10
 * @Description:使用多種方式將資料寫入檔案
 */
package main
import (
    "os"
    "io"
    "fmt"
    "io/ioutil"
    "bufio"
)

func main() {
      name := "testwritefile.txt"
      content := "Hello, xxbandy.github.io!n"
      WriteWithIoutil(name,content)
      contents := "Hello, xuxuebiaon"
      //清空一次檔案並寫入兩行contents
      WriteWithFileWrite(name,contents)
      WriteWithIo(name,content)
      //使用bufio包需要將資料先讀到buffer中,然後在flash到磁碟中
      WriteWithBufio(name,contents)
}

//使用ioutil.WriteFile方式寫入檔案,是將[]byte內容寫入檔案,如果content字串中沒有換行符的話,預設就不會有換行符
func WriteWithIoutil(name,content string) {
    data :=  []byte(content)
    if ioutil.WriteFile(name,data,0644) == nil {
        fmt.Println("寫入檔案成功:",content)
        }
    }

//使用os.OpenFile()相關函式開啟檔案物件,並使用檔案物件的相關方法進行檔案寫入操作
//清空一次檔案
func WriteWithFileWrite(name,content string){
    fileObj,err := os.OpenFile(name,os.O_RDWR|os.O_CREATE|os.O_TRUNC,0644)
    if err != nil {
        fmt.Println("Failed to open the file",err.Error())
        os.Exit(2)
    }
    defer fileObj.Close()
    if _,err := fileObj.WriteString(content);err == nil {
        fmt.Println("Successful writing to the file with os.OpenFile and *File.WriteString method.",content)
    }
    contents := []byte(content)
    if _,err := fileObj.Write(contents);err == nil {
        fmt.Println("Successful writing to thr file with os.OpenFile and *File.Write method.",content)
    }
}


//使用io.WriteString()函式進行資料的寫入
func WriteWithIo(name,content string) {
    fileObj,err := os.OpenFile(name,os.O_RDWR|os.O_CREATE|os.O_APPEND,0644)
    if err != nil {
        fmt.Println("Failed to open the file",err.Error())
        os.Exit(2)
    }
    if  _,err := io.WriteString(fileObj,content);err == nil {
        fmt.Println("Successful appending to the file with os.OpenFile and io.WriteString.",content)
    }
}

//使用bufio包中Writer物件的相關方法進行資料的寫入
func WriteWithBufio(name,content string) {
    if fileObj,err := os.OpenFile(name,os.O_RDWR|os.O_CREATE|os.O_APPEND,0644);err == nil {
        defer fileObj.Close()
        writeObj := bufio.NewWriterSize(fileObj,4096)
        //
       if _,err := writeObj.WriteString(content);err == nil {
              fmt.Println("Successful appending buffer and flush to file with bufio's Writer obj WriteString method",content)
           }

        //使用Write方法,需要使用Writer物件的Flush方法將buffer中的資料刷到磁碟
        buf := []byte(content)
        if _,err := writeObj.Write(buf);err == nil {
            fmt.Println("Successful appending to the buffer with os.OpenFile and bufio's Writer obj Write method.",content)
            if  err := writeObj.Flush(); err != nil {panic(err)}
            fmt.Println("Successful flush the buffer data to file ",content)
        }
        }
}