Go JSON 多态字段怎么用 RawMessage 延迟选择结构体

接口里有一个字段可能是用户、订单或设备，最稳妥的做法不是先把它解成 map[string]any，而是先读取类型标识，再用 json.RawMessage 延迟选择目标结构体。这样既保留了标准库的类型检查，也不会为每种 payload 设计一套重复的外层解析逻辑。

先让外层结构知道该延迟哪一块

假设消息都有 kind 和 payload，但 payload 的字段随 kind 改变。外层只声明稳定字段，变化部分使用 json.RawMessage：

type Envelope struct {
    Kind    string          `json:"kind"`
    Payload json.RawMessage `json:"payload"` // 暂不决定 payload 的具体类型
}

它的价值在于“先拆信封，后拆内容”。json.Unmarshal 读取 Envelope 时不会把 payload 降级成浮点数、字符串和 map[string]any 的混合树；RawMessage 会保留这段 JSON，等判别字段可用后再处理。

根据 kind 选择结构体，再做第二次解码

下面用两种事件演示完整分支。每个分支只负责创建目标值，真正的 JSON 解码统一放在末尾，调用方拿到的是具体类型。

package main

import (
    "encoding/json"
    "fmt"
)

type Envelope struct {
    Kind    string          `json:"kind"`
    Payload json.RawMessage `json:"payload"` // 延迟到 kind 确定后再解码
}

type UserCreated struct {
    ID    string `json:"id"`
    Email string `json:"email"`
}

type OrderPaid struct {
    OrderID string `json:"order_id"`
    Amount  int64  `json:"amount"`
}

func decodePayload(e Envelope) (any, error) {
    var target any
    switch e.Kind {
    case "user.created":
        target = new(UserCreated)
    case "order.paid":
        target = new(OrderPaid)
    default:
        return nil, fmt.Errorf("unsupported event kind %q", e.Kind) // 未知类型尽早失败
    }

    if len(e.Payload) == 0 || string(e.Payload) == "null" {
        return nil, fmt.Errorf("empty payload for %q", e.Kind) // 不把空值当合法对象
    }
    if err := json.Unmarshal(e.Payload, target); err != nil {
        return nil, fmt.Errorf("decode %s payload: %w", e.Kind, err) // 保留类型上下文
    }
    return target, nil
}

func main() {
    input := []byte(`[{"kind":"user.created","payload":{"id":"u-7","email":"a@example.com"}},
        {"kind":"order.paid","payload":{"order_id":"o-9","amount":1200}}]`)

    var events []Envelope
    if err := json.Unmarshal(input, &events); err != nil {
        panic(err) // 外层 JSON 结构错误，直接终止本次读取
    }
    for _, event := range events {
        value, err := decodePayload(event)
        if err != nil {
            fmt.Println("skip:", err) // 单条消息失败不必隐藏原因
            continue
        }
        fmt.Printf("%s -> %T\n", event.Kind, value)
    }
}

这里的关键不是写一个很长的 switch，而是让 switch 只决定“目标类型”，让解码、错误包装和空值判断保持一条路径。以后增加 device.online 时，只需新增结构体与分支，不会把外层循环改成反射代码。

三个容易漏掉的边界：null、未知字段和未知 kind

如果某个内部接口必须拒绝未知字段，可以只对选中的 payload 使用 json.Decoder 和 DisallowUnknownFields。不要为了严格校验而把所有消息先解成 map[string]any，那样会丢掉数字类型和结构体级别的约束。

把多态解析封装成稳定的调用边界

生产代码通常还要限制支持的 kind，并把原始消息放入日志或死信队列。建议让解析函数返回 any 与错误，业务层再用类型断言或进一步封装成接口；不要在解析函数里偷偷执行副作用。

还要注意，RawMessage 是一份 JSON 字节数据，不等于已经完成业务校验。金额范围、邮箱格式、事件版本等规则仍应在结构体解码成功后单独检查。这样“语法正确”“类型正确”和“业务可接受”三层职责才不会混在一起。

常见问题

RawMessage 和 map[string]any 有什么区别？

RawMessage 保留原始 JSON，适合延迟选择目标结构体；map[string]any 已经把内容转换成通用树，数字和嵌套类型需要调用方自己恢复。

未知字段应该报错吗？

面向可演进服务的读取端通常保留默认兼容行为；只有契约要求严格拒绝时，才对选中的 payload 使用 DisallowUnknownFields。

可以把 RawMessage 直接存进数据库吗？

可以作为原始 JSON 保存，但写入前仍要限制大小、确认 JSON 有效，并在读取时按版本和 kind 做迁移或兼容处理。