grpc入门Unary模式使用方法示例教程

syntax = "proto3";
package proto;
option go_package = "git.gqnotes.com/guoqiang/grpcexercises/greet/pb";
service GreetService {
  rpc Greet(GreetRequest) returns(GreetResponse) {}
}
message GreetRequest {
  string greeting = 1;
}
message GreetResponse {
  string result = 1;
}

tidy:
    go mod tidy
greet-gen:
     protoc -Igreet/proto/ --go_out=./greet --go_opt=module=git.gqnotes.com/guoqiang/grpcexercises/greet --go-grpc_out=./greet --go-grpc_opt=module=git.gqnotes.com/guoqiang/grpcexercises/greet greet/proto/*.proto
greet-build:
     go build -o ./greet/bin/server-osx ./greet/server
     go build -o ./greet/bin/client-osx ./greet/client
.PHONY: tidy greet-gen greet-build

make greet-gen

package main
import (
    "git.gqnotes.com/guoqiang/grpcexercises/greet/pb"
    "google.golang.org/grpc"
    "google.golang.org/grpc/reflection"
    "log"
    "net"
)
func main() {
    // 实现服务端逻辑，监听5632端口
    lis, err := net.Listen("tcp", ":5632")
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
        return
    }
    s := grpc.NewServer()
    // 注册服务
    pb.RegisterGreetServiceServer(s, &Server{})
    reflection.Register(s)
    log.Println("grpc server start")
    if err = s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
        return
    }
}
type Server struct {
    pb.UnimplementedGreetServiceServer
}

package main
import (
    "context"
    "git.gqnotes.com/guoqiang/grpcexercises/greet/pb"
    "log"
    "time"
)
// Greet greet
func (s *Server) Greet(ctx context.Context, req *pb.GreetRequest) (*pb.GreetResponse, error) {
    log.Printf("Greet function was invoked with %v\n", req)
    result := "Hello " + req.GetGreeting() + ", now time is:" + time.Now().String()
    res := &pb.GreetResponse{
        Result: result,
    }
    return res, nil
}

package main
import (
    "git.gqnotes.com/guoqiang/grpcexercises/greet/pb"
    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials/insecure"
    "log"
)
func main() {
    conn, err := grpc.Dial(":5632", grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        log.Fatalf("failed to dial: %v", err)
        return
    }
    defer conn.Close()
    // 实例化客户端
    client := pb.NewGreetServiceClient(conn)
    // 调用方法
    Greet(client)
}

package main
import (
    "context"
    "git.gqnotes.com/guoqiang/grpcexercises/greet/pb"
    "log"
)
func Greet(client pb.GreetServiceClient) {
    response, err := client.Greet(context.Background(), &pb.GreetRequest{
        Greeting: "xiaoming",
    })
    if err != nil {
        log.Fatalf("failed to call Greet: %v", err)
        return
    }
    log.Printf("response:%+v\n", response)
}

./greet/bin/server-osx

./greet/bin/client-osx