用 encoding/json/v2 流式读取连续 JSON 值

如果输入不是一个 JSON 数组，而是这样连续到来的多个顶层对象：{"id":1} {"id":2}，Go 1.27 的 encoding/json/v2 可以用 jsontext.Decoder 配合 json.UnmarshalDecode 逐个读取。每次调用只处理下一个 JSON 值，读完后返回 io.EOF；不要把所有字节先拼成一个数组，也不要把普通解码错误误判成结束。

先区分连续顶层值与一个 JSON 数组

Unmarshal 面向单个 JSON 值，输入必须能解释成一个完整的顶层值。连续对象则更像消息流或逐条日志：每条对象独立结束，下一条紧接着到来。此时循环的单位不是数组元素，而是“下一个顶层 JSON 值”。

例如 {"id":1,"kind":"open"}\n{"id":2,"kind":"close"} 是两个对象；[{"id":1},{"id":2}] 才是一个数组。前者用流式逐值解码，后者可以一次解码到切片。这个边界先判断清楚，后面的 API 选择就不会混乱。

用 jsontext.Decoder 接住 io.Reader

v2 把 JSON 语法读取和 Go 类型语义拆成两个包：encoding/json/jsontext 负责从 io.Reader 读取 JSON 文本，encoding/json/v2 负责把下一个值放进 Go 目标。文件、HTTP 响应体和字符串读取器都可以沿用同一种入口。

package main

import (
	"encoding/json/jsontext"
	json "encoding/json/v2"
	"fmt"
	"io"
	"log"
	"strings"
)

type Event struct {
	ID   int    `json:"id"`
	Kind string `json:"kind"`
}

func main() {
	// 空白分隔的两个顶层对象，模拟逐条到来的消息流。
	input := strings.NewReader(`{"id":1,"kind":"open"}
{"id":2,"kind":"close"}`)
	dec := jsontext.NewDecoder(input)

	for {
		var event Event
		// 每次只把下一个 JSON 值解码到当前目标结构体。
		err := json.UnmarshalDecode(dec, &event)
		if err == io.EOF {
			// 没有下一个顶层值时，EOF 是正常结束条件。
			break
		}
		if err != nil {
			// 截断、非法语法和字段类型错误都不能静默跳过。
			log.Fatalf("decode event stream: %v", err)
		}
		fmt.Printf("id=%d kind=%s\n", event.ID, event.Kind)
	}
}

关键点是目标参数必须传指针。每轮使用新的 Event 变量，能避免上一条对象残留字段影响下一条；如果复用目标，也要确认 v2 的对象合并语义符合你的业务预期。

循环调用 UnmarshalDecode 读取下一个值

这段循环把“数据”和“控制信号”分开：返回 nil 表示成功得到一条记录，io.EOF 表示流自然结束，其他错误则说明当前输入或目标类型需要处理。换行不是必须条件，空格、制表符和换行都只是 JSON 值之间的空白。

流式不等于每条记录都零内存。当前目标对象仍需要占用内存，超大单条值也可能很重；它解决的是不必把整个输入先收集成一个巨大字节切片，并且能在前一条成功后尽早交给业务处理。

把语法错误与语义错误分开处理

输入是 {"id":1 这类未闭合文本时，属于 JSON 语法没有完成；输入是 {"id":"one"} 而目标字段为 int 时，则是目标类型无法承接该值。两者都不是 io.EOF，否则会把坏数据伪装成正常收尾。

生产代码可以把来源标识、已处理条数和当前批次一起写入错误日志。若允许跳过坏记录，应先把原始记录隔离下来；不要在解码器已经消费到不确定位置后盲目继续，因为后面的字节未必仍位于可靠的顶层边界。

还要留意 v2 的语义变化：JSON v2 默认拒绝无效 UTF-8 和重复对象名，和旧版 encoding/json 的历史默认行为并不完全相同。迁移时如果输入来自旧系统，应把这类兼容性作为明确的回归样本，而不是只替换 import 路径。

按输入边界选择 v2、v1 或数组方案

如果要控制 JSON v2 的语法选项，可以在创建 jsontext.Decoder 时配置对应选项；解码到 Go 类型的选项则传给 UnmarshalDecode。不要把“连续值”理解成“必须每行一个对象”，真正的边界是每个顶层 JSON 值能否独立完成。

常见问题

连续 JSON 值之间必须换行吗？

不必须。只要前一个值已经结束，后面有合法 JSON 空白即可；换行只是日志和人工查看时更方便。

为什么不能对连续对象直接调用一次 Unmarshal？

Unmarshal要求输入解释为一个顶层 JSON 值。连续对象没有共同的数组边界，应改用解码器逐个消费。

遇到字段类型错误后能否继续读下一条？

默认不建议直接继续。先记录错误并确认解码器边界是否仍可控；对不可信输入，更稳妥的做法是隔离当前流或在上游按记录切分。

处理连续 JSON 的核心不是把数据拆成很多行，而是让解码循环以“下一个顶层值”为单位，并只把 io.EOF 当作正常结束。