登录
首页 >  Golang >  Go教程

GolangJSON流式解码详解教程

时间：2026-04-17 09:58:35 490浏览 收藏

本文深入介绍了 Go 语言中使用 `json.Decoder` 进行流式 JSON 解码的核心技巧与实战场景，涵盖从标准输入、大文件数组到 HTTP 响应等典型数据源，强调通过逐个解析而非全量加载来显著降低内存占用、提升处理效率；借助 `decoder.More()` 动态判断数据连续性，并结合结构体或 `interface{}` 灵活解码，让开发者轻松应对海量、动态或持续流入的 JSON 数据流——无论你是处理日志、ETL 管道还是实时 API 响应，这套轻量、稳定、原生的流式解码方案都值得立刻上手实践。

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，就能实现高效稳定的流式解码。

理论要掌握，实操不能落！以上关于《GolangJSON流式解码详解教程》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！

资料下载
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>