Golang Gin框架搭建项目（六）Grpc服务

1、安装编译器：

Releases · protocolbuffers/protobuf · GitHub下载地址 ：Releases · protocolbuffers/protobuf · GitHub

windows电脑下载：protoc-21.2-win64.zip

解压后将bin目录添加到环境变量中，GoLand不生效就重启软件：

 2、下载protoc-gen-go和grpc包：

go install google.golang.org/protobuf/cmd/protoc-gen-go@latest

go get google.golang.org/grpc/cmd/protoc-gen-go-grpc
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc

go get google.golang.org/grpc

3、编写一个proto文件：GrpcDemo.proto

syntax = "proto3";
option go_package = "./serviceGrpc/;serviceGrpc";//存放目录和包名
package demo;
service DemoService {
  rpc UnaryCall (DemoRequest) returns (DemoReply);
//  rpc StreamingFromServer (Request) returns (stream Reply);
//  rpc StreamingFromClient (stream Request) returns (Reply);
//  rpc StreamingBothWays (stream Request) returns (stream Reply);
}
message DemoRequest {
    string json = 1;
};
message DemoReply {
    string message  = 1;
}

4、根据proto文件生成go代码文件：

#将./protos/*.proto匹配到的proto文件生成输出到当前目录下的serviceGrpc文件夹下（与proto文件中的option go_package对应）。

protoc --go_out=. --go-grpc_out=. ./protos/*.proto  

 5、Grpc服务端：

创建一个业务处理文件：MyDemoServer.go

package serviceGrpc
 
import (
	"context"
	"fmt"
)
 
type MyDemoServer struct {
	UnimplementedDemoServer
}
 
func (s *MyDemoServer) UnaryCall(ctx context.Context, req *DemoRequest) (*DemoReply, error) {
	fmt.Println("request:", req.Json)
	return &DemoReply{Message: "Hello " + req.Json}, nil
}

入口main.go 同时使用gin和grpc:

        单独开一个协程去启动grpc，也看情况可以独立使用gin或grpc。

func main() {
	go useGrpc()
	useGin()
}
func useGin() {
	conf, err := config.ParseConfig("./config/app.json")
	if err != nil {
		panic("读取配置文件失败，" + err.Error())
	}
	//fmt.Printf("conf:%#v\n", conf)
 
	utils.InitRedisUtil(conf.RedisConfig.Addr, conf.RedisConfig.Port, conf.RedisConfig.Password)
	utils.InitMySqlUtil(conf.Database)
	//创建一个默认的路由引擎
	engine := gin.Default()
	routers.RegisterRouter(engine)
	engine.Run(":9090")
}
 
func useGrpc() {
	const port = ":9091" // 服务器端口
	listen, err := net.Listen("tcp", port)
	if err != nil {
		fmt.Printf("failed to listen: %v", err)
		return
	}
	s := grpc.NewServer()
	serviceGrpc.RegisterDemoServer(s, &serviceGrpc.MyDemoServer{})
	//reflection.Register(s)
 
	defer func() {
		s.Stop()
		listen.Close()
	}()
	err = s.Serve(listen)
	if err != nil {
		fmt.Printf("failed to server: %v", err)
		return
	}
}

 6、使用postman模拟请求