1.安装

go get google.golang.org/grpc
go get github.com/golang/protobuf

gogoprotobuf
go get github.com/gogo/protobuf/protoc-gen-gofast
go get github.com/gogo/protobuf/proto
go get github.com/gogo/protobuf/protoc-gen-gogo
go get github.com/gogo/protobuf/gogoproto

  • 下载protobuf
  • ./configure —prefix=/usr/local/protobuf
  • make
  • make install
  • 配置环境变量
    • GOGO_ROOT=${GOPATH}/src/github.com/gogo/protobuf
    • PROTOBUF=/usr/local/protobuf
    • PATH=$PROTOBUF/bin:$PATH

2.写proto

  1. syntax = "proto3";
  3. package containers;
  5. import "github.com/gogo/protobuf/gogoproto/gogo.proto";
  6. import "google/protobuf/any.proto";
  7. import "google/protobuf/empty.proto";
  8. import "google/protobuf/timestamp.proto";
  10. option go_package = "containers";
  12. // Containers provides metadata storage for containers used in the execution
  13. // service.
  14. service Containers {
  15.     rpc Get(GetContainerRequest) returns (GetContainerResponse);
  16.     rpc List(ListContainersRequest) returns (ListContainersResponse);
  17.     rpc Create(CreateContainerRequest) returns (CreateContainerResponse);
  18.     rpc Delete(DeleteContainerRequest) returns (google.protobuf.Empty);
  19. }
  21. message Container {
  22.     string id = 1;
  23.     map<string, string> labels  = 2;
  24.     string image = 3;
  25.     google.protobuf.Any spec = 4;
  26.     google.protobuf.Timestamp created_at = 5 [(gogoproto.stdtime) = true, (gogoproto.nullable) = false];
  27. }
  29. message GetContainerRequest {
  30.     string id = 1;
  31. }
  33. message GetContainerResponse {
  34.     Container container = 1 [(gogoproto.nullable) = false];
  35. }
  37. message ListContainersRequest {
  38. }
  40. message ListContainersResponse {
  41.     repeated Container containers = 1 [(gogoproto.nullable) = false];
  42. }
  44. message CreateContainerRequest {
  45.     Container container = 1 [(gogoproto.nullable) = false];
  46. }
  48. message CreateContainerResponse {
  49.     Container container = 1 [(gogoproto.nullable) = false];
  50. }
  52. message DeleteContainerRequest {
  53.     string id = 1;
  54. }
  56. message ListContainerMessage {
  57.     Container container = 1;
  58. }

3.codegen

protoc -I.:${GOPATH}/src --gofast_out=plugins=grpc:. api/services/containers/containers.proto

  1. type Container struct {
  2.     Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
  3.     Labels               map[string]string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
  4.     Image                string            `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
  5.     Spec                 *any.Any          `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
  6.     CreatedAt            time.Time         `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3,stdtime" json:"created_at"`
  7.     XXX_NoUnkeyedLiteral struct{}          `json:"-"`
  8.     XXX_unrecognized     []byte            `json:"-"`
  9.     XXX_sizecache        int32             `json:"-"`
  10. }
  1. func init() {
  2.     proto.RegisterType((*Container)(nil), "containers.Container")
  3.     proto.RegisterMapType((map[string]string)(nil), "containers.Container.LabelsEntry")
  4.     proto.RegisterType((*GetContainerRequest)(nil), "containers.GetContainerRequest")
  5.     proto.RegisterType((*GetContainerResponse)(nil), "containers.GetContainerResponse")
  6.     proto.RegisterType((*ListContainersRequest)(nil), "containers.ListContainersRequest")
  7.     proto.RegisterType((*ListContainersResponse)(nil), "containers.ListContainersResponse")
  8.     proto.RegisterType((*CreateContainerRequest)(nil), "containers.CreateContainerRequest")
  9.     proto.RegisterType((*CreateContainerResponse)(nil), "containers.CreateContainerResponse")
  10.     proto.RegisterType((*DeleteContainerRequest)(nil), "containers.DeleteContainerRequest")
  11.     proto.RegisterType((*ListContainerMessage)(nil), "containers.ListContainerMessage")
  12. }
  1. func init() {
  2.     proto.RegisterFile("api/services/containers/containers.proto", fileDescriptor_776da4f07b3f96b9)
  3. }

