JAVA分布式实战之互联网金融p2p共172课时

小编 2026-06-30 阅读:1293 评论:0
All(r io.Reader) ([]byte, error)         func ReadDir(dirname string) ([]os.FileInfo, error)         ...

All(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)

 

        读取文件和读目录示例:        

        package main

        import (
            \"fmt\"
            \"io/ioutil\"
            \"strings\"
        )

        var (
             myReadFile = \"my_read_file.txt\"
        )

        func main() {
            Ioutil(myReadFile)

            // test ioutil.ReadDir function
            dirname := \"/home/work/xs_golang/file_operation\"
            testReadDir(dirname)
        }

        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)
            }
        }

       func testReadDir(dirname string) error {
            fmt.Printf(\"file under directory: %s as follows:\\n\", dirname)

            fileInfoList, err := ioutil.ReadDir(dirname)
            if err != nil {
                fmt.Printf(\"ioutil.ReadDir failed. err: %v\\n\", err)
                return err
            }

            for index, fileInfo := range fileInfoList {
                fmt.Printf(\"%d\\t%s\\n\", index, fileInfo.Name())
            }

            return nil
        }

1.2 借助os.Open进行读取文件
1.2.1 借助os.Open和ioutil.ReadAll读取文件
        由于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 testOpenAndReadAll(name string) error {
            fileObj, err := os.Open(name)
            //if fileObj,err := os.OpenFile(name,os.O_RDONLY,0644); err == nil {
            if err !=  nil {
                fmt.Printf(\"os.Open failed. err: %v\\n\", err)
                return err
            }
            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)
            }

            return nil
        }

1.2.2 借助os.Open和文件对象的Read读取文件
        然而上述方式会比较繁琐一些,因为使用了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方法和文件对象的Read方法读取示例:   

        func testOpenAndFileObjRead(name string) error {
            fileObj, err := os.Open(name)
            if err != nil {
                fmt.Printf(\"os.Open failed. err: %v\\n\", err)
                return err
            }
            defer fileObj.Close()

            //在定义空的byte列表时尽量大一些,否则这种方式读取内容可能造成文件读取不完整
            buf := make([]byte, 10240)
            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)
            }
            return nil
        }

1.2.3 借助os.Open和bufio.Reader读取文件
        bufio包实现了缓存IO,它本身包装了io.Reader和io.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 或 \\r\\n)

        func (b *Reader) ReadLine() (line []byte, isPrefix bool, err error)

        //读取单个UTF-8字符并返回一个rune和字节大小

        func (b *Reader) ReadRune() (r rune, size int, err error)

        使用文件对象的Read方法和bufio.Reader读取示例: 

        func testBufioRead(name string) error {
            fileObj, err := os.Open(name)
            if err != nil {
                fmt.Printf(\"os.Open failed. err: %v\\n\", err)
                return err
            }
            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)
            }

            //需要注意的是,因为是将文件内容读取到[]byte中,因此需要对大小进行一定的把控
            buf := make([]byte, 10240)
            //读取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))
            }

            return nil
        }

2. 写文件
        那么上述几种方式来读取文件的方式也支持文件的写入,相关的方法如下:

2.1 使用ioutil包进行文件写入
        // 写入[]byte类型的data到filename文件中,文件权限为perm

        func WriteFile(filename string, data []byte, perm os.FileMode) error

        使用ioutil包进行写文件的示例:

        package main

        import (
            \"fmt\"
--------------------- 
作者:Arlingtonroad 
来源:CSDN 
原文:https://blog.csdn.net/Arlingtonroad/article/details/85023287 
版权声明:本文为博主原创文章,转载请附上博文链接!

版权声明

本文仅代表作者观点,不代表百度立场。
本文系作者授权百度百家发表,未经许可,不得转载。

热门文章
  • 机房智能化温湿度解决方式之POE供电以太网温湿度传感器

    机房智能化温湿度解决方式之POE供电以太网温湿度传感器
    机房智能化温湿度解决方式之POE供电以太网温湿度传感器 北京盈创力和电子科技有限公司 智能型TCP网口温湿度记录仪 北京IP网络温湿度记录仪厂家,北京盈创力和 北京智能型TCP网口温湿度记录仪IP网络温湿度记录仪是一种新型的基于TCP/IP协议双绞线以太网标准温湿度采集模块,利用它可以实现现场温度值、相对湿度值的采集,同时利用其自身的RJ45通信接口可以方便地和机房监控主机或交换机集线器进行联网。 工作于-40℃~85℃工业级带...
  • Sequential Monte Carlo Methods (SMC) 序列蒙特卡洛/粒子滤波/Bootstrap Filtering

    Sequential Monte Carlo Methods (SMC) 序列蒙特卡洛/粒子滤波/Bootstrap Filtering
    Problem Statement 我们考虑一个具有马尔可夫性质、非线性、非高斯的状态空间模型(State Space Model):对于一个时间序列上的观测结果{yt,t∈N}\\{ y_t , t \\in N \\}{yt​,t∈N},我们认为每个观测结果yty_tyt​的生成依赖于一个无法直接观察的隐变量xt∈{xt,t∈N}x_t \\in \\{x_t , t \\in N \\}xt​∈{xt​,t∈N},即:p(...
  • HTTP状态保持的原理

    HTTP状态保持的原理
    a)在用户登录之后,浏览器返回响应的时候会在响应中添加上cookieb)浏览器接收到cookie之后会自动保存c)当用户再次请求同一服务器中的其他网页的时候,浏览器会自动带上之前保存的cookied)服务接收到请求之后可以请 request 对象中取到cookie 判断当前用户是否登录  Http是无状态的,就是连接时数据互通,关闭后...
  • Hive 系统函数及示例

    Hive 系统函数及示例
    查看所有系统函数 show functions; 函数分类 内置函数【系统函数】 数学函数: floor、round、ceil、cos、log2等 字符串函数: length、reverse、trim、lower、get_json_object、repeat等 收集函数: size 转换函数: cast 日期函数: year、month、datediff、date、date_add等 条件函数: coalesce、case…w...
  • CSRF的原理和防范措施

    CSRF的原理和防范措施
    a)攻击原理:i.用户C访问正常网站A时进行登录,浏览器保存A的cookieii.用户C再访问攻击网站B,网站B上有某个隐藏的链接或者图片标签会自动请求网站A的URL地址,例如表单提交,传指定的参数iii.而攻击网站B在访问网站A的时候,浏览器会自动带上网站A的cookieiv.所以网站A在接收到请求之后可判断当前用户是登录状态,所以...
标签列表