Golang开发gRPC服务 proto文件定义与生成

P粉602998670

发布时间：2025-08-21 11:41:01

1078人浏览过

来源于php中文网

原创

答案：编写有效的proto文件需使用proto3语法，定义package、service和message，通过stream关键字实现流式传输，支持枚举与嵌套消息。

golang开发grpc服务 proto文件定义与生成

proto文件定义与生成是Golang开发gRPC服务的基础。它定义了服务接口和数据结构，并通过工具生成对应的Go代码，简化了开发流程。

定义proto文件并生成相应的Go代码。

如何编写一个有效的proto文件？

编写有效的proto文件需要理解protobuf的语法和最佳实践。首先，你需要明确定义你的服务接口，包括方法名、请求参数和返回类型。每个参数和返回类型都需要指定数据类型，例如

string

、

int32

或自定义的message类型。

一个简单的例子：

立即学习“go语言免费学习笔记（深入）”；

syntax = "proto3";

package example;

service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply);
}

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}

在这个例子中，我们定义了一个

Greeter

服务，它有一个

SayHello

方法，接收

HelloRequest

类型的参数，返回

HelloReply

类型的结果。

HelloRequest

包含一个

name

字段，

HelloReply

包含一个

message

字段。

= 1

表示字段的编号，用于protobuf的序列化和反序列化。

编写proto文件时，需要注意以下几点：

使用proto3语法:
```
syntax = "proto3";
```
声明使用proto3语法，这是目前推荐的版本，它简化了语法并提供了更好的性能。
定义package:
```
package example;
```
定义了包名，这有助于组织你的proto文件，并避免命名冲突。
定义service:
```
service Greeter { ... }
```
定义了服务接口，每个rpc方法定义了输入和输出类型。
定义message:
```
message HelloRequest { ... }
```
定义了数据结构，每个字段都有一个类型和一个唯一的编号。

接下来，你需要使用

protoc

编译器生成Go代码。首先，确保你已经安装了

protoc

编译器和

protoc-gen-go

插件：

go install google.golang.org/protobuf/cmd/protoc-gen-go@v1.28
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.2

然后，使用以下命令生成Go代码：

protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative example.proto

这个命令会生成

example.pb.go

和

example_grpc.pb.go

两个文件，包含了定义的服务接口和数据结构的Go代码。

paths=source_relative

选项指定生成的代码使用相对于proto文件的路径。

gRPC的流式传输如何通过proto定义实现？

gRPC支持四种类型的服务方法：简单RPC、服务器端流式RPC、客户端流式RPC和双向流式RPC。流式传输允许客户端或服务器发送一系列消息，而不是单个请求和响应。

在proto文件中，可以通过在RPC方法定义中使用

stream

关键字来指定流式传输。

服务器端流式RPC: 客户端发送一个请求，服务器返回一个消息流。
```
service RouteGuide {
  rpc GetServerStream (Point) returns (stream RouteNote) {}
}
```
客户端流式RPC: 客户端发送一个消息流，服务器返回一个响应。

ECTouch移动商城系统
ECTouch是上海商创网络科技有限公司推出的一套基于 PHP 和 MySQL 数据库构建的开源且易于使用的移动商城网店系统！应用于各种服务器平台的高效、快速和易于管理的网店解决方案，采用稳定的MVC框架开发，完美对接ecshop系统与模板堂众多模板，为中小企业提供最佳的移动电商解决方案。ECTouch程序源代码完全无加密。安装时只需将已集成的文件夹放进指定位置，通过浏览器访问一键安装，无需对已有

下载
```
service RouteGuide {
  rpc PutClientStream (stream RouteNote) returns (RouteSummary) {}
}
```

双向流式RPC: 客户端和服务器都可以发送消息流。

service RouteGuide {
  rpc GetBiDirectionalStream (stream RouteNote) returns (stream RouteNote) {}
}

在Go代码中，你需要实现这些流式方法。例如，对于服务器端流式RPC，你需要返回一个

stream RouteNote

，这意味着你需要实现一个循环，不断地向客户端发送消息。

func (s *server) GetServerStream(req *pb.Point, stream pb.RouteGuide_GetServerStreamServer) error {
    for i := 0; i < 10; i++ {
        note := &pb.RouteNote{
            Location: req,
            Message:  fmt.Sprintf("Message %d", i),
        }
        if err := stream.Send(note); err != nil {
            return err
        }
        time.Sleep(time.Second)
    }
    return nil
}

这个例子中，服务器接收一个

Point

类型的请求，然后循环10次，每次创建一个

RouteNote

类型的消息，并通过

stream.Send()

方法发送给客户端。

如何处理proto文件中的枚举类型和嵌套消息？

枚举类型和嵌套消息是protobuf中常用的数据结构，用于定义复杂的数据类型。

枚举类型: 用于定义一组相关的常量。

enum PhoneType {
  MOBILE = 0;
  HOME = 1;
  WORK = 2;
}

message PhoneNumber {
  string number = 1;
  PhoneType type = 2;
}

在这个例子中，

PhoneType

枚举定义了三种电话类型：

MOBILE

、

HOME

和

WORK

。

PhoneNumber

消息包含一个

number

字段和一个

type

字段，

type

字段的类型是

PhoneType

。

嵌套消息: 允许在一个消息中定义另一个消息。
```
message Person {
  string name = 1;
  int32 id = 2;
  string email = 3;
  repeated PhoneNumber phones = 4;
}
```
在这个例子中，
```
Person
```
消息包含一个
```
name
```
字段、一个
```
id
```
字段、一个
```
email
```
字段和一个
```
phones
```
字段。
```
phones
```
字段是一个
```
PhoneNumber
```
类型的数组，使用了
```
repeated
```
关键字，表示可以包含多个
```
PhoneNumber
```
。

在Go代码中，你可以直接使用生成的枚举类型和嵌套消息。

person := &pb.Person{
    Name:  "John Doe",
    Id:    123,
    Email: "john.doe@example.com",
    Phones: []*pb.PhoneNumber{
        {
            Number: "123-456-7890",
            Type:   pb.PhoneType_MOBILE,
        },
    },
}

这个例子中，我们创建了一个