共计 2876 个字符，预计需要花费 8 分钟才能阅读完成。
前言
笔者最近换了一份工作从一家新零售公司去到一家做电子商务的公司，主要的编程语言也从 NodeJs 转为了 Go，因为新公司使用的是 grpc 做的微服务，所以要重新开始学习新的东西了，正好把这周学习的东西做个总结。整个系列主要涉及 Golang、gRPC、go-micros、Docker、Docker-compose、consul，通过本系列，你可以了解到如何 1、使用 grpc/go-mircos 构建微服务，2、使用 docker 进行服务的部署，3、使用 consul 进行服务发现
grpc 简介
gRPC 是谷歌开源的一款跨平台、高性能的 RPC 框架，笔者目前主要使用它来进行后端微服务的开发。可能会有的同学对 RPC 不太熟悉, 其实在笔者看来，RPC 和 HTTP 并无多大的区别都是一种调用方式，区别则是在于 RPC 会限制传输协议、传输的参数等，以此换取高效的传输流程，比如 grpc 就使用的是 google 开源的 protobuf 协议，使用 TCP 的方式进行传输，使得请求比起普通的 JSON+HTPP 更加快捷。关于更多 protobuf 的信息，可以查看这里
必要的准备
了解 Golang 及其生态
安装 gRPc 及 protobuf，教程
安装 golang
安装 protobuf 编译器
本期目标
本期目标是使用 gRPC 实现一个非常小的微服务 user-service，服务的功能非常简单，只提供一个获取用户信息的接口
一、首先我们需要定义好整个服务的 protobuf 文件 user.proto
syntax = “proto3”; // 指定语法格式，注意 proto3 不再支持 proto2 的 required 和 optional
package proto; // 指定生成的 user.pb.go 的包名，防止命名冲突
// service 定义开放调用的服务，即 UserInfoService 微服务
service UserInfoService {
// rpc 定义服务内的 GetUserInfo 远程调用
rpc GetUserInfo (UserRequest) returns (UserResponse) {
}
}
// message 对应生成代码的 struct
// 定义客户端请求的数据格式
message UserRequest {
// [修饰符] 类型 字段名 = 标识符;
string name = 1;
}
// 定义服务端响应的数据格式
message UserResponse {
int32 id = 1;
string name = 2;
int32 age = 3;
repeated string title = 4; // repeated 修饰符表示字段是可变数组，即 slice 类型
}
然后我们通过 protoc 命令编译 proto 文件，生成对应的 go 文件
protoc -I . –go_out=plugins=grpc:. ./user.proto
具体文件太长就不放出来展示了
二、我们来实现 server.go
首先我们应该明确实现的步骤：1、实现 GetUserInfo 接口 2、使用 gRPC 建立服务，监听端口 3、将我们实现的服务注册到 gRPC 中去话不多说，代码如下
package main
import (
“fmt”
“log”
“net”
// Import the generated protobuf code
pb “go_mirco_service/proto”
“golang.org/x/net/context”
“google.golang.org/grpc”
)
type UserInfoService struct{}
var u = UserInfoService{}
func (u *UserInfoService) GetUserInfo(ctx context.Context, req *pb.UserRequest) (resp *pb.UserResponse, err error) {
name := req.Name
if name == “leoython” {
resp = &pb.UserResponse{
Id: 233,
Name: name,
Age: 20,
Title: []string{“Gopher”},
}
}
err = nil
return
}
func main() {
port := “:2333”
l, err := net.Listen(“tcp”, port)
if err != nil {
log.Fatalf(“listen error: %v\n”, err)
}
fmt.Printf(“listen %s\n”, port)
s := grpc.NewServer()
// 将 UserInfoService 注册到 gRPC
// 注意第二个参数 UserInfoServiceServer 是接口类型的变量
// 需要取地址传参
pb.RegisterUserInfoServiceServer(s, &u)
s.Serve(l)
}
到此我们就实现了利用 gRPC 实现了一个非常简单但是五脏俱全的 RPC 服务，但是却出现了一个问题，我们无法直接调用，所以我们还需要实现一个调用 server 的客户端，代码如下
package main
import (
“fmt”
“log”
pb “go_mirco_service/proto”
“golang.org/x/net/context”
“google.golang.org/grpc”
)
func main() {
conn, err := grpc.Dial(“:2333”, grpc.WithInsecure())
if err != nil {
log.Fatalf(“dial error: %v\n”, err)
}
defer conn.Close()
// 实例化 UserInfoService 微服务的客户端
client := pb.NewUserInfoServiceClient(conn)
// 调用服务
req := new(pb.UserRequest)
req.Name = “leoython”
resp, err := client.GetUserInfo(context.Background(), req)
if err != nil {
log.Fatalf(“resp error: %v\n”, err)
}
fmt.Printf(“Recevied: %v\n”, resp)
}
结语
至此，我们已经学会使用 gRPC 进行开发，采用 protobuf 进行参数的定义，下一篇笔者将会使用 grpc-gateway 将 RPC 接口转换为 rest 接口供客户端调用，而不需要客户端实现 RPC，这也是现在主流微服务的一种服务提供方式，对外使用 REST，对内使用 RPC，关于更多微服务的内容，推荐查看 nginx 的关于微服务的文章
关于作者
Leoython，擅长 Javascript, Python, Go，最近在研究 Rust 和 k8s
E-Mail: leoython@gmail.com
文章编写于: 2019/01/31
转载请注明出处:
http://www.leoython.club/arti…
