我有来自数据库的数据是json.RawMessage格式的.具体的列是jsonb.
我真的找不到一种方法来将数据解组到一个在proto上被定义为协议缓冲区的属性.
repeated google.protobuf.Any list = 1;
当我try 使用json.Unmarshal()对数据库中的数据进行解组时，则list为空.文档中提到了如下内容:
foo := &pb.Foo{...}
any, err := anypb.New(foo)
if err != nil {
...
}
...
foo := &pb.Foo{}
if err := any.UnmarshalTo(foo); err != nil {
...
}
但在这个例子中，foo是proto.Message类型的，我不能转换，因为我有json.RawMessage.
我有什么办法可以做到这一点吗？
首先，您应该了解DB列中存储的内容.json.RawMessage被简单地定义为type RawMessage []byte(见the doc).而且它没有提供足够的信息来回答你的问题.
我将提供一个演示来展示google.protobuf.Any是如何工作的，这将帮助您更好地理解您的问题.
Notes:
Foo and Bar) in the demo.
Any消息类型允许您将消息用作嵌入类型，而无需.proto定义.Any包含作为字节的任意序列化消息，以及充当该消息类型的全局唯一标识符并解析为该消息类型的URL.
main.go中的 comments .演示的文件夹 struct :
├── go.mod
├── main.go
└── pb
├── demo.pb.go
└── demo.proto
go.mod:
module github.com/ZekeLu/demo
go 1.19
require (
github.com/golang/protobuf v1.5.2
google.golang.org/protobuf v1.28.1
)
pb/demo.proto:
syntax = "proto3";
package pb;
import "google/protobuf/any.proto";
option go_package = "github.com/ZekeLu/demo/pb";
message MyMessage {
repeated google.protobuf.Any list = 1;
}
message Foo {
int32 v = 1;
}
message Bar {
string v = 1;
}
main.go:
package main
import (
"encoding/json"
"fmt"
"google.golang.org/protobuf/types/known/anypb"
"github.com/ZekeLu/demo/pb"
)
func main() {
// If the db stores an instance of pb.Foo, then unmarshal it first.
buf := json.RawMessage([]byte(`{"v":10}`))
var foo pb.Foo
err := json.Unmarshal(buf, &foo)
if err != nil {
panic(err)
}
// And then marshal it into a new Any instance, which can be used to
// create a slice that can be assigned to pb.MyMessage.List.
a1, err := anypb.New(&foo)
if err != nil {
panic(err)
}
bar := &pb.Bar{V: "10"}
a2, err := anypb.New(bar)
if err != nil {
panic(err)
}
// Initialize the List field.
m := pb.MyMessage{List: []*anypb.Any{a1, a2}}
buf, err = json.Marshal(&m)
if err != nil {
panic(err)
}
fmt.Printf("%s\n", buf)
// Output: {"list":[{"type_url":"type.googleapis.com/pb.Foo","value":"CAo="},{"type_url":"type.googleapis.com/pb.Bar","value":"CgIxMA=="}]}
// If the db stores the output above, it can be unmarshal directly
var m2 pb.MyMessage
err = json.Unmarshal(buf, &m2)
if err != nil {
panic(err)
}
fmt.Printf("%v\n", m2.List)
// Output: [[type.googleapis.com/pb.Foo]:{v:10} [type.googleapis.com/pb.Bar]:{v:"10"}]
}
运行演示的步骤:
$ protoc --proto_path=pb --go_out=pb --go_opt=paths=source_relative demo.proto
$ go mod tidy
$ go run main.go