From bb0f787db822923d3ebf8eedb1c6ae6afbaeffd4 Mon Sep 17 00:00:00 2001 From: viletyy Date: Tue, 15 Jun 2021 22:21:26 +0800 Subject: [PATCH] add: unary rpc --- client/client.go | 37 +++++++++++++++++++++++++++++++++++++ server/server.go | 36 ++++++++++++++++++++++++++++++++++++ 2 files changed, 73 insertions(+) create mode 100644 client/client.go create mode 100644 server/server.go diff --git a/client/client.go b/client/client.go new file mode 100644 index 0000000..e919c1f --- /dev/null +++ b/client/client.go @@ -0,0 +1,37 @@ +/* + * @Date: 2021-06-15 22:08:18 + * @LastEditors: viletyy + * @LastEditTime: 2021-06-15 22:17:08 + * @FilePath: /grpc-demo/client/client.go + */ +package main + +import ( + "context" + "flag" + "log" + + pb "github.com/go-inpro/grpc-demo/proto" + "google.golang.org/grpc" +) + +var port string + +func init() { + flag.StringVar(&port, "port", "8001", "启动端口号") + flag.Parse() +} + +func main() { + conn, _ := grpc.Dial(":"+port, grpc.WithInsecure()) + defer conn.Close() + + client := pb.NewGreeterClient(conn) + _ = SayHello(client) +} + +func SayHello(client pb.GreeterClient) error { + resp, _ := client.SayHello(context.Background(), &pb.HelloRequest{Name: "viletyy"}) + log.Printf("client.SayHello resp: %s", resp.Message) + return nil +} diff --git a/server/server.go b/server/server.go new file mode 100644 index 0000000..e2c0012 --- /dev/null +++ b/server/server.go @@ -0,0 +1,36 @@ +/* + * @Date: 2021-06-15 22:01:41 + * @LastEditors: viletyy + * @LastEditTime: 2021-06-15 22:07:56 + * @FilePath: /grpc-demo/server/server.go + */ +package main + +import ( + "context" + "flag" + "net" + + pb "github.com/go-inpro/grpc-demo/proto" + "google.golang.org/grpc" +) + +var port string + +func init() { + flag.StringVar(&port, "port", "8001", "启动端口号") + flag.Parse() +} + +type GreeterServer struct{} + +func (s *GreeterServer) SayHello(ctx context.Context, r *pb.HelloRequest) (*pb.HelloReply, error) { + return &pb.HelloReply{Message: "hello.world"}, nil +} + +func main() { + server := grpc.NewServer() + pb.RegisterGreeterServer(server, &GreeterServer{}) + lis, _ := net.Listen("tcp", ":"+port) + server.Serve(lis) +}