Go io.MultiReader 如何拼接多个输入流
需要把多个文件片段、内存字符串或网络响应按顺序交给同一个消费函数时,Go 不必先把它们全部读进内存。io.MultiReader 会把多个 io.Reader 视为一条连续输入:前一个 Reader 返回 io.EOF 后才切换到下一个,所有输入耗尽才返回最终的 EOF;如果某个 Reader 返回其他错误,读取会在该处停止。
io.MultiReader(r1, r2, r3)是顺序拼接,不是并发合并,也不会自动插入换行。- 它只负责组合读取,不负责关闭文件、连接等底层资源。
- 把组合 Reader 交给
io.Copy、io.ReadAll等现有函数即可,遇到非 EOF 错误要保留错误上下文。
把多个 Reader 变成一条连续输入
最小用法是把多个实现了 io.Reader 的对象作为可变参数传入。下面三个 strings.Reader 只提供片段内容,MultiReader 不会改变它们的类型,只返回一个新的 io.Reader 视图。

package main
import (
"io"
"os"
"strings"
)
func main() {
// 每个 Reader 代表一段独立输入,MultiReader 保留参数顺序。
joined := io.MultiReader(
strings.NewReader("header\n"),
strings.NewReader("body\n"),
strings.NewReader("footer\n"),
)
// 组合后的 Reader 可以直接交给已有的复制函数。
if _, err := io.Copy(os.Stdout, joined); err != nil {
panic(err)
}
}
输出会依次出现 header、body、footer。这里的换行来自每个字符串本身;如果片段没有换行,MultiReader 不会替你补分隔符。对于 HTTP 响应、压缩包片段或上传分块,这种“原样连接”通常正是需要的行为。
顺序读取时,EOF 和错误怎么传递
可以把它理解成一个带有当前位置的 Reader:当前 Reader 还没结束时,后面的 Reader 不会被读取;当前 Reader 报告 EOF 时,组合层继续尝试下一个。调用方只需要处理组合层返回的 n 和 err,不必自己写切换循环。

