实现一元 gRPC 服务
使用 grpc-go 构建服务器与客户端
实现一元 gRPC 服务 是 CoddyKit 上的免费 Go Academy 课时。 这是第 2 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Go Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Go Academy 课程共包含 4 节课。
什么是单请求单响应 RPC?
单请求单响应 RPC 是最简单的 gRPC 模式:客户端发送一个请求并接收一个响应,类似于通过网络调用普通函数。
实现服务器
实现生成的接口。嵌入 Unimplemented*Server 结构体以确保向前兼容:
type userServer struct {
pb.UnimplementedUserServiceServer
db *sql.DB
}
func (s *userServer) GetUser(ctx context.Context, req *pb.GetUserRequest) (*pb.User, error) {
// query DB
return &pb.User{Id: req.Id, Name: "Alice"}, nil
}启动服务器
创建 gRPC 服务器,注册实现,并监听 TCP 端口:
lis, _ := net.Listen("tcp", ":50051")
grpcSrv := grpc.NewServer()
pb.RegisterUserServiceServer(grpcSrv, &userServer{})
log.Fatal(grpcSrv.Serve(lis))客户端连接
连接服务器并创建客户端桩:
conn, err := grpc.NewClient("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
if err != nil { log.Fatal(err) }
defer conn.Close()
client := pb.NewUserServiceClient(conn)发起单请求单响应调用
在客户端桩上调用 RPC 方法,就像调用本地函数一样:
ctx, cancel := context.WithTimeout(context.Background(), time.Second)
defer cancel()
user, err := client.GetUser(ctx, &pb.GetUserRequest{Id: 42})
if err != nil { log.Fatalf("error: %v", err) }
fmt.Println(user.Name)错误处理
gRPC 使用状态码。使用 status.Errorf 返回错误,并使用 status.Code(err) 检查错误:
import "google.golang.org/grpc/status"
import "google.golang.org/grpc/codes"
// Server:
return nil, status.Errorf(codes.NotFound, "user %d not found", req.Id)
// Client:
if status.Code(err) == codes.NotFound { /* handle */ }上下文传递
传递给客户端 RPC 调用的上下文会将截止时间和取消信号传递到服务器。服务器应将其传递给下游调用(数据库、其他 RPC)。
用于生产环境的 TLS
在生产环境中,将不安全凭据替换为 TLS:
creds, _ := credentials.NewServerTLSFromFile("cert.pem", "key.pem")
grpcSrv := grpc.NewServer(grpc.Creds(creds))UnimplementedServer
嵌入 pb.UnimplementedXxxServer 会为所有 RPC 方法提供桩实现,并返回 Unimplemented 状态。这样,在 proto 中添加新的 RPC 但尚未实现它们时,服务器仍能通过编译。
grpc.Dial 与 grpc.NewClient
在较新版本中,grpc.Dial 已弃用。请使用 grpc.NewClient,它不会主动建立连接,而是在首次 RPC 调用时延迟建立连接。
反射服务
注册 gRPC 反射服务,使 grpcurl 等工具无需 .proto 文件即可检查可用服务:
reflection.Register(grpcSrv)快速检查
在 gRPC 服务器结构体中嵌入 pb.UnimplementedXxxServer 的作用是什么?
回顾:单请求单响应 gRPC
要点:
- 实现生成的接口;嵌入 UnimplementedServer
- 使用 grpc.NewServer() + Register,并在 TCP 监听器上 Serve
- 客户端:使用 grpc.NewClient + 生成的 NewXxxClient
- 使用 status.Errorf/status.Code 处理 gRPC 错误
用 AI 导师学习 Go — 免费
在浏览器中编写并运行真实代码,获得全天候 AI 导师的即时帮助,并在网页或应用中继续学习。
- 课程
- 51
- 课程
- 203
常见问题解答
「实现一元 gRPC 服务」课时是免费的吗?
是的 — 「实现一元 gRPC 服务」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Go Academy 课程的其余内容,请升级到 CoddyKit PRO。 Go Academy 课程共包含 4 节课。
「实现一元 gRPC 服务」这节课中我会学到什么?
使用 grpc-go 构建服务器与客户端 你通过在浏览器中直接运行的动手代码来练习 Go Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Go Academy 需要有经验吗?
无需任何先前经验。CoddyKit 上的 Go Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 2 节课,共 4 节。
「实现一元 gRPC 服务」课时需要多长时间?
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。
我能在这节 Go Academy 课中编写并运行代码吗?
能。每节 Go Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。