当前位置：首页 > news >正文

go grpc使用场景和使用示例

news 2025/8/29 6:43:41

Go gRPC 使用场景

微服务架构中的服务间通信：在微服务架构中，不同的服务之间需要高效、可靠地进行通信和数据交换，gRPC 可以很好地满足这一需求。
需要高并发、低延迟通信的场景：gRPC 基于 HTTP/2 协议，支持多路复用和头部压缩，能够减少网络延迟，提高通信效率，适用于对性能要求较高的场景。
跨语言、跨平台的系统整合：gRPC 使用 Protocol Buffers 作为接口定义语言，可以为多种编程语言生成对应的客户端和服务端代码，方便不同语言和平台之间的系统进行集成。
实时数据交互场景：如实时聊天系统、股票行情推送、物联网设备数据采集等，gRPC 的双向流式 RPC 模式能够实现客户端和服务端的实时双向通信。
大数据传输场景：对于需要传输大量数据的情况，如日志收集、文件传输等，gRPC 的服务端流式 RPC 和客户端流式 RPC 模式可以分批次传输数据，提高传输效率。

Go gRPC 使用示例

以下是一个简单的 Go gRPC 示例，包括服务端和客户端的代码：

1. 定义 `.proto` 文件

syntax = "proto3";package hello;service Greeter {rpc SayHello (HelloRequest) returns (HelloReply) {}
}message HelloRequest {string name = 1;
}message HelloReply {string message = 1;
}

2. 服务端代码

package mainimport ("context""log""net"pb "github.com/your-repo/your-project/hello""google.golang.org/grpc"
)type server struct {pb.UnimplementedGreeterServer
}func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {log.Printf("Received: %v", in.GetName())return &pb.HelloReply{Message: "Hello " + in.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.Printf("server listening at %v", lis.Addr())if err := s.Serve(lis); err != nil {log.Fatalf("failed to serve: %v", err)}
}

3. 客户端代码

package mainimport ("context""log""time"pb "github.com/your-repo/your-project/hello""google.golang.org/grpc"
)func main() {conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure(), grpc.WithBlock())if err != nil {log.Fatalf("did not connect: %v", err)}defer conn.Close()c := pb.NewGreeterClient(conn)ctx, cancel := context.WithTimeout(context.Background(), time.Second)defer cancel()r, err := c.SayHello(ctx, &pb.HelloRequest{Name: "World"})if err != nil {log.Fatalf("could not greet: %v", err)}log.Printf("Greeting: %s", r.GetMessage())
}

示例说明

服务端：
- 定义了一个 Greeter 服务，其中包含一个 SayHello 方法。
- 实现了 SayHello 方法的逻辑，接收客户端发送的请求，并返回一条问候消息。
- 使用 grpc.NewServer() 创建 gRPC 服务器，并通过 pb.RegisterGreeterServer() 注册服务。
- 服务器监听指定端口，等待客户端的连接和请求。
客户端：
- 使用 grpc.Dial() 连接到服务端。
- 创建 GreeterClient 实例，调用服务端的 SayHello 方法，并传入请求参数。
- 接收服务端返回的响应，并打印出来。