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"
#}