以下是一个简单的 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 mainimport ("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 服务了。