Go Readers读取数据流
go语言的io包指定了io.Reader接口。go语言标准库包含了这个接口的许多实现,包括文件、网络连接、压缩、加密等等。
io.Reader接口有一个Read方法:
func (T) Read(b []byte) (n int, err error)
在程序中,我们使用循环读取数据流,直到error返回io.EOF。
我们建立一个每次以8个字节读取strings.Reader的输出的程序示例
package mainimport("fmt""strings""io"
)func main() {r := strings.NewReader("Hello, Reader!")b := make([]byte, 8) // 8 这里控制每次读取的字节数for{n, err := r.Read(b)fmt.Printf("n = %v err = %v b = %v\n", n, err, b)fmt.Printf("b[:n] = %q\n", b[:n])if err == io.EOF{break}}
}
运行结果
n = 8 err = <nil> b = [72 101 108 108 111 44 32 82]
b[:n] = "Hello, R"
n = 6 err = <nil> b = [101 97 100 101 114 33 32 82]
b[:n] = "eader!"
n = 0 err = EOF b = [101 97 100 101 114 33 32 82]
b[:n] = ""
实现一个Reader类型,她不断生成ASCII字符'A'的流。
package mainimport ("fmt""io""os"
)type MyReader struct{}func Validate(r io.Reader) {b := make([]byte, 1024, 2048)i, o := 0, 0for ; i < 1<<20 && o < 1<<20; i++ { // test 1mbn, err := r.Read(b)for i, v := range b[:n] {if v != 'A' {fmt.Fprintf(os.Stderr, "got byte %x at offset %v, want 'A'\n", v, o+i)return}}o += nif err != nil {fmt.Fprintf(os.Stderr, "read error: %v\n", err)return}}if o == 0 {fmt.Fprintf(os.Stderr, "read zero bytes after %d Read calls\n", i)return}fmt.Println("OK!")
}//实现一个 Reader 类型,它不断生成 ASCII 字符 'A' 的流。
// TODO: Add a Read([]byte) (int, error) method to MyReader.
func (mr MyReader) Read(b []byte) (n int, err error) {i := 0for ;i < len(b);i++ {b[i] = 'A'}return i, nil
}func main() {Validate(MyReader{})
}
代码中的 func Validate(r io.Reader) 可以从 github 上下载。
Github: https://github.com/golang/tour
参考:
https://www.yuque.com/docs/share/0952086f-f2b6-401d-bcb5-0a9aa9fffec8
Go Readers读取数据流相关推荐
- ajax 文件数据流,Ajax如何读取数据流中的xml文件?
Ajax如何读取数据流中的xml文件? 这是我的源代码,请大家帮忙看看,我读到的怎么都是空值.是不是方法错了? var xmlHttp; function createXMLHttpRequest() ...
- python读取数据流_python3+pyshark读取wireshark数据包并追踪telnet数据流
一.程序说明 本程序有两个要点,第一个要点是读取wireshark数据包(当然也可以从网卡直接捕获改个函数就行),这个使用pyshark实现.pyshark是tshark的一个python封装,至于t ...
- java图片转换为数据流_OpenCV 读取数据流图片
背景 OpenCV 提供的 API 是直接根据路径读取图片的, 在实际生产环境中,可能大部分情况下都是直接读取网络图片 在内存就完成图片和 opencv 的 Mat 对象的转换 那么该如何读取 byt ...
- python读取数据流_IOError:读取图像fi时数据流中断
以下是代码(一个简单的python代码,可以在图片中添加数字):from PIL import Image, ImageDraw, ImageFont def addnum(number, filep ...
- HttpURLConnection请求数据流的写入(write)和读取(read)
URLConnection类给应用程序和web资源之间架设起了通信的桥梁,这些web资源通常是通过url来标记的,本文将讲述如何使用HttpURLConnection来访问web页面(发送数据流)和读 ...
- 读取海康工业相机(gige)数据流
读取海康工业相机(gige)数据流 调用海康工业相机(gige),读取数据流并转为opencv(numpy)矩阵格式 参考官方开发案例GrabImage.py,对数据流相机转换 def work_th ...
- hdfs读写流程_深度探索Hadoop分布式文件系统(HDFS)数据读取流程
一.开篇 Hadoop分布式文件系统(HDFS)是Hadoop大数据生态最底层的数据存储设施.因其具备了海量数据分布式存储能力,针对不同批处理业务的大吞吐数据计算承载力,使其综合复杂度要远远高于其他数 ...
- 《剑指offer》-- 序列化二叉树、二叉搜索树的第k个节点、数据流中的中位数、滑动窗口的最大值
一.序列化二叉树: 1.题目: 请实现两个函数,分别用来序列化和反序列化二叉树. 2.解题思路: (1)根据前序遍历规则完成序列化与反序列化.所谓序列化指的是遍历二叉树为字符串:所谓反序列化指的是依据 ...
- 牛客网 在线编程 数据流中的中位数
题目描述 如何得到一个数据流中的中位数?如果从数据流中读出奇数个数值,那么中位数就是所有数值排序之后位于中间的数值.如果从数据流中读出偶数个数值,那么中位数就是所有数值排序之后中间两个数的平均值.我们 ...
最新文章
- 一篇SSM框架整合友好的文章(二)
- 重磅,武汉大学获捐10亿元!
- Linux内核的同步机制---自旋锁
- Centos 7 mysql Buffered warning: Changed limits: max_connections: 214 解决方法
- 关于java中::语法的理解
- LeGO-LOAM学习
- 前端学习(2):什么是html和css
- html日期只显示7天,vue+elementui 只能选7天内的日期
- STM32F4 HAL 库开发报错:Hal_StatusTypeDef is undefined的解决办法
- Android 系统(222)---Android 的lowmemorykiller机制
- FF:与吉利控股的合作取得实质性进展 双方技术团队正紧密对接
- HCIE Secuirty AC概述 备考笔记(幕布)
- linux 内核挂起 ping,Linux内核安全详解 ping到死复活方法
- 推荐5个适合小白使用的论文文献查找网站!
- 盘点|国产无线通信模块厂,赶紧收藏!
- 无线网络常用软件与工具大全
- linux雨滴桌面,Rainmeter(雨滴桌面秀)
- 10. Java8新特性-新日期和时间API
- 使用CSDN-markdown编辑器入门
- zjs-my-diary-20200527