使用 Protobuf 和 Go
你要序列化并发送的消息可以包含在包含的 test.proto 文件中
package example;
enum FOO { X = 17; };
message Test {
required string label = 1;
optional int32 type = 2 [default=77];
repeated int64 reps = 3;
optional group OptionalGroup = 4 {
required string RequiredField = 5;
}
}
要编译协议缓冲区定义,请运行 protoc 并将 –go_out 参数设置为要将 Go 代码输出到的目录。
protoc --go_out=. *.proto
要从示例包中创建和使用 Test 对象,
package main
import (
"log"
"github.com/golang/protobuf/proto"
"path/to/example"
)
func main() {
test := &example.Test {
Label: proto.String("hello"),
Type: proto.Int32(17),
Reps: []int64{1, 2, 3},
Optionalgroup: &example.Test_OptionalGroup {
RequiredField: proto.String("good bye"),
},
}
data, err := proto.Marshal(test)
if err != nil {
log.Fatal("marshaling error: ", err)
}
newTest := &example.Test{}
err = proto.Unmarshal(data, newTest)
if err != nil {
log.Fatal("unmarshaling error: ", err)
}
// Now test and newTest contain the same data.
if test.GetLabel() != newTest.GetLabel() {
log.Fatalf("data mismatch %q != %q", test.GetLabel(), newTest.GetLabel())
}
// etc.
}
要将额外的参数传递给插件,请使用以冒号分隔的输出目录中以逗号分隔的参数列表:
protoc --go_out=plugins=grpc,import_path=mypackage:. *.proto