Go
Protobuf in Go
Поиск…
Вступление
Protobuf или Protocol Buffer кодирует и декодирует данные, чтобы различные приложения или модули, написанные на разных языках, могли быстро и надежно обменивать большое количество сообщений без перегрузки канала связи. С protobuf производительность прямо пропорциональна количеству сообщений, которые вы отправляете. Он сжимает сообщение для отправки в сериализованном двоичном формате, предоставляя ваши инструменты для кодирования сообщения в источнике и декодирования его в пункте назначения.
замечания
Существует два этапа использования protobuf .
- Сначала вы должны скомпилировать определения буфера протокола
- Импортируйте приведенные выше определения с помощью библиотеки поддержки в вашу программу.
Поддержка gRPC
Если файл proto указывает службы RPC, protoc-gen-go может быть проинструктирован о создании кода, совместимого с gRPC ( http://www.grpc.io/) . Для этого передайте параметр plugins в protoc-gen-go; обычный способ заключается в том, чтобы вставить его в аргумент -go_out для protoc:
protoc --go_out=plugins=grpc:. *.proto
Использование 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