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

在Go语言中使用gRPC实现服务通信,是一种高效、跨语言的远程过程调用方式。它基于HTTP/2协议,采用Protocol Buffers作为接口定义语言(IDL),具有高性能和强类型的优势。下面通过一个实际例子,介绍如何使用Golang结合gRPC完成服务端与客户端的通信。
第一步是定义服务接口和消息结构。创建一个hello.proto文件:
syntax = "proto3";
<p>package greet;
option go_package = "./greetpb";</p><p>service Greeter {
rpc SayHello (HelloRequest) returns (HelloResponse);
}</p><p>message HelloRequest {
string name = 1;
}</p><p>message HelloResponse {
string message = 1;
}
这个文件定义了一个Greeter服务,包含一个SayHello方法,接收HelloRequest并返回HelloResponse。
安装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,分别包含消息结构和服务桩代码。
编写服务端逻辑,实现定义的服务接口:
package main <p>import ( "context" "log" "net"</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">"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服务器。
客户端连接服务端并调用远程方法:
package main <p>import ( "context" "log" "time"</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">"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通信。这种方式清晰、高效,适合微服务架构中的服务间交互。
以上就是Golang如何使用gRPC实现服务通信_Golang gRPC服务调用实践的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号