您好,登錄后才能下訂單哦!
Go語言中怎么對文件進行讀寫操作,很多新手對此不是很清楚,為了幫助大家解決這個難題,下面小編將為大家詳細講解,有這方面需求的人可以來學習下,希望你能有所收獲。
1.func Copy(dst Writer, src Reader) (written int64, err error)這個函數是從一個文件讀取拷貝到另外一個文件,一直拷貝到讀取文件的EOF,所以不會返回io.EOF錯誤,參數是寫入目標器和讀取目標器,返回int64的拷貝字節數和err信息
import (
"fmt"
"io"
"os"
)
func main() {
r, _ := os.Open("test.txt")
w, _ := os.Create("write.txt")
num, err := io.Copy(w, w)
if err != nil {
fmt.Println(err)
}
fmt.Println(num) //返回int64的11 打開我的write.txt正是test.txt里邊的hello widuu
}
2.func CopyN(dst Writer, src Reader, n int64) (written int64, err error)看函數就知道了跟上述的是一樣的,只是多加了一個讀取數的限制,然后我們看下代碼
復制代碼 代碼如下:
import (
"fmt"
"io"
"io/ioutil"
"os"
)
func main() {
r, _ := os.Open("test.txt")
w, _ := os.Create("write1.txt")
num, err := io.CopyN(w, r, 5)
if err != nil {
fmt.Println(err)
}
defer r.Close()
b, _ := ioutil.ReadFile("write1.txt")
fmt.Println(string(b)) //輸出 hello
fmt.Println(num) //5
}
3.func ReadAtLeast(r Reader, buf []byte, min int) (n int, err error)這個函數就是從讀取器中讀取數據放到我們的buf中,限定了最小的讀取字節數,如果我們讀取的數據小于最小讀取器,譬如你設定min的值是8,但是你讀取的數據字節數是5就會返回一個`io.ErrUnexpectedEOF`,如果大于就會返回`io.ErrShortBuffer`,讀取完畢會有`io.EOF`~~,多講一些哈,這個Reader只要我們滿足這個interface就可以用這個
復制代碼 代碼如下:
type Reader interface {
Read(p []byte) (n int, err error)
}
其中*File就支持func (f *File) Read(b []byte) (n int, err error)
復制代碼 代碼如下:
import (
"fmt"
"io"
"os"
)
func main() {
r, _ := os.Open("write1.txt")
b := make([]byte, 20)
defer r.Close()
var total int
for {
n, err := io.ReadAtLeast(r, b, 8)
if err == nil {
fmt.Println("Read enough value:", string(b)) // Read enough value: hello widuu
}
if err == io.ErrUnexpectedEOF { //讀取了的數據小于我們限定的最小讀取數據8
fmt.Println("Read fewer value:", string(b[0:n]))
}
if err == io.ErrShortBuffer{ //這個是我們設定的buf也就是b小于我們限定8
fmt.Println("buf too Short")
os.Exit(1)
}
if err == io.EOF { //讀完了 輸出
fmt.Println("Read end total", total) //Read end total 11
break
}
total = total + n
}
}
4.func ReadFull(r Reader, buf []byte) (n int, err error)這個函數和上邊的函數是相似,只不過是讀取len(buf)個,放在buf中
復制代碼 代碼如下:
import (
"fmt"
"io"
"os"
)
func main() {
r, _ := os.Open("write.txt")
b := make([]byte, 20)
num, err := io.ReadFull(r, b)
defer r.Close()
if err == io.EOF {
fmt.Println("Read end total", num)
}
if err == io.ErrUnexpectedEOF {
fmt.Println("Read fewer value:", string(b[:num])) //Read fewer value: hello widuu,依然是buf長度大于讀取的長度
return
}
fmt.Println("Read value:", string(b)) //如果b是5 就出現這里
}
5.func WriteString(w Writer, s string) (n int, err error)弄完讀了,當然帶要寫了,這個函數主要是向寫入目標中寫入字符創,返回是寫入的字節數還有error錯誤,主要是權限的錯誤,其中寫入呀!都是writer這個結構就可以寫入
復制代碼 代碼如下:
type Writer interface {
Write(p []byte) (n int, err error)
}
跟read一樣我們的*File是有func (f *File) Write(b []byte) (n int, err error),當然其實我們的*File中就已經有WirteString了func (f *File) WriteString(s string) (ret int, err error)
import (
"fmt"
"io"
"io/ioutil"
"os"
)
func main() {
w, _ := os.OpenFile("write1.txt", os.O_RDWR, os.ModePerm)
n, err := io.WriteString(w, "ni hao ma")
if err != nil {
fmt.Println(err) //當我用os.open()的時候木有權限 悲催的~~輸出write write1.txt: Access is denied.
}
defer w.Close()
b, _ := ioutil.ReadFile("write1.txt")
fmt.Println("write total", n) //write total 9
fmt.Println(string(b)) // ni hao ma
}
6.type LimitedReader
復制代碼 代碼如下:
type LimitedReader struct {
R Reader // 讀取器了
N int64 // 最大字節限制
}
只實現了一個方法func (l *LimitedReader) Read(p []byte) (n int, err error)其實我們不難發現這個跟我們的ReadAtLast()就是親兄弟的節奏
復制代碼 代碼如下:
import (
"fmt"
"io"
"os"
)
func main() {
reader, _ := os.Open("test.txt")
limitedreader := io.LimitedReader{
R: reader,
N: 20,
}
p := make([]byte, 10)
var total int
for {
n, err := limitedreader.Read(p)
if err == io.EOF {
fmt.Println("read total", total) //read total 11
fmt.Println("read value", string(p)) //read value hello widuu
break
}
total = total + n
}
}
7.type PipeReader
復制代碼 代碼如下:
type PipeReader struct {
// contains filtered or unexported fields
}
(1)func Pipe() (*PipeReader, *PipeWriter)創建一個管道,并返回它的讀取器和寫入器,這個會在內存中進行管道同步,它的開啟會io.Reader然后等待io.Writer的輸入,沒有內部緩沖,它是安全的調用Read和Write彼此和并行調用寫
復制代碼 代碼如下:
import (
"fmt"
"io"
"reflect"
)
func main() {
r, w := io.Pipe()
fmt.Println(reflect.TypeOf(r)) //*io.PipeReader
fmt.Println(reflect.TypeOf(w)) //*io.PipeWriter
}
(2)func (r *PipeReader) Close() error管道關閉后,正在進行或后續的寫入Write操作返回ErrClosedPipe
復制代碼 代碼如下:
import (
"fmt"
"io"
)
func main() {
r, w := io.Pipe()
r.Close()
_, err := w.Write([]byte("hello widuu"))
if err == io.ErrClosedPipe {
fmt.Println("管道已經關閉無法寫入") //管道已經關閉無法寫入
}
}
(3)func (r *PipeReader) CloseWithError(err error) error這個就是上邊的r.Close關閉的時候,寫入器會返回錯誤的信息
復制代碼 代碼如下:
import (
"errors"
"fmt"
"io"
)
func main() {
r, w := io.Pipe()
r.Close()
err := errors.New("管道符關閉了") //errors這個包我們前邊已經說過了,就一個方法New不會的可以看看前邊的
r.CloseWithError(err)
_, err = w.Write([]byte("test"))
if err != nil {
fmt.Println(err) //管道符關閉了
}
}
(4)func (r *PipeReader) Read(data []byte) (n int, err error)標準的閱讀接口,它從管道中讀取數據、阻塞一直到一個寫入接口關閉,如果寫入端發生錯誤,它就會返回錯誤,否則返回的EOF
復制代碼 代碼如下:
import (
"fmt"
"io"
)
func main() {
r, w := io.Pipe()
go w.Write([]byte("hello widuu"))
d := make([]byte, 11)
n, _ := r.Read(d) //從管道里讀取數據
fmt.Println(string(d))
fmt.Println(n)
}
看完上述內容是否對您有幫助呢?如果還想對相關知識有進一步的了解或閱讀更多相關文章,請關注億速云行業資訊頻道,感謝您對億速云的支持。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。