首页 > Golang > Go教程

GolangJSON流式解析教程详解

时间：2025-09-30 13:18:30 470浏览收藏

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《Golang jsonDecoder流式解析教程》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

使用json.Decoder可高效流式解码大型或流式JSON数据，适用于标准输入、文件和HTTP响应场景，通过decoder.More()判断数据是否继续，逐个解析对象以降低内存占用。

Golang jsonDecoder流式解码操作示例

在处理大型 JSON 数据或从网络流、文件流中读取 JSON 时，使用 json.Decoder 进行流式解码比一次性加载整个 JSON 更高效。Go 的 encoding/json 包提供了 json.NewDecoder 函数，可以从任何实现了 io.Reader 接口的源进行逐步解码。

基本用法：从标准输入流式解码 JSON

下面示例演示如何从 os.Stdin 持续读取 JSON 对象，适用于逐个处理 JSON 记录的场景（如日志流）：

package main

import (
    "encoding/json"
    "log"
    "os"
)

type Person struct {
    Name string `json:"name"`
    Age  int    `json:"age"`
}

func main() {
    decoder := json.NewDecoder(os.Stdin)

    for {
        var person Person
        // 流式读取每一个 JSON 对象
        if err := decoder.Decode(&person); err != nil {
            log.Println("解码结束或出错:", err)
            break
        }
        log.Printf("接收到: %+v\n", person)
    }
}

运行程序后，可以输入多个 JSON 对象（每行一个）：

{"name": "Alice", "age": 30}
{"name": "Bob", "age": 25}

每输入一行，程序就会立即解码并输出一条日志。

从文件中流式读取 JSON 数组

当 JSON 文件包含一个大数组时，避免将整个数组加载到内存。可以通过解码器逐个读取数组元素：

package main

import (
    "encoding/json"
    "log"
    "os"
)

func main() {
    file, err := os.Open("data.json")
    if err != nil {
        log.Fatal("无法打开文件:", err)
    }
    defer file.Close()

    decoder := json.NewDecoder(file)

    // 先读取数组起始符号 [
    if _, err := decoder.Token(); err != nil {
        log.Fatal("读取起始符失败:", err)
    }

    var count int
    for decoder.More() {
        var person Person
        if err := decoder.Decode(&person); err != nil {
            log.Println("解码对象失败:", err)
            continue
        }
        count++
        log.Printf("第 %d 个: %+v", count, person)
    }

    // 读取数组结束符号 ]
    if _, err := decoder.Token(); err != nil {
        log.Fatal("读取结束符失败:", err)
    }
}

对应的 data.json 文件内容：

[
    {"name": "Alice", "age": 30},
    {"name": "Bob", "age": 25},
    {"name": "Charlie", "age": 35}
]

从 HTTP 响应流式解码

在处理来自 API 的大型 JSON 响应时，可以直接从 http.Response.Body 流式解码：

resp, err := http.Get("https://api.example.com/large-stream")
if err != nil {
    log.Fatal("请求失败:", err)
}
defer resp.Body.Close()

decoder := json.NewDecoder(resp.Body)
for decoder.More() {
    var item map[string]interface{}
    if err := decoder.Decode(&item); err != nil {
        log.Println("解码响应项失败:", err)
        break
    }
    // 处理每个 item
    log.Println("收到数据:", item)
}

使用 json.Decoder 能有效降低内存占用，特别适合处理未知大小或持续不断的 JSON 数据流。关键是通过 decoder.More() 判断是否还有更多数据，并配合结构体或接口类型灵活解析。

基本上就这些。根据数据源选择合适的 Reader，就能实现高效稳定的流式解码。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。