微服务架构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不太熟悉,导致代码编写错误,一直续租失败。

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

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

上一篇:contact form 7设置方法与详细步骤


下一篇:hexo博客部署到云服务器