微服务架构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)
}

总结：

在编写Demo的过程中，遇到的难点：

构思的难点:整个项目的调用流程，由于第一次接触微服务，对项目内部整体的gRPC调用流程不太熟悉，比如谁去调用业务的gRPC以及什么时候进行服务注册和服务发现。

实现的难点:etcd中的续租和健康检查部分，由于当时对这方法的知识点和API不太熟悉，导致代码编写错误，一直续租失败。

目前自己对微服务的理解：

微服务并不是一个全新的技术，而是一种架构的思想。相比于单体项目的能够方便地进行横向扩容，提高系统整体的处理能力。并且项目的迭代和部署是非常方便的。应用微服务的难点在于项目拆分的粒度以及各服务之间的通信、链路追踪。

原文地址：https://blog.csdn.net/wangye135/article/details/142761603

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！