gRPC 和 Go：构建高性能 Web 服务-Golang-PHP中文网

gRPC 和 Go：构建高性能 Web 服务

Barbara Streisand

发布： 2024-09-30 20:07:03

原创

275 人浏览过

gRPC and Go: Building High-Performance Web Services

介绍

在微服务和分布式系统的世界中，服务之间的高效通信至关重要。这就是 Google 开发的高性能 RPC（远程过程调用）框架 gRPC 发挥作用的地方。与 Go（一种专为简单和高效而设计的静态类型编译编程语言）相结合，gRPC 可以帮助您构建健壮且可扩展的 Web 服务。

什么是 gRPC？

gRPC 代表 google Remote Procedure Call。它是一个开源框架，使用 HTTP/2 进行传输，使用 Protocol Buffers 作为接口描述语言，并提供身份验证、负载平衡等功能。 gRPC 允许您在 .proto 文件中定义服务方法和消息类型，然后可以使用该文件生成多种语言的客户端和服务器代码。

为什么将 gRPC 与 Go 结合使用？

性能：gRPC 使用 HTTP/2，它允许通过单个连接复用多个请求，从而减少延迟并提高性能。
代码生成：使用 Protocol Buffers，您可以定义一次服务并在 Go 中生成客户端和服务器代码，确保一致性并减少样板代码。
流式传输：gRPC 支持客户端、服务器端和双向流式传输，非常适合实时应用程序。
互操作性：gRPC 服务可以由用不同语言编写的客户端使用，使其成为多语言环境的通用选择。

Go 中的 gRPC 入门

### 先决条件

开始之前，请确保您已安装以下软件：

Go（两个最新主要版本中的任何一个）
协议缓冲区编译器 (protoc)
Protocol Buffer 编译器的 Go 插件

您可以使用以下命令安装 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)
}

登录后复制