基于 grpc,protobuf 搭建 server/client 模型通信

//安装 protobuf编译器
brew install protobuf
protoc --version
//安装 go protobuf 插件
go get -u github.com/golang/protobuf/{protoc-gen-go,proto}
//安装 grpc
go get -u google.golang.org/grpc

syntax = "proto3";
package example;
service FormatRequest {
 rpc DoFormat(Request) returns (Response){}
}
message Request{
    string userid = 1;
    string name=2;
    double score=3;
    int64 classId=4;
}
message Response{
    bool success =1;
    int32 errcodde =2;
}

protoc -I=. --go_out=plugins=grpc:. data.proto

package main
import (
	"GoTest/grpcTest/example"
	"context"
	"log"
	"net"
	"google.golang.org/grpc"
	"google.golang.org/grpc/reflection"
)
const (
	Port string = "9999"
)
type FormatRequest struct{}
func (fd *FormatRequest) DoFormat(ctx context.Context, in *example.Request) (out *example.Response, err error) {
	log.Printf("in is %+v\n", in)
	//TODO: 业务处理逻辑
	out = &example.Response{Success: true}
	return out, nil
}
func main() {
	listener, err := net.Listen("tcp", ":"+Port)
	if err != nil {
		log.Fatalln("faile listen at :"+Port, err)
	} else {
		log.Println("server is listening at :" + Port)
	}
	rpcServer := grpc.NewServer()
	example.RegisterFormatRequestServer(rpcServer, &FormatRequest{})
	reflection.Register(rpcServer)
	if err = rpcServer.Serve(listener); err != nil {
		log.Fatalln("faile serve at :" + Port)
	}
}

package main
import (
	"GoTest/grpcTest/example"
	"context"
	"log"
	"google.golang.org/grpc"
)
const (
	ADDRESS string = "localhost:9999"
)
type singletonRPC struct {
	clientRPC example.FormatRequestClient
}
var instance *singletonRPC
//单例模式客户端连接 RPC
func ConnectRPC() *example.FormatRequestClient {
	if instance != nil {
		return &instance.clientRPC
	}
	//因为这里没有启用安全链接，需要传人grpc.WithInsecure()表示忽略证书认证
	conn, err := grpc.Dial(ADDRESS, grpc.WithInsecure())
	if err != nil {
		panic("Can't connect: " + ADDRESS)
	}
	clientRPC := example.NewFormatRequestClient(conn)
	instance = &singletonRPC{clientRPC: clientRPC}
	return &clientRPC
}
func main() {
	//客户端链接 RPC
	client := *ConnectRPC()
	for i := 0; i <= 10000; i++ {
		_, err := client.DoFormat(context.Background(), &example.Request{
			Name:    "Jack",
			ClassId: 66,
			Score:   100,
		})
		if err != nil {
			log.Fatalln("Do format error:" + err.Error())
		}
	}
}