从包含分隔符的 JSON 流中提取有效 JSON 数据

package main

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

type MyStruct struct {
    Command string `json:"command"`
    ID      string `json:"id"`
    Msg     string `json:"msg,omitempty"` //omitempty 可以在json序列化时忽略空值
}

func main() {
    // 创建一个缓冲区来保存流数据
    data := make([]byte, 5000)

    // 从 stdin 循环读取数据
    for {
        n, err := os.Stdin.Read(data)
        if err != nil {
            fmt.Println("Error reading from stdin:", err)
            return // 或者 panic(err) 如果你希望程序在发生错误时崩溃
        }

        // 查找换行符的位置，假设 JSON 数据以换行符结尾
        index := bytes.IndexByte(data[:n], '\n') // 只在读取到的数据范围内查找
        if index == -1 {
            fmt.Println("No newline found in the input")
            continue // 继续下一次循环
        }

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

        // 反序列化 JSON 数据
        var myStruct MyStruct
        err = json.Unmarshal(jsonData, &myStruct)
        if err != nil {
            fmt.Println("Error unmarshaling JSON:", err)
            continue // 继续下一次循环
        }

        // 处理 myStruct
        fmt.Printf("Received: %+v\n", myStruct)

        // 跳过 "end" 行
        // 假设 "end" 行紧随 JSON 数据之后，并且以换行符结尾
        endLine := make([]byte, 4) // "end\n" 的长度
        _, err = os.Stdin.Read(endLine)
        if err != nil {
            fmt.Println("Error reading 'end' line:", err)
            return // 或者 panic(err)
        }
        if string(endLine) != "end\n" && string(endLine) != "end\r" {
            fmt.Println("Expected 'end' line, but got:", string(endLine))
            // 如果不是 "end\n"，可能需要采取其他错误处理措施
            // 例如，将 endLine 的内容放回 stdin 中，以便下次读取
        }
    }
}