Go语言从单体服务到微服务设计方案详解_Golang

Go语言从单体服务到微服务设计方案详解

2023-03-24 12:13stark张宇 Golang

这篇文章主要为大家介绍了Go语言从单体服务到微服务设计方案详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

概述

微服务是一种思想，与编程语言无关，编程语言是思想下具体的一种实现方式，怎么设计架构方案和实现主要看主要面临的业务场景。

业务场景

主站核心业务使用的是yaf(php)开发的，要实现k8s + x编程语言自主微服务实现，受到陈皓(左耳听风)的影响，我选用的编程语言是Go，Go语言有更强大的生态，有谷歌，k8s作为强大的后盾，摸着石头过河。

设计方案

Go语言从单体服务到微服务设计方案详解

Api网关

提到微服务我们就联想到Rpc，主流微服务价格设计，微服务之间的调用都使用Rpc，微服务也有直接用http实现的，Rpc限制了开发时候的灵活性和兼容性，主要3点原因:

1.Http协议是实际通信的标准，灵活性和兼容性得到了很好的市场验证，对Rpc我抱有怀疑态度，在Api层进行权限的统一认证( Token/Cookies ) , 后期微服务体系成熟，可以统一接入Api网关服务，Api网关服务是不可缺少的，全使用Nginx反向代理的方式，再数据统计的角度上局限性。

2.控制异常，如果发生异常,Rpc服务挂掉或者遭到网络攻击/刷请求，请求会直接打到Rpc上，如果有网关层，可以在Redis中加Redis锁，把无效的网络请求进行隔离。

数据

拆分微服务最大的两个问题是数据的一致性和性能，系统性能的瓶颈主要是因为计算机Cpu，内存(memory/内存条、cache/Cpu的内存) 是非常快的，所有的性能问题大同小异，磁盘I/O往往才是性能的瓶颈。

1.数据的一致性的解决办法

模块化拆分和迁移微服务功能，把涉及到的整块进行迁移，可以按比重分流/整体功能进行，按比重分流要保留新旧数据的兼容，需要双写，现在的有声业务体量小，可以整块整块的迁移。

2.性能：有声的数据量非常小，暂时不使用redis缓存可能也不会造成什么性能问题，所以我把很小的公共部分进行了缓存，主要考虑C端用户的体验。

Go中的Grpc使用

Go-zero这个框架使用goctl工具开发速度非常高效，对调用外部的Grpc服务需要做更多的兼容，这里做一个解释说明，protoc-gen-go、protoc-gen-go-grpc这两个工具是protobuf的工具，是Go 1.5版本后新加的，这个地方饶了好大一圈。

GitHub Demo 地址 : github.com/grpc/grpc-g…

				?

									$ go install google.golang.org/protobuf/cmd/protoc-gen-go@v1.28

									$ go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.2

在有声微服务中，是调用UserRpc的权限验证部分，Go-zero不支持，所以自己写了一些兼容包。

1.首先pb文件生成Pb和Grpc文件

				?

									$ ll

									-rw-r--r--  1 stark  staff    69K  3 20 15:51 cp_user_internal.pb.go

									-rw-r--r--  1 stark  staff    34K  3 20 15:51 cp_user_internal_grpc.pb.go

2.调用UserRpc服务,需要实现的包是客户端部分代码，本地需要TLS加密，服务才能被调用的到,grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})))是TLS灵魂。

				?

									package client

									func Auth(Session string, Action string, Controller string, Param string) bool {

									    // 1.建立链接

									    flag.Parse()

									    conn, err := grpc.Dial("testing.gongzicp.com:1443", grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})))

									    if err != nil {

									        log.Fatalf("did not connect: %v", err)

									    }

									    defer conn.Close()

									    client := pb.NewUserInternalClient(conn)

									    //2.验证管理员权限

									    resp, err := client.AdminMid(context.Background(), &pb.UserInternalParams_AdminMidReq{

									        Session: Session,

									    })

									    //3.验证菜单权限

									    auth, err := client.AdminAuth(context.Background(), &pb.UserInternalParams_AdminAuthReq{

									            Action:     Action,

									            Controller: Controller,

									            Param:      Param,

									            Session:    Session,

									        })

									    //....

									}