快捷導(dǎo)航

Go語(yǔ)言從單體服務(wù)到微服務(wù)設(shè)計(jì)方案詳解

更新時(shí)間：2023年03月23日 14:35:39 作者：stark張宇

這篇文章主要為大家介紹了Go語(yǔ)言從單體服務(wù)到微服務(wù)設(shè)計(jì)方案詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

概述

微服務(wù)是一種思想，與編程語(yǔ)言無(wú)關(guān)，編程語(yǔ)言是思想下具體的一種實(shí)現(xiàn)方式，怎么設(shè)計(jì)架構(gòu)方案和實(shí)現(xiàn)主要看主要面臨的業(yè)務(wù)場(chǎng)景。

業(yè)務(wù)場(chǎng)景

主站核心業(yè)務(wù)使用的是yaf(php)開(kāi)發(fā)的，要實(shí)現(xiàn)k8s + x編程語(yǔ)言自主微服務(wù)實(shí)現(xiàn)，受到陳皓(左耳聽(tīng)風(fēng))的影響，我選用的編程語(yǔ)言是Go，Go語(yǔ)言有更強(qiáng)大的生態(tài)，有谷歌，k8s作為強(qiáng)大的后盾，摸著石頭過(guò)河。

設(shè)計(jì)方案

Api網(wǎng)關(guān)

提到微服務(wù)我們就聯(lián)想到Rpc，主流微服務(wù)價(jià)格設(shè)計(jì)，微服務(wù)之間的調(diào)用都使用Rpc，微服務(wù)也有直接用http實(shí)現(xiàn)的，Rpc限制了開(kāi)發(fā)時(shí)候的靈活性和兼容性，主要3點(diǎn)原因:

1.Http協(xié)議是實(shí)際通信的標(biāo)準(zhǔn)，靈活性和兼容性得到了很好的市場(chǎng)驗(yàn)證，對(duì)Rpc我抱有懷疑態(tài)度，在Api層進(jìn)行權(quán)限的統(tǒng)一認(rèn)證( Token/Cookies ) , 后期微服務(wù)體系成熟，可以統(tǒng)一接入Api網(wǎng)關(guān)服務(wù)，Api網(wǎng)關(guān)服務(wù)是不可缺少的，全使用Nginx反向代理的方式，再數(shù)據(jù)統(tǒng)計(jì)的角度上局限性。

2.控制異常，如果發(fā)生異常,Rpc服務(wù)掛掉或者遭到網(wǎng)絡(luò)攻擊/刷請(qǐng)求，請(qǐng)求會(huì)直接打到Rpc上，如果有網(wǎng)關(guān)層，可以在Redis中加Redis鎖，把無(wú)效的網(wǎng)絡(luò)請(qǐng)求進(jìn)行隔離。

數(shù)據(jù)

拆分微服務(wù)最大的兩個(gè)問(wèn)題是數(shù)據(jù)的一致性和性能，系統(tǒng)性能的瓶頸主要是因?yàn)橛?jì)算機(jī)Cpu，內(nèi)存(memory/內(nèi)存條、cache/Cpu的內(nèi)存) 是非?？斓?，所有的性能問(wèn)題大同小異，磁盤(pán)I/O往往才是性能的瓶頸。

1.數(shù)據(jù)的一致性的解決辦法

模塊化拆分和遷移微服務(wù)功能，把涉及到的整塊進(jìn)行遷移，可以按比重分流/整體功能進(jìn)行，按比重分流要保留新舊數(shù)據(jù)的兼容，需要雙寫(xiě)，現(xiàn)在的有聲業(yè)務(wù)體量小，可以整塊整塊的遷移。

2.性能：有聲的數(shù)據(jù)量非常小，暫時(shí)不使用redis緩存可能也不會(huì)造成什么性能問(wèn)題，所以我把很小的公共部分進(jìn)行了緩存，主要考慮C端用戶的體驗(yàn)。

Go中的Grpc使用

Go-zero這個(gè)框架使用goctl工具開(kāi)發(fā)速度非常高效，對(duì)調(diào)用外部的Grpc服務(wù)需要做更多的兼容，這里做一個(gè)解釋說(shuō)明，protoc-gen-go、protoc-gen-go-grpc這兩個(gè)工具是protobuf的工具，是Go 1.5版本后新加的，這個(gè)地方饒了好大一圈。

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

在有聲微服務(wù)中，是調(diào)用UserRpc的權(quán)限驗(yàn)證部分，Go-zero不支持，所以自己寫(xiě)了一些兼容包。

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.調(diào)用UserRpc服務(wù),需要實(shí)現(xiàn)的包是客戶端部分代碼，本地需要TLS加密，服務(wù)才能被調(diào)用的到,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.驗(yàn)證管理員權(quán)限
	resp, err := client.AdminMid(context.Background(), &pb.UserInternalParams_AdminMidReq{
		Session: Session,
	})
	//3.驗(yàn)證菜單權(quán)限
	auth, err := client.AdminAuth(context.Background(), &pb.UserInternalParams_AdminAuthReq{
			Action:     Action,
			Controller: Controller,
			Param:      Param,
			Session:    Session,
		})
	//....
}