Golang怎么JSON流式编解码_Golang如何用Decoder和Encoder处理JSON流【进阶】-Golang-PHP中文网

json.Decoder 卡住是因为它等待完整 JSON 值，不自动处理流式分块或未闭合结构；需确保输入语义清晰（如 NDJSON）或明确边界。

golang怎么json流式编解码_golang如何用decoder和encoder处理json流【进阶】

常见现象是：用 json.Decoder 读取 HTTP 响应或管道数据时，程序 hang 在 Decode() 调用上，不报错也不返回。根本原因不是 bug，而是它默认等待完整 JSON 值——哪怕你只传了半个对象、多了一个逗号、或者流还没结束。

HTTP 场景下，服务端可能分块传输（chunked），但 Decoder 不会主动等下一块；它只从当前 io.Reader 里“啃”出一个合法 JSON 值就停，剩下的字节留在缓冲区
如果上游写入未关闭连接、也未发送完整 JSON（比如数组少了个 ]），Decode() 就一直阻塞
解决办法不是加超时（那只是掩盖问题），而是确保输入流语义清晰：用换行分隔的 JSON（NDJSON）或明确控制边界

json.Encoder 内部带缓冲，调用 Encode() 后数据未必立刻写出。在流式场景（如写入 http.ResponseWriter 或 os.Stdout）中，这会导致接收方迟迟收不到数据，甚至超时断连。

必须显式调用 Flush() —— 它不是可选优化，是流式输出的必要步骤
注意：Flush() 只刷编码器自己的缓冲，不保证底层 writer（如 bufio.Writer）也刷出去；如果 wrapper 了 bufio.Writer，得再调一次它的 Flush()
示例：向 WebSocket 发送 JSON 流时，漏掉 enc.Flush()，前端永远收不到第一条消息

日志、事件流、API 分页响应常用 NDJSON 格式。Go 标准库没有内置 NDJSON 解析器，但 json.Decoder 可以复用，只需注意换行处理。

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

别用 bytes.Split() 先切行再解析——浪费内存，且无法处理跨行字符串（JSON 字符串里允许换行）
正确做法：把输入包装成 bufio.Scanner，用 ScanLines 拆行，每行丢给独立的 json.NewDecoder(strings.NewReader(line)) 解析
性能提示：重复创建 Decoder 开销小，比维护一个 Decoder 并手动跳过换行更可靠；因为 Decoder 不会自动跳过行尾符，自己管理状态容易出错
错误处理要细粒度：某一行解析失败（invalid character），不影响后续行

不能。同一个 json.Decoder 或 json.Encoder 实例被多个 goroutine 同时调用 Decode() 或 Encode()，会引发 panic 或数据错乱。

典型误用：起一堆 goroutine 共享一个 Decoder 读同一 TCP 连接 —— 即使加锁也难保字节边界对齐，很可能把一个 JSON 值拆到两个 goroutine 里解析
正确模式：每个 goroutine 持有自己独立的 Decoder/Encoder，共享底层 io.Reader/io.Writer 时需额外同步（如用 sync.Mutex 包裹 Read/Write）
更推荐解耦：用 channel 分发解析后的结构体，而不是分发原始字节流