add: unary rpc

This commit is contained in:
viletyy 2021-06-15 22:21:26 +08:00
parent ef0675cdc5
commit bb0f787db8
2 changed files with 73 additions and 0 deletions

37
client/client.go Normal file
View File

@ -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
}

36
server/server.go Normal file
View File

@ -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)
}