系列：Go 语言从入门到进阶作者：耿雨飞适用版本：go v1.26.2前置条件在开始本章学习之前，请确保：已完成前九章的学习，熟悉 Go 基本语法、函数、接口、泛型与并发编程理解接口的定义与实现机制，尤其是隐式实现规则已获取 Go 1.26.2 源码树（go-go1.26.2目录）导读I/O（Input/Output）是几乎所有程序的基础。Go 标准库围绕io包的核心接口构建了一套高度可组合的 I/O 体系：io.Reader和io.Writer两个接口贯穿整个标准库，从文件读写、网络通信到加密解码，几乎所有涉及数据流动的场景都围绕它们展开。本章将系统地学习 Go 的 I/O 体系。我们从io包的核心接口出发，深入bufio的缓冲优化策略，掌握os包的文件系统操作，最后学习fmt的格式化 I/O。整个过程将持续对照源码，帮助你理解每一层抽象背后的实现细节。本章将对照 Go 1.26.2 源码中的以下关键路径：源码路径内容说明src/io/io.goio包核心接口与工具函数src/io/pipe.go同步内存管道实现src/bufio/bufio.gobufio.Reader与bufio.Writer缓冲读写src/bufio/scan.gobufio.Scanner基于分隔符的扫描器src/os/file.go文件操作核心 APIsrc/os/dir.go目录读取操作src/os/env.go环境变量操作src/os/exec.go进程管理src/fmt/doc.go格式化动词完整说明src/fmt/print.goStringer、Formatter等接口定义与打印实现学习目标学完本章后，你应当能够：说明io.Reader、io.Writer、io.Closer、io.Seeker四个核心接口的契约及其设计理念运用io.Copy、io.TeeReader、io.Pipe等工具函数组合数据流理解bufio.Reader的环形缓冲区结构以及bufio.Scanner的分词机制使用bufio.Writer进行缓冲写入并理解Flush的必要性熟练使用os包完成文件创建、读写、删除与目录操作掌握fmt包的格式化动词体系，实现Stringer和Formatter接口自定义输出格式10.1io包核心接口io包是 Go I/O 体系的基石。它不提供任何具体的 I/O 实现，而是定义了一组最小化的接口契约，让不同的 I/O 实现能够通过统一的接口互相组合。10.1.1 Reader、Writer、Closer、Seeker四大基础接口定义在src/io/io.go中，每个接口只有一个方法：// src/io/io.go（第 86-126 行）// Reader 是对"读取"操作的抽象typeReaderinterface{Read(p[]byte)(nint,errerror)}// Writer 是对"写入"操作的抽象typeWriterinterface{Write(p[]byte)(nint,errerror)}// Closer 是对"关闭"操作的抽象typeCloserinterface{Close()error}// Seeker 是对"定位"操作的抽象typeSeekerinterface{Seek(offsetint64,whenceint)(int64,error)}Reader 的契约是最重要的，也是最容易出错的。源码注释详细说明了几条关键规则：Read将最多len(p)个字节读入p，返回实际读取的字节数n（0 = n = len(p)）和可能的错误即使n len(p)，Read也可能使用p的全部空间作为暂存区当数据流结束时，Read可以返回n 0, err = nil（本次读到数据），下一次调用才返回0, io.EOF；也可以直接返回n 0, err = io.EOF调用者应当始终先处理n 0的数据，再检查错误// 正确的 Reader 消费模式for{n,err:=r.Read(buf)ifn0{// 先处理读到的数据process(buf[:n])}iferr!=nil{iferr==io.EOF{break// 数据流结束}returnerr// 真正的错误}}Writer 的契约相对简单：Write必须写入len(p)个字节，如果写入的字节数n len(p)，则必须返回非nil的错误。Seeker的whence参数有三个预定义常量：const(SeekStart=0// 相对于文件开头SeekCurrent=1// 相对于当前位置SeekEnd=2// 相对于文件末尾)源码洞察：这四个接口各自只定义一个方法，这是 Go 接口设计哲学的典型体现——“接口越小，适用面越广”。整个标准库中有数百个类型实现了Reader或Writer，正因为门槛极低，才获得了极高的可组合性。10.1.2 组合接口io包基于四大基础接口定义了一系列组合接口：// src/io/io.go（第 130-172 行）typeReadWriterinterface{Reader Writer}typeReadCloserinterface{Reader Closer}typeWriteCloserinterface{Writer Closer}typeReadWriteCloserinterface{Reader Writer Closer}typeReadSeekerinterface{Reader Seeker}typeReadWriteSeekerinterface{Reader Writer Seeker}这些组合接口的核心价值在于精确表达能力需求。例如，一个函数只需要读取和关闭，就应该接受io.ReadCloser而不是具体类型*os.File。这样既保证了必要的能力约束，又保留了最大的灵活性。此外，io包还定义了一些专用接口：接口方法用途ReaderFromReadFrom(r Reader) (int64, error)从 Reader 拉取数据（优化拷贝）WriterToWriteTo(w Writer) (int64, error)向 Writer 推送数据（优化拷贝）ReaderAtReadAt(p []byte, off int64) (int, error)从指定偏移读取（支持并发）WriterAtWriteAt(p []byte, off int64) (int, error)向指定偏移写入（支持并发）ByteReaderReadByte() (byte, error)逐字节读取ByteWriterWriteByte(c byte) error逐字节写入RuneReaderReadRune() (rune, int, error)逐 rune 读取StringWriterWriteString(s string) (int, error)写入字符串（避免[]byte转换）ReaderAt和WriterAt是两个特殊的接口——它们的操作是基于绝对偏移的，不影响也不受文件当前位置的影响，因此天然支持并发调用。10.1.3io.Copy、io.TeeReader、io.Pipeio包提供的工具函数让各种 Reader 和 Writer 能够灵活组合。io.Copy——数据拷贝的瑞士军刀io.Copy从src读取数据，写入dst，直到src返回io.EOF或发生错误：// src/io/io.go（第 387-388 行）funcCopy(dst Writer,src Reader)(writtenint64,errerror){returncopyBuffer(dst,src,nil)}copyBuffer是实际的实现（第 407-456 行），它的优化策略非常精妙：WriterTo 优先：如果src实现了WriterTo，直接调用src.WriteTo(dst)，避免中间缓冲区ReaderFrom 次之：如果dst实现了ReaderFrom，直接调用dst.ReadFrom(src)默认缓冲拷贝：分配 32 KB 缓冲区，循环调用Read/WritefunccopyBuffer(dst Writer,src Reader,buf[]byte)(writtenint64,errerror){// 优化路径 1：WriterToifwt,ok:=src.(WriterTo);ok{returnwt.WriteTo(dst)}// 优化路径 2：ReaderFromifrf,ok:=dst.(ReaderFrom);ok{returnrf.ReadFrom(src)}// 默认路径：32KB 缓冲拷贝ifbuf==nil{size:=32*1024// ...buf=make([]byte,size)}for{nr,er:=src.Read(buf)ifnr0{nw,ew:=dst.Write(buf[0:nr])// ...}// ...}}这种通过接口类型断言选择最优路径的模式在标准库中随处可见。例如，os.File同时实现了ReaderFrom和WriterTo，在 Linux 上可以利用sendfile系统调用实现零拷贝传输。使用示例：packagemainimport("fmt""io""os")funcmain(){src,_:=os.Open("input.txt")defersrc.Close()dst,_:=os.Create("output.txt")deferdst.Close()written,err:=io.Copy(dst,src)iferr!=nil{fmt.Println("拷贝失败:",err)return}fmt.Printf("成功拷贝 %d 字节\n",written)}还有两个变体：io.CopyN(dst, src, n)：最多拷贝n个字节io.CopyBuffer(dst, src, buf)：使用用户提供的缓冲区io.TeeReader——读取时同步分流TeeReader返回一个 Reader，它在读取r的同时将数据写入w：// src/io/io.go（第 618-620 行）funcTeeReader(r Reader,w Writer)Reader{returnteeReader{r,w}}typeteeReaderstruct{r Reader w Writer}func(t*teeReader)Read(p[]byte)(nint,errerror){n,err=t.r.Read(p)ifn0{ifn,err:=t.w.Write(p[:n]);err!=nil{returnn,err}}return}实现极为简洁：每次Read时，先从源读取，再将读到的数据写入目标。没有内部缓冲——写入必须在读取返回之前完成。典型用途是在读取数据的同时计算哈希校验：packagemainimport("crypto/sha256""fmt""io""os")funcmain(){f,_:=os.Open("data.bin")deferf.Close()h:=sha256.New()tee:=io.TeeReader(f,h)// 读取全部内容（同时自动写入哈希器）data,_:=io.ReadAll(tee)fmt.Printf("数据长度: %d\n",len(data))fmt.Printf("SHA-256: %x\n",h.Sum(nil))}io.Pipe——同步内存管道io.Pipe创建一对配对的PipeReader和PipeWriter，实现 goroutine 间的同步数据传递：// src/io/pipe.go（第 195-202 行）funcPipe()(*PipeReader,*PipeWriter){pw:=PipeWriter{r:PipeReader{pipe:pipe{wrCh:make(chan[]byte),rdCh:make(chanint),done:make(chanstruct{}),}}}returnpw.r,pw}看看内部的pipe结构：typepipestruct{wrMu sync.Mutex// 写操作串行化wrChchan[]byte// 写端传递数据切片rdChchanint// 读端返回已读字节数once sync.Once// 保护 done 通道只关闭一次donechanstruct{}// 关闭信号rerr onceError// 读端关闭错误werr onceError// 写端关闭错误}工作机制是纯 channel 驱动的：写端将[]byte切片通过wrCh发送给读端读端copy数据后，通过rdCh返回实际读取的字节数写端根据已读字节数推进剩余数据，直到全部被消费没有内部缓冲区——数据直接从写端的内存拷贝到读端的内存。这意味着Write会阻塞直到Read消费完所有数据。典型用途是连接"生产者"和"消费者"：packagemainimport("encoding/json""fmt""io")funcmain(){pr,pw:=io.Pipe()// 生产者：编码 JSON 并写入管道gofunc()