在Go语言中处理流式数据中的字节序列替换：实用策略与流处理考量

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "io"
    "io/ioutil" // 注意：ioutil.ReadAll 在 Go 1.16+ 中已被 io.ReadAll 替代
    "strings"
)

// MyStruct 定义了预期的 JSON 结构
type MyStruct struct {
    List []interface{} `json:"list"` // 使用 interface{} 以适应不同的列表元素类型
}

// processRequestBody 负责处理 HTTP 请求体，并对特定错误模式进行修正
func processRequestBody(r io.Reader) (MyStruct, error) {
    // 1. 读取整个请求体到内存
    data, err := ioutil.ReadAll(r) // 生产环境中推荐使用 io.ReadAll(r)
    if err != nil {
        return MyStruct{}, fmt.Errorf("读取请求体失败: %w", err)
    }

    // 2. 针对特定的已知服务器 bug 进行实用性修正
    // 假设服务器有时会精确地返回 `{"list": [{}]}`，而我们希望将其视为空列表
    const specificBugPayload = `{"list": [{}]}`
    if string(data) == specificBugPayload {
        fmt.Println("检测到特定的服务器 bug 数据。返回空列表结构。")
        // 返回一个符合预期的空列表结构，避免 JSON 解析错误
        return MyStruct{List: []interface{}{}}, nil
    }

    // 3. 对于其他情况，进行正常的 JSON 解码
    var result MyStruct
    // 使用 bytes.NewReader 将内存中的数据包装成 io.Reader，供 json.NewDecoder 使用
    decoder := json.NewDecoder(bytes.NewReader(data))
    if err := decoder.Decode(&result); err != nil {
        return MyStruct{}, fmt.Errorf("JSON 解码失败: %w", err)
    }
    return result, nil
}

func main() {
    fmt.Println("--- 场景一：正常 JSON 数据 ---")
    normalJSON := `{"list": ["item1", "item2"]}`
    r1 := strings.NewReader(normalJSON)
    res1, err := processRequestBody(r1)
    if err != nil {
        fmt.Println("错误:", err)
    } else {
        fmt.Printf("结果 (正常): %+v\n", res1)
    }
    fmt.Println()

    fmt.Println("--- 场景二：精确匹配到服务器 bug 数据 ---")
    bugJSON := `{"list": [{}]}`
    r2 := strings.NewReader(bugJSON)
    res2, err := processRequestBody(r2)
    if err != nil {
        fmt.Println("错误:", err)
    } else {
        fmt.Printf("结果 (Bug 处理): %+v\n", res2)
    }
    fmt.Println()

    fmt.Println("--- 场景三：包含空对象，但不是精确的 bug 模式 ---")
    // 这种情况下的空对象 `{}` 会被正常解码，如果 MyStruct.List 元素类型是 map[string]interface{} 或 interface{}
    otherEmptyObjectJSON := `{"list": [{}, "item3"]}`
    r3 := strings.NewReader(otherEmptyObjectJSON)
    res3, err := processRequestBody(r3)
    if err != nil {
        fmt.Println("错误:", err)
    } else {
        fmt.Printf("结果 (其他空对象): %+v\n", res3)
    }
    fmt.Println()
}