Golang如何使用gRPC实现服务通信_Golang gRPC服务调用实践

首先定义.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插件:

# 安装 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.gohello_grpc.pb.go,分别包含消息结构和服务桩代码。

实现gRPC服务端

编写服务端逻辑,实现定义的服务接口:

package main

import ( "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 main

import ( "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通信。这种方式清晰、高效,适合微服务架构中的服务间交互。