go 的 json 编码器无法直接处理 io.reader 类型，因其不实现 marshaler 接口；需封装为可序列化的自定义类型（如 jsonreader），通过实现 marshaljson/unmarshaljson 方法，将 reader 内容转为字符串再编码，从而支持持久化与重建。
go 的 json 编码器无法直接处理 io.reader 类型，因其不实现 marshaler 接口；需封装为可序列化的自定义类型（如 jsonreader），通过实现 marshaljson/unmarshaljson 方法，将 reader 内容转为字符串再编码，从而支持持久化与重建。
在 Go 中，json.Marshal() 和 json.Unmarshal() 仅能处理可直接映射为 JSON 基本类型的值（如 string、int、map、slice 等），而 io.Reader 是一个接口，本身不携带可序列化的数据状态——它仅表示“可读能力”，其底层数据可能已消耗、不可重放，且无默认 JSON 表示。因此，当你将 Body io.Reader 直接嵌入结构体并调用 json.Marshal() 时，该字段会被忽略（或序列化为空），反序列化后自然为 nil。
✅ 正确做法是：用可序列化的具体类型替代 io.Reader 接口，并显式控制编解码逻辑。推荐方案是定义一个包装类型（如 JSONReader），内嵌 *bytes.Reader 并实现 json.Marshaler 和 json.Unmarshaler 接口：
type Response struct {
Headers map[string][]string `json:"headers"`
Body *JSONReader `json:"body,omitempty"`
Status int `json:"status"`
}
type JSONReader struct {
*bytes.Reader
}
func NewJSONReader(data []byte) *JSONReader {
return &JSONReader{bytes.NewReader(data)}
}
// MarshalJSON 将 Reader 内容读取为字符串，并以 JSON 字符串形式编码（带双引号）
func (r JSONReader) MarshalJSON() ([]byte, error) {
data, err := io.ReadAll(r.Reader)
if err != nil {
return nil, err
}
// 注意：需手动添加引号，因为 json.MarshalString 已被弃用；此处用 strconv.Quote 更安全
return []byte(strconv.Quote(string(data))), nil
}
// UnmarshalJSON 从 JSON 字符串中解析内容，重建 bytes.Reader
func (r *JSONReader) UnmarshalJSON(data []byte) error {
if r == nil {
return errors.New("json.JSONReader: UnmarshalJSON on nil pointer")
}
var s string
if err := json.Unmarshal(data, &s); err != nil {
return err
}
r.Reader = bytes.NewReader([]byte(s))
return nil
}
? 关键细节说明：
-
MarshalJSON()中使用io.ReadAll完整读取 Reader 数据（注意：原ioutil.ReadAll已移至io包）； - 使用
strconv.Quote(string(data))替代手动拼接"，避免特殊字符（如换行、引号）导致 JSON 格式错误； -
UnmarshalJSON()先解码为string，再转为[]byte创建新bytes.Reader，确保每次反序列化都获得可读、未消耗的 Reader； - 结构体字段
Body应声明为*JSONReader（指针），否则UnmarshalJSON无法修改接收者；
? 使用示例：
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
// 构造响应
resp := &Response{
Headers: map[string][]string{"Content-Type": {"application/json"}},
Body: NewJSONReader([]byte(`{"id":123,"name":"test"}`)),
Status: 200,
}
// 序列化存库
data, _ := json.Marshal(resp)
fmt.Printf("Serialized: %s\n", data)
// 输出类似：{"headers":{"Content-Type":["application/json"]},"body":"{\"id\":123,\"name\":\"test\"}","status":200}
// 反序列化还原
var r Response
json.Unmarshal(data, &r)
bodyBytes, _ := io.ReadAll(r.Body)
fmt.Printf("Recovered body: %s\n", bodyBytes) // {"id":123,"name":"test"}
⚠️ 注意事项：
- 此方案适用于中小体积、可全部载入内存的 Body 数据（如 API 响应体）；若 Body 过大（如 GB 级文件流），不应强制全量读取，而应改用数据库 BLOB 字段单独存储二进制数据，结构体中仅保存 ID 或路径；
-
JSONReader不支持并发读取（bytes.Reader本身非线程安全），多 goroutine 访问需加锁或按需Clone()； - 若需兼容
io.ReadCloser（如 HTTP 响应体），应在业务层关闭资源，JSONReader本身无需 Close —— 它只是数据快照，非资源持有者。
总之，接口不能直接序列化，但可通过适配器模式赋予其编解码能力。JSONReader 是典型实践：它把“读取行为”转化为“静态数据表示”，让 Go 的 JSON 生态无缝支持流式字段的持久化需求。
