gRPC（二）golang gRPC样例

本文代码地址

https://gitee.com/shoothzj/grpc-examples

go语言实现gRPC客户端服务端

添加golang package定义

option go_package = "go_grpc_examples/echo";

安装依赖

go install google.golang.org/protobuf/cmd/protoc-gen-go@v1.28
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.2
go get google.golang.org/grpc

生成golang代码

protoc --go_out=echo --go_opt=paths=source_relative --go-grpc_out=echo --go-grpc_opt=paths=source_relative  --proto_path=..  ../message_proto2.proto

server侧代码

package main

import (
    "context"
    "go_grpc_examples/echo"
    "google.golang.org/grpc"
    "log"
    "net"
)

type server struct {
    echo.UnimplementedEchoProto2ServiceServer
}

func (s *server) EchoProto2(ctx context.Context, req *echo.EchoProto2Req) (*echo.EchoProto2Resp, error) {
    return &echo.EchoProto2Resp{
        StrReq:   req.StrReq,
        StrOpt:   req.StrOpt,
        StrRep:   req.StrRep,
        Int64Req: req.Int64Req,
        Int32Opt: req.Int32Opt,
        Comic:    req.Comic,
    }, nil
}

func main() {
    listen, err := net.Listen("tcp", ":10240")
    if err != nil {
        panic(err)
    }
    s := grpc.NewServer()
    echo.RegisterEchoProto2ServiceServer(s, &server{})
    log.Printf("server listening at %v", listen.Addr())
    if err := s.Serve(listen); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

客户端代码

package main

import (
    "context"
    "go_grpc_examples/echo"
    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials/insecure"
    "log"
    "time"
)

func main() {
    conn, err := grpc.Dial("localhost:10240", grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        panic(err)
    }
    defer conn.Close()
    c := echo.NewEchoProto2ServiceClient(conn)

    // Contact the server and print out its response.
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    defer cancel()
    var strReq = "strReq"
    var strOpt = "strOpt"
    var int64Req = int64(64)
    var int32Opt = int32(32)
    comic := echo.Comic_Bleach
    r, err := c.EchoProto2(ctx, &echo.EchoProto2Req{
        StrReq:   &strReq,
        StrOpt:   &strOpt,
        StrRep:   []string{"str", "req"},
        Int64Req: &int64Req,
        Int32Opt: &int32Opt,
        Comic:    &comic,
    })
    if err != nil {
        log.Fatalf("could not greet: %v", err)
    }
    log.Printf("Greeting: %s", r)
}