首先定义.proto接口文件并生成Go代码,然后实现服务端和客户端逻辑。服务端通过gRPC监听端口注册服务,客户端建立连接后调用远程方法,完成高效通信。

在Go语言中使用gRPC实现服务通信,是一种高效、跨语言的远程过程调用方式。它基于HTTP/2协议,采用Protocol Buffers作为接口定义语言(IDL),具有高性能和强类型的优势。下面通过一个实际例子,介绍如何使用Golang结合gRPC完成服务端与客户端的通信。
定义服务接口(.proto文件)
第一步是定义服务接口和消息结构。创建一个hello.proto文件:
syntax = "proto3";package greet; option go_package = "./greetpb";
service Greeter { rpc SayHello (HelloRequest) returns (HelloResponse); }
message HelloRequest { string name = 1; }
message HelloResponse { string message = 1; }
这个文件定义了一个Greeter服务,包含一个SayHello方法,接收HelloRequest并返回HelloResponse。
生成Go代码
安装protobuf编译器和Go插件:
立即学习“go语言免费学习笔记(深入)”;
# 安装 protoc 编译器(需系统级安装) # 然后安装 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_opt=paths=source_relative \
--go-grpc_out=. --go-grpc_opt=paths=source_relative \
hello.proto
会生成两个文件:hello.pb.go 和 hello_grpc.pb.go,分别包含消息结构和服务桩代码。
实现gRPC服务端
编写服务端逻辑,实现定义的服务接口:
package mainimport ( "context" "log" "net"
"google.golang.org/grpc" pb "your-module/greetpb")
type server struct { pb.UnimplementedGreeterServer }
func (s server) SayHello(ctx context.Context, req pb.HelloRequest) (*pb.HelloResponse, error) { return &pb.HelloResponse{ Message: "Hello, " + req.GetName(), }, nil }
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 running on :50051") if err := s.Serve(lis); err != nil { log.Fatalf("failed to serve: %v", err) }}
服务端监听:50051端口,注册GreeterServer实现,并启动gRPC服务器。
编写gRPC客户端
客户端连接服务端并调用远程方法:
package mainimport ( "context" "log" "time"
"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) ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() resp, err := client.SayHello(ctx, &pb.HelloRequest{Name: "Alice"}) if err != nil { log.Fatalf("could not greet: %v", err) } log.Printf("Response: %s", resp.GetMessage())}
客户端通过grpc.Dial建立连接,创建Stub对象后即可像调用本地方法一样发起远程调用。
基本上就这些。只要定义好proto接口,生成代码,再分别实现服务端逻辑和客户端调用,就能完成一次完整的gRPC通信。这种方式清晰、高效,适合微服务架构中的服务间交互。