| 底层 Reader 的返回 | MultiReader 的处理 | 调用方应关注什么 |
|---|---|---|
n > 0,错误为 nil | 把本次字节交给调用方 | 继续读取,不能假设一次 Read 就读满缓冲区 |
io.EOF | 切换到下一个输入;全部结束后才返回 EOF | 把 EOF 当作正常结束 |
| 非 EOF 错误 | 停止组合读取并返回错误 | 记录当前输入的上下文,决定重试或回滚 |
这也解释了一个常见误区:MultiReader 不是“把所有数据提前拼成 []byte”。它按需读取,适合把多个大输入交给流式消费者。另一方面,Reader 的顺序是固定的,不适合需要并行拉取、按时间合并或随机访问的场景。
文件输入要自己管理关闭时机
组合文件时,打开动作和关闭动作仍属于调用方。io.MultiReader 只持有 Reader,不会替你调用 Close。因此可以先打开文件、用 defer 确保函数返回时关闭,再把文件 Reader 交给组合层:
func concatFiles(dst io.Writer, paths ...string) error {
readers := make([]io.Reader, 0, len(paths))
for _, path := range paths {
file, err := os.Open(path)
if err != nil {
return fmt.Errorf("打开 %s: %w", path, err)
}
// 文件生命周期由当前函数负责,MultiReader 不会自动 Close。
defer file.Close()
readers = append(readers, file)
}
// 组合层只负责顺序读取,错误仍交给调用方处理。
_, err := io.Copy(dst, io.MultiReader(readers...))
return err
}
生产代码还应根据项目的错误策略处理 Close 返回值,并评估一次打开太多文件的风险。若文件数量很大,可以改成自定义 Reader,按需打开和关闭当前文件,避免一次持有过多文件描述符。
需要换行或并发时,不要误用 MultiReader
如果业务要求每个片段之间强制加入换行、长度前缀或协议分隔符,应显式加入一个 Reader,例如在相邻片段之间插入 strings.NewReader("\n")。如果目标是同时写入多个输出端,应看 io.MultiWriter;如果目标是并行读取后按时间或序号合并,则需要额外的并发协调结构。选择 API 前先确认“顺序原样连接”是不是实际需求。
常见问题
io.MultiReader 会自动关闭底层文件吗?
不会。文件、网络连接等资源必须由打开它们的代码负责关闭。
多个 Reader 之间会自动添加空格或换行吗?
不会。它只连接字节流,分隔符必须由调用方作为输入片段显式提供。
遇到一个 Reader 的普通错误后还会继续下一个吗?
不会。非 EOF 错误会返回给调用方并停止继续读取,是否重试应由业务层决定。
琥珀沙丘与细月手机壁纸怎么做出 OLED 深黑层次
- 上一篇
- 琥珀沙丘与细月手机壁纸怎么做出 OLED 深黑层次
- 下一篇
- MySQL 窗口函数取每组最新记录时如何处理并列时间
-
- Golang · Go教程 | 23分钟前 |
- Go gzip 写入结束后怎么正确关闭并刷新尾部
- 397浏览 收藏
-
- Golang · Go教程 | 34分钟前 |
- Go gzip Header.Name 怎么设置归档文件名
- 251浏览 收藏
-
- Golang · Go教程 | 49分钟前 | go · gzip · 压缩流 · Go gzip compress/gzip Multistream
- Go gzip 多段压缩流怎么连续读取
- 428浏览 收藏
-
- Golang · Go教程 | 1小时前 | 文件处理 · Go教程 · 压缩归档 · Go archive/zip CreateHeader ZIP目录 FileHeader.Name
- Go archive/zip 写入目录条目时怎么避免路径混乱
- 493浏览 收藏
-
- Golang · Go教程 | 1小时前 |
- Go archive/zip 写入文件时怎么设置条目的修改时间
- 131浏览 收藏
-
- Golang · Go教程 | 1小时前 | 文件处理 · 标准库 · Go教程 · archive/zip · Go archive/zip ZIP 文件名 压缩包大小 ZIP64
- Go archive/zip 怎么读取压缩包内文件名和大小
- 280浏览 收藏
-
- Golang · Go教程 | 1小时前 |
- Go encoding/csv 开启 ReuseRecord 后为什么上一条记录会被改写
- 433浏览 收藏
-
- Golang · Go教程 | 1小时前 | 标准库 · go · csv · Go CSV解析 encoding/csv csv.Reader
- Go encoding/csv 中带引号换行的字段怎么解析
- 139浏览 收藏
-
- Golang · Go教程 | 2小时前 | go · csv · 数据导入 · encoding/csv FieldsPerRecord ErrFieldCount
- Go encoding/csv 遇到不齐列数据怎么保留记录
- 203浏览 收藏
-
- Golang · Go教程 | 2小时前 |
- Go bufio.Writer 写文件后为什么必须 Flush
- 420浏览 收藏
-
- Golang · Go教程 | 2小时前 |
- Go bufio.Reader 读取一行时怎么保留行尾换行符
- 498浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 41次使用
-
- SuperCLUE
- SuperCLUE是权威的中文大语言模型综合评测基准,涵盖语言理解、知识应用、AI Agent智能体及安全性等12项核心能力。通过多轮对话与客观测试,定期发布榜单与技术报告,为模型研发、优化及行业选型提供科学依据。
- 191次使用
-
- C-Eval
- 深入了解C-Eval中文评估套件,涵盖52个学科与4级难度。本文详解其功能特点、Zero-shot/Few-shot使用方法及代码示例,助您全面评测LLM中文理解与泛化能力。
- 129次使用
-
- AI Prompt Library
- 探索AI Prompt Library免费资源库,涵盖营销、写作及多场景AI提示词。兼容ChatGPT、Claude等工具,一键复制优化输出,提升工作效率。
- 56次使用
-
- Generrated
- Generrated汇集9300+张DALL·E生成图像及对应提示词,支持查看完整图集、对比DALL·E 2与3版本差异,是AI绘图新手学习Prompt设计与获取创作灵感的实用工具。
- 42次使用
-
- Go map 并发写 panic 怎么办:从共享 map 到可控写入路径
- 2026-06-30 123浏览
-
- GScript 编写标准库示例详解
- 2022-12-30 369浏览
-
- 关于Golang标准库flag的全面讲解
- 2023-02-25 344浏览
-
- Golang标准库unsafe源码解读
- 2022-12-29 464浏览
-
- go语言中的defer关键字
- 2023-02-17 150浏览

