本文介绍如何通过 go 反射机制,设计一个与业务结构体完全解耦的通用反序列化方法,将 `[]json.rawmessage` 安全、高效地转换为任意目标结构体切片(如 `[]othertype`),无需修改核心逻辑即可支持多种 elasticsearch 返回类型。
在构建面向 ElasticSearch 等外部数据源的 Go 应用时,常面临「同一数据获取层需适配多种业务结构体」的问题:例如两个索引分别返回 {foo, id} 和 {bar, baz, eee} 形式的文档,对应 FooDoc 和 BarDoc 两种结构体。若为每种类型单独编写反序列化逻辑,会导致高度重复、难以维护。理想方案是定义一个零耦合、强抽象的 UnmarshalStruct 方法——它不感知具体结构体定义,仅接收目标切片的指针,自动完成批量 json.Unmarshal。
核心难点在于:Go 不支持泛型切片的直接类型擦除(如 []interface{} 无法直接接收 []OtherType 的地址),而 append 也无法在编译期推导目标元素类型。此时,反射(reflect)是唯一可行的标准库方案。
以下是一个生产就绪的实现:
import (
"encoding/json"
"reflect"
)
type TestStruct struct {
Slice []json.RawMessage // 直接持有 RawMessage 切片,避免多层嵌套解包
}
// UnmarshalStruct 将 t.Slice 中每个 json.RawMessage 反序列化为 v 指向的切片元素
// v 必须为 *[]T 类型(即指向某个结构体切片的指针)
func (t TestStruct) UnmarshalStruct(v interface{}) error {
// 1. 获取 v 所指的切片 Value(要求 v 是指针)
rv := reflect.ValueOf(v)
if rv.Kind() != reflect.Ptr || rv.IsNil() {
return fmt.Errorf("UnmarshalStruct: v must be a non-nil pointer to slice")
}
slice := rv.Elem()
if slice.Kind() != reflect.Slice {
return fmt.Errorf("UnmarshalStruct: v must point to a slice, got %s", slice.Kind())
}
// 2. 重置目标切片容量与长度,匹配原始数据量
slice = reflect.MakeSlice(slice.Type(), len(t.Slice), len(t.Slice))
rv.Elem().Set(slice) // 写回原变量
// 3. 遍历 RawMessage,逐个反序列化到切片元素地址
for i, raw := range t.Slice {
elemPtr := slice.Index(i).Addr().Interface() // 获取 &slice[i]
if err := json.Unmarshal(raw, elemPtr); err != nil {
return fmt.Errorf("failed to unmarshal item %d: %w", i, err)
}
}
return nil
}
使用方式简洁直观: