在微服务和分布式系统的世界中,服务之间的高效通信至关重要。这就是 Google 开发的高性能 RPC(远程过程调用)框架 gRPC 发挥作用的地方。与 Go(一种专为简单和高效而设计的静态类型编译编程语言)相结合,gRPC 可以帮助您构建强大且可扩展的 Web 服务。
gRPC 代表 google Remote Procedure C全部。它是一个开源框架,使用 HTTP/2 进行传输,使用 Protocol Buffers 作为接口描述语言,并提供身份验证、负载平衡等功能。 gRPC 允许您在 .proto 文件中定义服务方法和消息类型,然后可以使用该文件生成多种语言的客户端和服务器代码。
### 先决条件
开始之前,请确保您已安装以下软件:
您可以使用以下命令安装Go插件:
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest
更新您的路径,以便协议编译器可以找到插件:
export PATH="$PATH:$(go env GOPATH)/bin"
通过打开终端并输入以下内容来确认 protoc 已在您的系统中安装和配置:
protoc --version
您应该看到与此类似的输出
C:\Users\Guest>protoc --version ~ libprotoc 27.3
如果它无法识别protoc命令,那么您可以使用Chocolatey for windows来安装protocol buffers:
choco install protoc
如果不是这种情况,即您没有安装 Chocolatey 或者您使用的是不同的操作系统,您可以在此处查看官方安装文档。
创建 .proto 文件来定义您的 gRPC 服务。例如:
helloworld.proto
syntax = "proto3"; package helloworld; message HelloRequest { string name = 1; } message HelloResponse { string message = 1; } service Greeter { rpc SayHello (HelloRequest) returns (HelloResponse) {} }
从 .proto 文件生成 Go 代码:
protoc --go_out=. --go-grpc_out=. helloworld.proto
在 Go 中创建服务器:
server.go
package main import ( "context" "log" "net" "google.golang.org/grpc" pb "path/to/your/proto" ) type server struct { pb.GreeterServer } func main() { lis, err := net.Listen("tcp", ":8080") if err != nil { log.Fatalf("failed to listen: %v", err) } log.Printf("Server started at %v", lis.Addr()) grpcServer := grpc.NewServer() pb.RegisterGreeterServer(grpcServer, &server{}) if err := grpcServer.Serve(lis); err != nil { log.Fatalf("failed to serve: %v", err) } } // SayHello name should be the same RPC name as defined in your proto file func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloResponse, error) { return &pb.HelloResponse{Message: "Hello " in.Name}, nil }
在 Go 中创建客户端:
client.go
package main import ( "context" "log" "os" "time" "google.golang.org/grpc" pb "path/to/your/proto" ) func main() { conn, err := grpc.NewClient("localhost:8080", grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { log.Fatalf("did not connect: %v", err) } defer conn.Close() client := pb.NewGreeterClient(conn) name := "John Doe" if len(os.Args) > 1 { name = os.Args[1] } callSayHello( client, name ) } func callSayHello(client pb.GrpcServiceClient, name string) { ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() res, err := client.SayHello(ctx, &pb.HelloRequest{Name: name}) if err != nil { log.Fatalf("Failed to called: %v", err) } log.Printf("%v", res) }
gRPC 和 Go 一起为构建高性能、可扩展的 Web 服务提供了强大的组合。通过利用两者的优势,您可以创建高效、可靠且易于维护和扩展的应用程序。
演示存储库链接:Github.com
免责声明: 提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发到邮箱:[email protected] 我们会第一时间内为您处理。
Copyright© 2022 湘ICP备2022001581号-3