grpc服务

import (
    "github.com/yoyofx/yoyogo/abstractions"
    "github.com/yoyofxteam/dependencyinjection"
    yrpc "github.com/yoyofx/yoyogo/grpc"
    "google.golang.org/grpc"
    pb "grpc-demo/proto/helloworld"
    "grpc-demo/services"
)
func main() {
    configuration := abstractions.NewConfigurationBuilder().
        AddEnvironment().
        AddYamlFile("config").Build()
    hosting := yrpc.NewHostBuilder().
        UseConfiguration(configuration).Configure(func(app *yrpc.ApplicationBuilder) {
            //app.AddUnaryServerInterceptor( logger.UnaryServerInterceptor() )
            //app.AddStreamServerInterceptor( logger.StreamServerInterceptor() )
            app.AddGrpcService(func( server *grpc.Server, ctx *yrpc.ServiceContext ) {
                pb.RegisterGreeterServer( server, services.NewGreeterServer() )
            })
        }).
        ConfigureServices(func(collection *dependencyinjection.ServiceCollection) {
            //grpc client
            hosting.AddHostService(collection, NewClientService)
            collection.AddSingleton(NewHelloworldApi)
            //服务注册、发现
            nacos.UseServiceDiscovery(collection)
        }).Build()
    hosting.Run()
}
type Api struct {
    client pb.GreeterClient
}
// nacos 服务发现 grpc://public/[yoyogo_grpc_dev]
func NewHelloworldApi(factory *grpconn.Factory) *Api {
    clientConn, err := factory.CreateClientConn("grpc://public/[yoyogo_grpc_dev]")
    if err != nil {
        log.Println(err)
        return nil
    }
    client := pb.NewGreeterClient(clientConn)
    return &Api{client: client}
}
func (hw *Api) SayHello() error {
    resp, _ := hw.client.SayHello(context.Background(), &pb.HelloRequest{Name: "eddycjy"})
    log.Printf("client.SayHello resp: %s", resp.Message)
    return nil
}

protoc 安装

wget https://github.com/google/protobuf/releases/download/v3.15.6/protobuf-all-3.15.6.zip
unzip protobuf-all-3.15.6.zip && cd protobuf-3.15.6/
./configure
make
make install
protoc --version

go插件

go get -u github.com/golang/protobuf/protoc-gen-go@v1.3.2

安装grpc依赖

go get -u google.golang.org/grpc@v1.29.1

.proto 代码生成

protoc --go_out=plugins=grpc:. ./proto/*.proto

java 代码生成

protoc --java_out=./ XX.proto

grpc调试

go install github.com/fullstorydev/grpcurl/cmd/grpcurl

grpcurl -plaintext localhost:31127 list
# helloworld.Greeter

grpcurl -plaintext localhost:31127 list helloworld.Greeter
#helloworld.Greeter.SayHello
#helloworld.Greeter.SayList
#helloworld.Greeter.SayRecord
#helloworld.Greeter.SayRoute

grpc调用

grpcurl -plaintext -d '{"name":"Go"}' localhost:31127 helloworld.Greeter.SayHello
#{
#  "message": "hello.world.at.server: Go"
#}