河南省住房和建设厅安监站网站,网站添加搜索,久久建筑网农网改造工程钻孔机开挖基坑专项施工方案,通过关键词优化提升企业网站Go原生的pkg中有一些核心的interface#xff0c;其中io.Reader/Writer是比较常用的接口。很多原生的结构都围绕这个系列的接口展开#xff0c;在实际的开发过程中#xff0c;你会发现通过这个接口可以在多种不同的io类型之间进行过渡和转化。本文结合实际场景来总结一番。 总… Go原生的pkg中有一些核心的interface其中io.Reader/Writer是比较常用的接口。很多原生的结构都围绕这个系列的接口展开在实际的开发过程中你会发现通过这个接口可以在多种不同的io类型之间进行过渡和转化。本文结合实际场景来总结一番。 总览 围绕io.Reader/Writer有几个常用的实现 net.Conn, os.Stdin, os.File: 网络、标准输入输出、文件的流读取strings.Reader: 把字符串抽象成Readerbytes.Reader: 把[]byte抽象成Readerbytes.Buffer: 把[]byte抽象成Reader和Writerbufio.Reader/Writer: 抽象成带缓冲的流读取比如按行读写这些实现对于初学者来说其实比较难去记忆在遇到实际问题的时候更是一脸蒙圈不知如何是好。下面用实际的场景来举例 场景举例 0. base64编码成字符串 encoding/base64包中 func NewEncoder(enc *Encoding, w io.Writer) io.WriteCloser 这个用来做base64编码但是仔细观察发现它需要一个io.Writer作为输出目标并用返回的WriteCloser的Write方法将结果写入目标下面是Go官方文档的例子 input : []byte(foo\x00bar)
encoder : base64.NewEncoder(base64.StdEncoding, os.Stdout)
encoder.Write(input) 这个例子是将结果写入到Stdout如果我们希望得到一个字符串呢观察上面的图不然发现可以用bytes.Buffer作为目标io.Writer input : []byte(foo\x00bar)
buffer : new(bytes.Buffer)
encoder : base64.NewEncoder(base64.StdEncoding, buffer)
encoder.Write(input)
fmt.Println(string(buffer.Bytes()) 1. []byte和struct之间正反序列化 这种场景经常用在基于字节的协议上比如有一个具有固定长度的结构 type Protocol struct {Version uint8BodyLen uint16Reserved [2]byteUnit uint8Value uint32
} 通过一个[]byte来反序列化得到这个Protocol一种思路是遍历这个[]byte然后逐一赋值。其实在encoding/binary包中有个方便的方法 func Read(r io.Reader, order ByteOrder, data interface{}) error 这个方法从一个io.Reader中读取字节并已order指定的端模式来给填充datadata需要是fixed-sized的结构或者类型。要用到这个方法首先要有一个io.Reader从上面的图中不难发现我们可以这么写 var p Protocol
var bin []byte
//...
binary.Read(bytes.NewReader(bin), binary.LittleEndian, p) 换句话说我们将一个[]byte转成了一个io.Reader。 反过来我们需要将Protocol序列化得到[]byte使用encoding/binary包中有个对应的Write方法 func Write(w io.Writer, order ByteOrder, data interface{}) error 通过将[]byte转成一个io.Writer即可 var p Protocol
buffer : new(bytes.Buffer)
//...
binary.Writer(buffer, binary.LittleEndian, p)
bin : buffer.Bytes()2. 从流中按行读取 比如对于常见的基于文本行的HTTP协议的读取我们需要将一个流按照行来读取。本质上我们需要一个基于缓冲的读写机制读一些到缓冲然后遍历缓冲中我们关心的字节或字符。在Go中有一个bufio的包可以实现带缓冲的读写 func NewReader(rd io.Reader) *Reader
func (b *Reader) ReadString(delim byte) (string, error) 这个ReadString方法从io.Reader中读取字符串直到delim就返回delim和之前的字符串。如果将delim设置为\n相当于按行来读取了 var conn net.Conn
//...
reader : NewReader(conn)
for {line, err : reader.ReadString([]byte(\n))//...
}花式技zuo巧si string转[]byte a : Hello, playground
fmt.Println([]byte(a)) 等价于 a : Hello, playground
buf : new(bytes.Buffer)
buf.ReadFrom(strings.NewReader(a))
fmt.Println(buf.Bytes())
