以下是一个简单的 Go gRPC 例子,其中包括服务端和客户端:
首先,我们需要安装 grpc
和 protobuf
的 Go 插件:
go get -u google.golang.org/grpc go get -u github.com/golang/protobuf/protoc-gen-go
然后,我们需要定义一个 .proto
文件来定义我们的服务和消息。这里是一个示例 .proto
文件:
protobuf syntax = "proto3"; package example; service Greeter { rpc SayHello (HelloRequest) returns (HelloResponse); } message HelloRequest { string name = 1; } message HelloResponse { string message = 1; }
接下来,我们使用 protoc
工具来生成 Go 代码:
protoc --go_out=plugins=grpc:. *.proto
这将在当前目录下生成 example.pb.go
文件,其中包含我们定义的服务和消息的 Go 代码。
接下来,我们可以编写服务端代码:
package main import ( "context" "google.golang.org/grpc" "log" "net" pb "path/to/your/proto/package" ) type server struct{} func (s *server) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error) { return &pb.HelloResponse{ Message: "Hello, " + req.Name + "!", }, 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("Starting server on port 50051...") if err := s.Serve(lis); err != nil { log.Fatalf("failed to serve: %v", err) } }
在这个例子中,我们定义了一个名为 server
的结构体,并实现了 SayHello
方法来响应客户端的请求。我们还在 main
函数中创建了一个 grpc.Server
实例,并将我们的服务注册到该实例上。最后,我们使用 Serve
方法来启动服务端并监听端口 50051
。
现在,我们可以编写客户端代码:
package main import ( "context" "log" "google.golang.org/grpc" pb "path/to/your/proto/package" ) func main() { conn, err := grpc.Dial(":50051", grpc.WithInsecure()) if err != nil { log.Fatalf("failed to connect: %v", err) } defer conn.Close() c := pb.NewGreeterClient(conn) resp, err := c.SayHello(context.Background(), &pb.HelloRequest{Name: "World"}) if err != nil { log.Fatalf("failed to call SayHello: %v", err) } log.Printf("Response: %s", resp.Message) }
在这个例子中,我们首先使用 grpc.Dial
方法来连接到服务端,然后创建一个 GreeterClient
实例来调用服务端的 SayHello
方法。最后,我们输出响应的消息。
现在,我们可以运行服务端和客户端来测试我们的 gRPC 服务了。