微服务架构Gin-etcd-gRPC接合的入门实践

最近在学习微服务，先后学习gRPC、etcd。学习过这两个技术之后，结合Gin框架，简单实现了一个微服务的小demo了。
以下是各技术在微服务架构中的功能。

Gin框架作为网关，外部请求的统一出口。负责将外部的HTTP请求转化为RPC请求，并转发给对应模块的RPC方法进行处理。
etcd储存和监听服务模块的ip和port信息。负责服务注册和服务发现。
gRPC微服务系统内部的通信方式。

项目地址：

GIn_etcd_gRPC: 使用Gin_etcd_gRPC实现的一个微服务的架构的小demo (gitee.com)

项目目录：

项目一共有四个模块，每一个模块都是单独的服务，可以独立打包部署。

serviceHub服务中心，主要负责服务注册和服务发现，对外提供etcd的读写RPC方法。
gateway网关，使用Gin，相当于外部HTTP和内部gRPC的桥梁，主要负责将外部的HTTP请求转换转发给对应模块的RPC方法并将结果返回给客户端。
user、post业务模块，负责具体处理请求，并将结构返回给调用者。

项目中的端口信息：

etcd:127.0.0.1:2379
serviceHub:127.0.0.1:8004
post:127.0.0.1:8005
user:127.0.0.1:8006
gateway:127.0.0.1:8008

注意项目的启动顺序，先启动etcd,之后启动serviceHub、然后是post、user、gateway。

项目调用流程图:

在getway当中，我们需要进行路由注册，将路径和对应的处理方法关联起来。因此，我们需要进行服务发现和服务调用。让/user/login请求路径被user模块的login方法所处理。具体看仓库中的路由注册的代码。

func main() {r := gin.Default()//1. 获取服务注册与发现的模块信息DiscoveryConn, err := grpc.Dial("127.0.0.1:8004", grpc.WithTransportCredentials(insecure.NewCredentials()))if err != nil {log.Fatalf("get DiscoveryConn err %v", DiscoveryConn)}discoveryClient := discoveryPb.NewDiscoveryClient(DiscoveryConn)_, err = discoveryClient.WatchService(context.Background(), &discoveryPb.Prefix{Prefix: "/"})if err != nil {log.Fatal("watch prefix / is error:", err)}//进行路由注册router.Register(r, discoveryClient)//启动服务r.Run("127.0.0.1:8008")
}

func Register(r gin.IRouter, client discoveryPb.DiscoveryClient) {userRouter(r, client)postRouter(r, client)
}func userRouter(r gin.IRouter, client discoveryPb.DiscoveryClient) {userGroup := r.Group("/user")//通过 服务发现 获取/user模块的ip和端口信息，之后创建user模块的RPC客户端，让服务端处理对应的请求。//由于使用的是Gin框架,因此,在路径对应Handle方法中调用服务端的请求.userModelInfo, userErr := client.GetServices(context.Background(), &discoveryPb.ServiceName{Name: "/user"})if userErr != nil {log.Fatalf("get userServiceInfo error %v", userErr)}userModelConn, userConnErr := grpc.Dial(userModelInfo.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))if userConnErr != nil {log.Fatalf("get userServiceInfo error %v", userConnErr)}userClient := userPb.NewUserClient(userModelConn)//user模块的路由注册.user := api.User{Client: userClient}userGroup.POST("/login", user.Login)userGroup.POST("/register", user.Register)
}

type User struct {Client userPb.UserClient
}func (u *User) Register(c *gin.Context) {registerInfo := userRegLog{}if err := c.ShouldBindJSON(&registerInfo); err != nil {log.Fatalf("get userLogin info err, %v", err)}res, err := u.Client.UserRegister(context.Background(), &userPb.LoginOrRegisterInfo{PhoneNumber:  registerInfo.phoneNumber,UserPassword: registerInfo.userPassword,})if err != nil {c.JSON(http.StatusExpectationFailed, res)}c.JSON(http.StatusOK, res)
}