Golang如何使用gRPC进行远程调用

Go语言通过gRPC实现高效远程调用依赖Protocol Buffers和HTTP/2，流程包括定义.proto接口、生成代码、实现服务端与客户端；2. 编写hello.proto定义服务和消息结构；3. 使用protoc生成hello.pb.go和hello_grpc.pb.go代码；4. 服务端注册Greeter服务并启动监听；5. 客户端连接服务端并调用SayHello方法获取响应。

Go语言通过gRPC实现高效远程调用，主要依赖Protocol Buffers和HTTP/2。整个流程包括定义接口、生成代码、实现服务端与客户端。下面详细介绍如何在Golang中使用gRPC进行远程调用。

定义服务接口（.proto文件）

gRPC使用Protocol Buffers定义服务方法和消息结构。你需要编写一个.proto文件来描述服务。

例如，创建hello.proto：

<font face="Courier New">
syntax = "proto3";
package greet;
option go_package = "./greetpb";
message HelloRequest {
string name = 1;
}
message HelloResponse {
string message = 1;
}
service Greeter {
rpc SayHello (HelloRequest) returns (HelloResponse);
}
</font>

这个文件定义了一个Greeter服务，包含一个SayHello方法。

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

生成Go代码

使用protoc编译器和Go插件生成服务代码。

安装工具：

<font face="Courier New">
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest
</font>

生成代码：

<font face="Courier New">
protoc --go_out=. --go_opt=paths=source_relative \
--go-grpc_out=. --go-grpc_opt=paths=source_relative \
hello.proto
</font>

执行后会生成hello.pb.go和hello_grpc.pb.go两个文件，包含结构体和服务桩代码。

实现gRPC服务端

编写服务端程序，注册并启动gRPC服务器。

<font face="Courier New">
package main
import (
"log"
"net"
"google.golang.org/grpc"
pb "your-module/greetpb"
)
type server struct {
pb.UnimplementedGreeterServer
}
func (s *server) SayHello(req *pb.HelloRequest, stream pb.Greeter_SayHelloServer) error {
resp := &pb.HelloResponse{
Message: "Hello, " + req.Name,
}
return stream.Send(resp)
}
func main() {
lis, err := net.Listen("tcp", ":50051")
if err != nil {
log.Fatalf("failed to listen: %v", err)
}
s := grpc.NewServer()
pb.RegisterGreeterServer(s, &server{})
log.Println("gRPC server listening on :50051")
if err := s.Serve(lis); err != nil {
log.Fatalf("failed to serve: %v", err)
}
}
</font>

实现gRPC客户端

客户端连接服务端并发起远程调用。

<font face="Courier New">
package main
import (
"context"
"log"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
pb "your-module/greetpb"
)
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.NewGreeterClient(conn)
req := &pb.HelloRequest{Name: "Alice"}
resp, err := client.SayHello(context.Background(), req)
if err != nil {
log.Fatalf("could not greet: %v", err)
}
log.Printf("Response: %s", resp.Message)
}
</font>

基本上就这些。只要定义好proto接口，生成代码，再分别实现服务端处理逻辑和客户端调用，就能完成一次gRPC远程调用。注意确保服务端运行后再启动客户端测试。不复杂但容易忽略细节，比如包路径和protoc参数。