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

news2024/11/24 15:33:37

最近在学习微服务，先后学习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)
}