Go io.MultiWriter 一个目标失败后如何处理部分写入

先说结论：io.MultiWriter 会把一次 Write 按参数顺序逐个交给目标。前面的目标已经写成功、后面的目标尚未调用时，如果中间目标返回错误，MultiWriter 不会回滚，也不会继续向后写。因此它适合“尽量复制并报告第一个失败点”，不等于事务广播。

处理部分写入的关键不是重试整个 MultiWriter，而是记录本次写入的目标顺序、失败目标和原始数据，再按目标能力做幂等补偿。

本文只讨论一个目标失败时的判断方式。最终返回的 n 是出错目标本次返回的字节数，不是所有目标已经写入的字节总和。

MultiWriter 为什么会留下部分结果

io.MultiWriter(a, b, c) 内部按 a → b → c 的顺序写同一份 p。某个目标返回非空错误时，当前调用立即停止；如果目标返回的字节数少于 len(p) 但没有错误，MultiWriter 会用 io.ErrShortWrite 停止。于是可能出现三种结果：

• a 已完整写入，b 返回错误，c 根本没有被调用。
• a 已完整写入，b 短写，返回 ErrShortWrite，后续仍停止。
• a、b 已成功，c 只写入一部分并返回错误。

这也是为什么不能看到 n > 0 就把所有目标都当成成功。n 只描述当前失败目标的返回值；前序目标是否成功，需要调用方自己记录。

先把失败目标和已完成目标记下来

如果业务需要补偿，建议不要直接把文件、日志、网络对象混在一个匿名列表里。给每个目标加名称，并在包装器中记录每次调用的结果。下面的代码是结构示例，不代表已经在本地执行：

type namedWriter struct {
	name string
	w    io.Writer
	log  *[]string
}

func (w namedWriter) Write(p []byte) (int, error) {
	// 记录每个目标的结果，便于区分“已写入”和“尚未调用”。
	n, err := w.w.Write(p)
	if err != nil {
		*w.log = append(*w.log, w.name+": failed")
		return n, err
	}
	if n != len(p) {
		// 遵守 io.Writer 约定，把短写转换为明确错误。
		*w.log = append(*w.log, w.name+": short write")
		return n, io.ErrShortWrite
	}
	*w.log = append(*w.log, w.name+": ok")
	return n, nil
}

var events []string
w := io.MultiWriter(
	namedWriter{"primary", primary, &events},
	namedWriter{"mirror", mirror, &events},
	namedWriter{"audit", audit, &events},
)
n, err := w.Write(payload)
// n 和 err 只对应本次停止位置；events 才能说明前序目标。
_ = n
_ = err

这个包装器的价值是留下可解释记录，而不是把 MultiWriter 变成原子操作。若 mirror 失败，events 会有 primary: ok 和 mirror: failed，不会凭空出现 audit: ok。

重试时不要把前序目标重复写一遍

最安全的补偿方式取决于目标。可追加的日志通常可以从失败目标开始补写；带偏移量的文件或对象存储应使用稳定记录号；外部接口则要带幂等键，避免重试造成重复业务操作。若无法判断前序目标是否已经落盘，先读取目标状态或写入带唯一 ID 的记录，再决定补偿。

还要注意资源生命周期：文件目标要处理 Close 错误，网络目标要区分连接失败和服务端拒绝；这些都不是 MultiWriter 自动提供的回滚信息。

上线前检查这四个边界

1. 目标顺序是否固定？如果顺序会变化，故障记录就无法稳定定位。
2. 每个目标是否有可观测名称、请求 ID 或记录 ID？不要只记录一个布尔成功值。
3. 重试是否幂等？至少要能判断“已经写过”“写到哪里”和“还缺多少”。
4. 是否明确接受部分成功？如果业务必须全成全败，就需要事务型存储或自定义协调协议，不能只套 MultiWriter。

常见问题

MultiWriter 会并发写多个目标吗？

不会。标准实现按列表顺序逐个写入；需要并发时要自己设计并发、错误汇总和取消策略。

一个目标短写但返回 nil 会怎样？

MultiWriter 会返回 io.ErrShortWrite 并停止，不会继续调用后续目标。

能不能直接再次调用同一个 MultiWriter？

只有在所有目标都能安全幂等重放时才可以。更常见的做法是记录停止位置，只补偿确认失败或未调用的目标。