本文介绍如何使用 go 反射机制，编写一个与具体结构体解耦的通用方法，将 `[]json.rawmessage` 安全、高效地反序列化为任意目标结构体切片（如 `[]othertype`），无需修改业务逻辑或硬编码类型。
在 Go 中，由于缺乏泛型（在 Go 1.18 前）和类型擦除机制，直接实现“接收任意结构体切片指针并填充数据”的抽象函数是不可行的——编译器无法在编译期推导 interface{} 的底层类型。但借助 reflect 包，我们可以在运行时安全地完成这一任务，同时保持调用层完全类型安全。
核心思路是：让 UnmarshalStruct 接收一个指向目标切片的指针（interface{}），通过反射获取其元素类型与容量，动态创建对应切片，并逐个对 json.RawMessage 执行 json.Unmarshal 到每个元素地址上。
以下是一个完整、可复用的实现示例：
package main
import (
"encoding/json"
"fmt"
"reflect"
)
// 示例源数据结构（模拟 ElasticSearch 返回的 Hits.Source）
type TestStruct struct {
Slice []json.RawMessage // 直接持有 RawMessage 切片，简化层级
}
// UnmarshalStruct 将内部的 RawMessage 切片反序列化为指定结构体切片
// v 必须为 *[]T 类型（即指向切片的指针），否则 panic
func (t TestStruct) UnmarshalStruct(v interface{}) error {
rv := reflect.ValueOf(v)
if rv.Kind() != reflect.Ptr || rv.Elem().Kind() != reflect.Slice {
return fmt.Errorf("UnmarshalStruct: argument must be a pointer to slice, got %v", rv.Kind())
}
slice := rv.Elem()
elemType := slice.Type().Elem()
// 动态分配目标切片（长度 & 容量 = t.Slice 长度）
newSlice := reflect.MakeSlice(slice.Type(), len(t.Slice), len(t.Slice))
for i, raw := range t.Slice {
// 获取第 i 个元素的地址（&slice[i]），用于 Unmarshal
addr := newSlice.Index(i).Addr()
if err := json.Unmarshal(raw, addr.Interface()); err != nil {
return fmt.Errorf("failed to unmarshal item %d: %w", i, err)
}
}
// 将构造好的切片写回原变量
slice.Set(newSlice)
return nil
}再定义两个业务结构体以演示多类型支持：
type Foo struct {
ID int `json:"id"`
Foo string `json:"foo"`
}
type Bar struct {
Bar string `json:"bar"`
Baz string `json:"baz"`
Eee string `json:"eee"`
}调用方式简洁且类型明确：
func main() {
// 模拟 Elastic 返回的原始 JSON 数据（Source 字段）
rawJSONs := []json.RawMessage{
json.RawMessage(`{"id": 1, "foo": "hello"}`),
json.RawMessage(`{"id": 2, "foo": "world"}`),
}
ts := TestStruct{Slice: rawJSONs}
// ✅ 反序列化为 []Foo
var foos []Foo
if err := ts.UnmarshalStruct(&foos); err != nil {
panic(err)
}
fmt.Printf("Foos: %+v\n", foos) // [{ID:1 Foo:"hello"} {ID:2 Foo:"world"}]
// ✅ 同一实例，反序列化为 []Bar（需提供匹配的 raw data）
rawBars := []json.RawMessage{
json.RawMessage(`{"bar": "x", "baz": "y", "eee": "z"}`),
json.RawMessage(`{"bar": "a", "baz": "b", "eee": "c"}`),
}
ts2 := TestStruct{Slice: rawBars}
var bars []Bar
if err := ts2.UnmarshalStruct(&bars); err != nil {
panic(err)
}
fmt.Printf("Bars: %+v\n", bars) // [{Bar:"x" Baz:"y" Eee:"z"} {Bar:"a" Baz:"b" Eee:"c"}]
}⚠️ 重要注意事项：
- UnmarshalStruct 要求传入 &slice（即切片指针），而非切片本身；否则反射无法修改原变量。
- 输入 json.RawMessage 必须与目标结构体字段标签（json:）严格匹配，否则反序列化失败或字段为空。
- 错误处理必须显式检查（如示例中的 if err != nil），避免静默失败。
- 若需更高性能（高频调用），可考虑预编译 json.Decoder 或结合 unsafe 优化（不推荐初学者使用）。
✅ 总结： 该方案在不侵入业务结构、不依赖具体包（如 olievere/elastic）、不牺牲类型安全的前提下，实现了真正意义上的「抽象化反序列化」。它将数据转换逻辑与领域模型彻底解耦，完美适配多索引、多 Schema 的搜索场景，是构建弹性数据访问层的推荐实践。