client

  1. // ContainersClient is the client API for Containers service.
  2. //
  3. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  4. type ContainersClient interface {
  5.     Get(ctx context.Context, in *GetContainerRequest, opts ...grpc.CallOption) (*GetContainerResponse, error)
  6.     List(ctx context.Context, in *ListContainersRequest, opts ...grpc.CallOption) (*ListContainersResponse, error)
  7.     Create(ctx context.Context, in *CreateContainerRequest, opts ...grpc.CallOption) (*CreateContainerResponse, error)
  8.     Delete(ctx context.Context, in *DeleteContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
  9. }
  11. type containersClient struct {
  12.     cc *grpc.ClientConn
  13. }
  15. func NewContainersClient(cc *grpc.ClientConn) ContainersClient {
  16.     return &containersClient{cc}
  17. }
  20. func (c *containersClient) Get(ctx context.Context, in *GetContainerRequest, opts ...grpc.CallOption) (*GetContainerResponse, error) {
  21.     out := new(GetContainerResponse)
  22.     err := c.cc.Invoke(ctx, "/containers.Containers/Get", in, out, opts...)
  23.     if err != nil {
  24.         return nil, err
  25.     }
  26.     return out, nil
  27. }
  29. func (c *containersClient) List(ctx context.Context, in *ListContainersRequest, opts ...grpc.CallOption) (*ListContainersResponse, error) {
  30.     out := new(ListContainersResponse)
  31.     err := c.cc.Invoke(ctx, "/containers.Containers/List", in, out, opts...)
  32.     if err != nil {
  33.         return nil, err
  34.     }
  35.     return out, nil
  36. }
  38. func (c *containersClient) Create(ctx context.Context, in *CreateContainerRequest, opts ...grpc.CallOption) (*CreateContainerResponse, error) {
  39.     out := new(CreateContainerResponse)
  40.     err := c.cc.Invoke(ctx, "/containers.Containers/Create", in, out, opts...)
  41.     if err != nil {
  42.         return nil, err
  43.     }
  44.     return out, nil
  45. }
  47. func (c *containersClient) Delete(ctx context.Context, in *DeleteContainerRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
  48.     out := new(empty.Empty)
  49.     err := c.cc.Invoke(ctx, "/containers.Containers/Delete", in, out, opts...)
  50.     if err != nil {
  51.         return nil, err
  52.     }
  53.     return out, nil
  54. }

server

  1. // ContainersServer is the server API for Containers service.
  2. type ContainersServer interface {
  3.     Get(context.Context, *GetContainerRequest) (*GetContainerResponse, error)
  4.     List(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
  5.     Create(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
  6.     Delete(context.Context, *DeleteContainerRequest) (*empty.Empty, error)
  7. }
  9. func RegisterContainersServer(s *grpc.Server, srv ContainersServer) {
  10.     s.RegisterService(&_Containers_serviceDesc, srv)
  11. }
  13. var _Containers_serviceDesc = grpc.ServiceDesc{
  14.     ServiceName: "containers.Containers",
  15.     HandlerType: (*ContainersServer)(nil),
  16.     Methods: []grpc.MethodDesc{
  17.         {
  18.             MethodName: "Get",
  19.             Handler:    _Containers_Get_Handler,
  20.         },
  21.         {
  22.             MethodName: "List",
  23.             Handler:    _Containers_List_Handler,
  24.         },
  25.         {
  26.             MethodName: "Create",
  27.             Handler:    _Containers_Create_Handler,
  28.         },
  29.         {
  30.             MethodName: "Delete",
  31.             Handler:    _Containers_Delete_Handler,
  32.         },
  33.     },
  34.     Streams:  []grpc.StreamDesc{},
  35.     Metadata: "api/services/containers/containers.proto",
  36. }