go语言学习-gRPC3-rpc以及grpc示例

|—— hello/
    |—— client/
        |—— main.go   // 客户端
    |—— server/
        |—— main.go   // 服务端
|—— proto/
    |—— hello/
        |—— hello.proto   // proto描述文件
        |—— hello.pb.go   // proto编译后文件

syntax = "proto3"; // 指定proto版本
package hello;     // 指定默认包名

// 指定golang包名
option go_package = "../hello";

// 定义Hello服务
service Hello {
    // 定义SayHello方法
    rpc SayHello(HelloRequest) returns (HelloResponse) {}
}

// HelloRequest 请求结构
message HelloRequest {
    string name = 1; //代表序号
}

// HelloResponse 响应结构
message HelloResponse {
    string message = 1;
}

#下载protoc-gen-go-grpc编译工具，专门编译为grpc格式
$ go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
$ go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest

#下载grpc包
go get -u google.golang.org/grpc

#保存到/usr/local/bin/下
find / -name protoc-gen-go-grpc
cp /root/go/bin/protoc-gen-go-grpc /usr/local/bin/

#编辑/etc/profile环境变量增加
#:/usr/local/bin/protoc-gen-go-grpc
#加载环境变量
source /etc/profile

cd proto/hello
protoc --go-grpc_out=. hello.proto

//server/main.go
package main

import (
	"fmt"
	"net"

	pb "go-project/go-project/go_basic2/gRpc/demo3/proto/hello" // 引入编译生成的包

	"golang.org/x/net/context"
	"google.golang.org/grpc"
	"google.golang.org/grpc/grpclog"
)

const (
	// Address gRPC服务地址
	Address = "127.0.0.1:50052"
)

// 定义helloService并实现约定的接口
type helloService struct{}

// HelloService Hello服务
var HelloService = helloService{}

// SayHello 实现Hello服务接口
func (h helloService) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloResponse, error) {
	//此处调用生成的hello_grpc.pb.go中的接口
	//type HelloServer interface {
	// 定义SayHello方法
	//SayHello(context.Context, *HelloRequest) (*HelloResponse, error)

	resp := new(pb.HelloResponse)
	resp.Message = fmt.Sprintf("Hello %s.", in.Name)

	return resp, nil
}

func main() {
	listen, err := net.Listen("tcp", Address)
	if err != nil {
		grpclog.Fatalf("Failed to listen: %v", err)
	}

	// 实例化grpc Server
	s := grpc.NewServer()

	// 注册HelloService
	pb.RegisterHelloServer(s, HelloService)

	grpclog.Println("Listen on " + Address)
	s.Serve(listen)
}

$ go run main.go
Listen on 127.0.0.1:50052  //服务端已开启并监听50052端口

package main

import (
	pb "go-project/go-project/go_basic2/gRpc/demo3/proto/hello" // 引入编译生成的包 // 引入proto包

	"golang.org/x/net/context"
	"google.golang.org/grpc"
	"google.golang.org/grpc/grpclog"
)

const (
	// Address gRPC服务地址
	Address = "127.0.0.1:50052"
)

func main() {
	// 连接
	conn, err := grpc.Dial(Address, grpc.WithInsecure())
	if err != nil {
		grpclog.Fatalln(err)
	}
	defer conn.Close()

	// 初始化客户端
	c := pb.NewHelloClient(conn)

	// 调用方法
	req := &pb.HelloRequest{Name: "gRPC"}
	res, err := c.SayHello(context.Background(), req)

	if err != nil {
		grpclog.Fatalln(err)
	}

	grpclog.Println(res.Message)
}

$ go run main.go
Hello gRPC.    // 接收到服务端响应