从非标准 JSON 流中提取有效 JSON 数据的 Go 语言教程

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "os"
)

// MyStruct 定义了 JSON 数据的结构
type MyStruct struct {
    Command string `json:"command"`
    ID      string `json:"id"`
    Msg     string `json:"msg,omitempty"` //omitempty 表示如果该字段为空，则不序列化
}

func main() {
    // 创建一个缓冲区来保存流数据
    data := make([]byte, 5000) // 根据实际情况调整缓冲区大小

    // 从 stdin 循环读取数据
    for {
        n, err := os.Stdin.Read(data)
        if err != nil {
            fmt.Println("读取错误:", err)
            return // 或使用 panic(err) 取决于错误处理策略
        }

        // 查找换行符的位置，用于分割 JSON 对象
        index := bytes.Index(data[:n], []byte("
"))
        if index == -1 {
            fmt.Println("未找到换行符，可能数据不完整")
            continue // 继续下一次循环，等待更多数据
        }

        // 提取 JSON 数据部分
        jsonData := data[:index]

        // 创建 MyStruct 实例
        var myStruct MyStruct

        // 反序列化 JSON 数据
        err = json.Unmarshal(jsonData, &myStruct)
        if err != nil {
            fmt.Println("JSON 反序列化错误:", err)
            continue // 继续下一次循环，处理下一个 JSON 对象
        }

        // 对 myStruct 进行处理
        fmt.Printf("解析到的结构体: %+v
", myStruct)

        // 移除已处理的数据和分隔符 "end
"
        remainingData := data[index+1:]

        // 检查是否包含 "end
" 分隔符
        endIndex := bytes.Index(remainingData[:n-index-1], []byte("end
"))
        if endIndex == -1 {
            fmt.Println("未找到 'end\n' 分隔符")
            continue
        }

        // 移动剩余数据到缓冲区开头
        copy(data, remainingData[endIndex+len("end
"):])
        // 重置缓冲区剩余部分
        for i := len(remainingData[endIndex+len("end
"):]); i < len(data); i++ {
            data[i] = 0
        }
    }
}