GolangJSON流式解码详解教程

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)
    }
}

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

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)
    }
}

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

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)
}