
本文详解如何使用 go 语言正确解析包含多个 json 对象的数组文件,并将每个对象作为独立 json 字符串发送至 rest 接口,涵盖结构体定义、动态解析、序列化与 http 请求实践。
在 Go 中处理未知结构的 JSON 数组(如从文件读取的 [{}, {}] 格式),最灵活且实用的方式是采用 json.RawMessage 或 interface{} 进行动态解析,而非强行定义嵌套结构体——尤其当字段名不规范(如含空格、斜杠)、类型混杂或结构深度不确定时(如 NAME4 和 NAME8 中嵌套的数组对象)。
✅ 正确解析 JSON 数组的核心步骤
- 读取文件内容:使用 os.ReadFile(替代已弃用的 ioutil.ReadFile)获取原始字节;
- 解码为 []interface{}:直接将顶层 JSON 数组解码为 Go 的切片,每个元素为 interface{};
- 逐项序列化并发送:对每个元素调用 json.Marshal 转为字节流,再通过 http.Post 或 http.Client.Do 发送。
以下是完整、可运行的示例代码:
package main
import (
"bytes"
"encoding/json"
"fmt"
"io"
"log"
"net/http"
"os"
)
func main() {
// 1. 读取 JSON 文件
data, err := os.ReadFile("dat_one_extract.json")
if err != nil {
log.Fatalf("读取文件失败: %v", err)
}
// 2. 解析为 JSON 数组([]interface{})
var jsonArray []interface{}
if err := json.Unmarshal(data, &jsonArray); err != nil {
log.Fatalf("JSON 解析失败: %v", err)
}
fmt.Printf("成功加载 %d 个 JSON 对象\n", len(jsonArray))
// 3. 遍历每个对象,序列化并发送到 REST 接口
for i, obj := range jsonArray {
// 将单个对象重新编码为 JSON 字节(保持原始结构和键名)
jsonBytes, err := json.Marshal(obj)
if err != nil {
log.Printf("第 %d 个对象序列化失败: %v", i+1, err)
continue
}
// 示例:发送到本地测试接口(请替换为实际 endpoint)
resp, err := http.Post(
"https://httpbin.org/post", // 替换为目标 REST URL
"application/json",
bytes.NewBuffer(jsonBytes),
)
if err != nil {
log.Printf("第 %d 个对象发送失败: %v", i+1, err)
continue
}
defer resp.Body.Close()
// 可选:检查响应状态
if resp.StatusCode < 200 || resp.StatusCode >= 300 {
body, _ := io.ReadAll(resp.Body)
log.Printf("第 %d 个对象返回非成功状态 %d: %s", i+1, resp.StatusCode, string(body))
continue
}
fmt.Printf("✅ 第 %d 个对象发送成功(%d 字节)\n", i+1, len(jsonBytes))
}
}⚠️ 关键注意事项
- 避免使用 json.RawMessage 误用场景:若你只需「透传」原始 JSON(不修改结构),json.RawMessage 更高效;但本例中需遍历并发送,[]interface{} + json.Marshal 更直观安全。
- 字段命名兼容性:原 JSON 中存在 "Contact Zip"、"Date of Contact" 等含空格键名,不可用结构体字段自动映射(Go 结构体字段无法含空格),因此必须使用 map[string]interface{} 或 interface{} 动态方式。
- 错误处理不可省略:每个 json.Marshal 和 http.Post 都应单独检查错误,避免因单条数据失败导致整个流程中断。
- 内存友好建议(大数据量):若 JSON 文件极大(GB 级),应改用 json.Decoder 流式解析(配合 bufio.Scanner 分块读取),而非一次性加载全部内容到内存。
✅ 总结
无需预先定义复杂嵌套结构体,Go 的 encoding/json 包天然支持通过 interface{} 实现“无 schema”解析。核心逻辑即:读取 →json.Unmarshal到[]interface{}→ 遍历 →json.Marshal` → HTTP 发送。该方案简洁、健壮、符合 Go 的惯用风格,也便于后续扩展(如添加重试、并发控制、日志追踪等)。
如需进一步支持并发发送(提升吞吐)、请求头设置(如 Authorization)、或超时控制,可在 http.Client 上配置自定义实例,这正是 Go 网络编程灵活性的体现。










