【Go语言实战】(9) gRPC 实现一个简单微服务

• 写在前面
• 1. 安装
• • 1.1 grpc
  • 1.2 proto
  • 1.3 protobuf
• 2. 编写代码
• • 2.1 初始化项目
  • 2.2 编写proto
  • 2.3 编写服务端
  • 2.4 实现客户端
• 3. 演示

这一次我们用gRPC实现获取用户的信息

grpc的安装直接go get即可

go get google.golang.org/grpc

下载proto，我是下载这个的。

然后解压出来把bin目录放在直接放在系统变量当中

我们在终端

go get github.com/golang/protobuf

如果你像我一样go get不下来的话，可以直接git clone 源码

然后进入protoc-gen-go文件夹中，在此文件夹下打开cmd

执行

go build

就会发现多了一个可执行文件

然后把这个可执行文件放到刚刚1.2 讲的那个proto的文件夹下

打开cmd 输入 protoc

这样即可

• 新建一个文件夹gRPC，然后创建proto文件夹和client.go、server.go文件

在proto下创建一个user.proto

注意proto语法：

• 一个message类型定义描述了一个请求或响应的消息格式，可以包含多种类型字段。
• 例如定义一个搜索请求的消息格式，每个请求包含查询字符串、页码、每页数目。
• 字段名用小写，转为go文件后自动变成大写，message就相当于结构体。

先定下版本号：

syntax = "proto3";

然后是输出路径

option go_package = "./";

定义客户端请求格式

message UserRequest{
    // 定义请求参数
    string name = 1;
}

指定生成的包名称

package proto;

定义服务端响应格式

message UserResponse{
   // 定义响应参数
   int32 id = 1;
   string name = 2;
   int32 age = 3;
   // 字段修饰符
   // repeated 表示可变数组，类似于切片类型
   repeated string hobby = 4;
}

定义服务接口

service UserInfoService{
    // 接口内的方法
    // 定义请求参数为UserRequest,响应参数为UserResponse
    rpc GetUserInfo (UserRequest) returns (UserResponse){

    }
}

然后执行

protoc --go_out=plugins=grpc:. user.proto

生成pb.go文件

• 定义服务对象

type UserInfoService struct {
}

var u = UserInfoService{}

• 实现服务端的执行方法

func (service *UserInfoService)GetUserInfo(ctx context.Context,req *pb.UserRequest)(resp *pb.UserResponse,err error) {
	name := req.Name
	// 在数据库查询用户信息
	if name == "zs" {
		resp = &pb.UserResponse{
			Id:   1,
			Name: name,
			Age:  19,
			// 切片字段
			Hobby :[]string{"FanOne","FanOneTwo"},
		}
	}
	err = nil
	return
}

• 实现监听连接

	// 1. 监听
	address := "127.0.0.1:8080"
	lis, err := net.Listen("tcp", address)
	if err != nil {
		fmt.Println("监听异常 ",err)
		return
	}
	fmt.Println("监听成功")

• 实例化rpc

	s := grpc.NewServer()

• 在gRPC上注册微服务

	// 第一个类型是服务，第二个类型是接口的变量
	pb.RegisterUserInfoServiceServer(s,&u)

• 启动gRPC服务端

	_ = s.Serve(lis)

• 创建与gRPC服务端的连接

	conn, err := grpc.Dial("127.0.0.1:8080", grpc.WithInsecure())
	if err != nil {
		fmt.Println("连接异常",err)
	}
	defer conn.Close()

• 实例化gRPC客户端

	client := pb.NewUserInfoServiceClient(conn)

• 组装参数，New一个请求的参数，然后发送对象

	req := new(pb.UserRequest)
	req.Name="zs"

• 调用接口获取响应

	resp ,err := client.GetUserInfo(context.Background(),req)
	if err != nil {
		fmt.Println("响应异常",err)
	}
	fmt.Println("响应结果",resp)

• 先开启服务端监听端口

• 开启客户端发送请求

然后就可以获取到服务端信息了。

注意一点：

rpc的调用是一台机子的内存调用另一台自己的内存，所以我们要传指针的形式。