Go语言中结构体与dynamic.Message/proto.Message互转报错，求解决方案

错误原因 #

你遇到的cannot unmarshal string into Go struct field ... timestamppb.Timestamp错误，本质是标准库encoding/json不兼容Protobuf的特殊类型（如timestamppb.Timestamp）。Protobuf的JSON序列化有专属规范（比如Timestamp以RFC3339字符串形式存在），标准库无法识别并转换为timestamppb.Timestamp结构体；同时你通过自定义结构体Response中转的方式，绕了不必要的JSON中间层，进一步放大了格式兼容性问题。

最优解决方案：直接操作或转换Protobuf消息 #

优先避免JSON中转，直接基于Protobuf生态的工具处理dynamic.Message和静态proto.Message的互转及修改：

方案1：直接修改dynamic.Message（无需转换） #

利用dynamic.Message的反射API直接修改字段值，完全跳过JSON和自定义结构体：

import (
    "fmt"
    "google.golang.org/protobuf/types/dynamicpb"
)

func modifyDynamicInput(input *dynamicpb.Message) error {
    // 逐层定位到目标字段：Updates[0].Entry.Metadata.Description
    updatesField := input.GetMessageDescriptor().Fields().ByName("Updates")
    if updatesField == nil {
        return fmt.Errorf("field 'Updates' not found in message")
    }
    updatesList := input.GetField(updatesField).(*dynamicpb.List)
    if updatesList.Len() == 0 {
        return fmt.Errorf("no entries in 'Updates' list")
    }
    firstUpdate := updatesList.Get(0).(*dynamicpb.Message)

    entryField := firstUpdate.GetMessageDescriptor().Fields().ByName("Entry")
    if entryField == nil {
        return fmt.Errorf("field 'Entry' not found in update")
    }
    entryMsg := firstUpdate.GetField(entryField).(*dynamicpb.Message)

    metadataField := entryMsg.GetMessageDescriptor().Fields().ByName("Metadata")
    if metadataField == nil {
        return fmt.Errorf("field 'Metadata' not found in entry")
    }
    metadataMsg := entryMsg.GetField(metadataField).(*dynamicpb.Message)

    descField := metadataMsg.GetMessageDescriptor().Fields().ByName("Description")
    if descField == nil {
        return fmt.Errorf("field 'Description' not found in metadata")
    }
    // 修改字段值
    metadataMsg.SetField(descField, "18")
    return nil
}

方案2：dynamic.Message与静态proto.Message互转 #

如果更习惯操作静态生成的Protobuf结构体（如v1.SetRequest），可以用proto包直接完成互转：

import (
    "google.golang.org/protobuf/proto"
    "google.golang.org/protobuf/types/dynamicpb"
)

func convertAndModify(input *dynamicpb.Message) (*dynamicpb.Message, error) {
    // 1. dynamic.Message转静态proto.Message
    staticReq := &v1.SetRequest{}
    if err := proto.Unmarshal(input.Value, staticReq); err != nil {
        return nil, err
    }

    // 2. 修改静态结构体字段
    staticReq.Updates[0].Entry.Metadata.Description = "18"

    // 3. 静态proto.Message转回dynamic.Message
    newDynamicMsg := &dynamicpb.Message{}
    newDynamicMsg.MessageDescriptor = staticReq.ProtoReflect().Descriptor()
    if err := proto.Marshal(staticReq, &newDynamicMsg.Value); err != nil {
        return nil, err
    }
    return newDynamicMsg, nil
}

兼容JSON中转的修复方案（不推荐，仅作备选） #

如果必须通过自定义结构体Response中转，需替换标准库JSON为Protobuf专属的protojson工具，它能正确处理timestamppb.Timestamp等特殊类型：

import (
    "google.golang.org/protobuf/encoding/protojson"
)

// 修改后的转换代码
var data Response
// 用protojson代替json.Unmarshal，从dynamic.Message的Value反序列化
if err := protojson.Unmarshal(input.Value, &data); err != nil {
    return err
}
data.Updates[0].Entry.Metadata.Description = "18"

new_input := &v1.SetRequest{}
// 用protojson序列化data，再反序列化为静态proto.Message
dataByte, err := protojson.Marshal(&data)
if err != nil {
    return err
}
if err := protojson.Unmarshal(dataByte, new_input); err != nil {
    log.Fatalf("Unmarshal error: %v", err)
}

内容的提问来源于stack exchange，提问作者LST