首先定义.proto文件声明RPC服务和消息结构，然后通过protoc生成Go代码，接着实现服务端逻辑并启动gRPC服务器，最后编写客户端代码调用远程方法。整个流程依赖Protobuf定义接口，结合gRPC框架自动处理通信与序列化，开发者只需关注业务逻辑实现。
在Golang中使用Protobuf定义RPC接口，核心是通过Protocol Buffers（简称Protobuf）定义服务方法，再结合gRPC框架实现远程调用。整个流程包括定义.proto文件、生成Go代码、实现服务端和客户端逻辑。
定义.proto文件描述RPC服务
首先创建一个.proto文件，在其中定义你想要暴露的RPC方法和消息结构。使用syntax = "proto3";声明语法版本，并通过service关键字定义服务。
例如，创建user.proto：
syntax = "proto3";
package example;
// 定义请求和响应消息
message GetUserRequest {
string user_id = 1;
}
message UserResponse {
string name = 1;
int32 age = 2;
}
// 定义RPC服务
service UserService {
rpc GetUser(GetUserRequest) returns (UserResponse);
}
这个文件定义了一个名为UserService的服务，包含一个GetUser方法，接收GetUserRequest并返回UserResponse。
立即学习“go语言免费学习笔记（深入）”；
生成Go代码
需要安装Protobuf编译器protoc以及Go插件：
- 安装protoc：从GitHub release页面下载对应平台的二进制文件
- 安装Go插件：
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest
执行命令生成Go代码：
protoc --go_out=. --go-grpc_out=. user.proto
会生成两个文件：user.pb.go和user_grpc.pb.go，分别包含消息结构体和服务接口定义。
实现服务端逻辑
在Go中实现服务接口，注册到gRPC服务器：
package main
import (
"context"
"log"
"net"
"google.golang.org/grpc"
pb "your-module-path/proto" // 替换为你的模块路径
)
type userService struct {
pb.UnimplementedUserServiceServer
}
func (s *userService) GetUser(ctx context.Context, req *pb.GetUserRequest) (*pb.UserResponse, error) {
return &pb.UserResponse{
Name: "Alice",
Age: 30,
}, nil
}
func main() {
lis, err := net.Listen("tcp", ":50051")
if err != nil {
log.Fatalf("failed to listen: %v", err)
}
grpcServer := grpc.NewServer()
pb.RegisterUserServiceServer(grpcServer, &userService{})
log.Println("gRPC server running on :50051")
if err := grpcServer.Serve(lis); err != nil {
log.Fatalf("failed to serve: %v", err)
}
}
这里实现了GetUser方法，并启动gRPC服务器监听指定端口。
编写客户端调用代码
客户端连接服务器并调用RPC方法：
package main
import (
"context"
"log"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
pb "your-module-path/proto"
)
func main() {
conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
if err != nil {
log.Fatalf("did not connect: %v", err)
}
defer conn.Close()
client := pb.NewUserServiceClient(conn)
resp, err := client.GetUser(context.Background(), &pb.GetUserRequest{UserId: "123"})
if err != nil {
log.Fatalf("could not get user: %v", err)
}
log.Printf("User: %s, Age: %d", resp.Name, resp.Age)
}
客户端通过Dial建立连接，使用生成的客户端接口发起调用。
基本上就这些。只要定义好.proto文件，工具链会帮你处理序列化和通信细节，专注业务逻辑即可。注意保持.proto文件与生成代码同步，避免调用失败。
