您好,登錄后才能下訂單哦!
這篇文章將為大家詳細講解有關(guān)微服務(wù)框架Go-Micro 集成Nacos的服務(wù)注冊是怎樣的,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。
Go Micro 是一個基于 Go 語言編寫的、用于構(gòu)建微服務(wù)的基礎(chǔ)框架,提供了分布式開發(fā)所需的核心組件,包括 RPC 和事件驅(qū)動通信等。
它的設(shè)計哲學是「可插拔」的插件化架構(gòu),其核心專注于提供底層的接口定義和基礎(chǔ)工具,這些底層接口可以兼容各種實現(xiàn)。例如 Go Micro 默認通過 consul 進行服務(wù)發(fā)現(xiàn),通過 HTTP 協(xié)議進行通信,通過 protobuf 和 json 進行編解碼,以便你可以基于這些開箱提供的組件快速啟動,但是如果需要的話,你也可以通過符合底層接口定義的其他組件替換默認組件,比如通過 nacos, etcd 或 zookeeper 進行服務(wù)發(fā)現(xiàn),這也是插件化架構(gòu)的優(yōu)勢所在:不需要修改任何底層代碼即可實現(xiàn)上層組件的替換。
Micro 是一個微服務(wù)工具包,包括:
API
提供并將 HTTP 請求路由到相應(yīng)微服務(wù)的 API 網(wǎng)關(guān)。它充當微服務(wù)訪問的單一入口,將 HTTP 請求轉(zhuǎn)換為 RPC 并轉(zhuǎn)發(fā)給相應(yīng)的服務(wù)也可以用作反向代理。
Web
UI 是 go-micro 的 web 版本,允許通過 UI 交互訪問環(huán)境。在未來,它也將是一種聚合微型 Web 服務(wù)的方式。它包含一種 Web 應(yīng)用程序的代理方式。將 /[name] 通過注冊表路由到相應(yīng)的服務(wù)。Web UI 將前綴“go.micro.web?!保梢耘渲茫┨砑拥矫Q中,在注冊表中查找它,然后將進行反向代理。
Sidecar
go-micro 的 HTTP 接口版本,這是將非 Go 應(yīng)用程序集成到微環(huán)境中的一種方式。
Bot
Hubot 風格的 bot,位于您的微服務(wù)平臺中,可以通過 Slack,HipChat,XMPP 等進行交互。它通過消息傳遞提供 CLI 的功能??梢蕴砑悠渌顏碜詣訄?zhí)行常見的操作任務(wù)。
CLI
一個直接的命令行界面來與你的微服務(wù)進行交互,它提供了一種觀察和與運行環(huán)境交互的方式。
用于在 Go 中編寫微服務(wù)的插件式 RPC 框架。它提供了用于服務(wù)發(fā)現(xiàn),客戶端負載平衡,編碼,同步和異步通信庫。go-micro 是一個獨立的庫,可以獨立于其他工具包使用。
go-micro 是組件化的框架,每一個基礎(chǔ)功能都是一個 interface ,方便擴展。同時,組件又是分層的,上層基于下層功能向上提供服務(wù),整體構(gòu)成 go-micro 框架。go-micro 框架的構(gòu)成組件有:
Registry
提供服務(wù)發(fā)現(xiàn)機制:解析服務(wù)名字至服務(wù)地址。目前支持的注冊中心有 consul、etcd、 zookeeper、dns、gossip 等。
Selector
選擇器通過選擇提供負載均衡機制。當客戶端向服務(wù)器發(fā)出請求時,它將首先查詢服務(wù)的注冊表。這通常會返回一個表示服務(wù)的正在運行的節(jié)點列表。選擇器將選擇這些節(jié)點中的一個用于查詢。多次調(diào)用選擇器將允許使用平衡算法。目前的方法是循環(huán)法,隨機哈希和黑名單。
Broker
發(fā)布和訂閱的可插入接口,服務(wù)之間基于消息中間件的異步通信方式,默認使用 http 方式,線上通常使用消息中間件,如 Nats、Kafka、RabbitMQ 和 http(用于開發(fā))。
Transport
通過點對點傳輸消息的可插拔接口。目前的實現(xiàn)是 http,rabbitmq 和 nats 。通過提供這種抽象,運輸可以無縫地換出。
Codec
服務(wù)之間消息的編碼/解碼。
Plugins
提供 go-micro 的 micro/go-plugins 插件。
Server
服務(wù)器是構(gòu)建正在運行的微服務(wù)的接口。它提供了一種提供 RPC 請求的方法。該組件基于上面的 Registry/Selector/Transport/Broker 組件,對外提供一個統(tǒng)一的服務(wù)請求入口。
Client
提供一種制作 RPC 查詢的方法訪問微服務(wù)的客戶端。它結(jié)合了注冊表,選擇器,代理和傳輸。它還提供重試,超時,使用上下文等。類似 Server 組件,它也是通過 Registry/Selector/Transport/Broker 組件實現(xiàn)查找服務(wù)、負載均衡、同步通信、異步消息等功能。
Nacos 是一個更易于構(gòu)建云原生應(yīng)用的動態(tài)服務(wù)發(fā)現(xiàn)、配置管理和服務(wù)管理的平臺,Nacos 脫胎于阿里巴巴內(nèi)部的 ConfigServer 和 Diamond ,是它們的開源實現(xiàn)。經(jīng)歷過雙十一流量峰值和阿里巴巴經(jīng)濟體超大規(guī)模容量的考驗,沉淀了阿里巴巴軟負載團隊在這個領(lǐng)域十年的經(jīng)驗,在穩(wěn)定性和功能性上都有很好的保障。
Nacos 邏輯架構(gòu)及其組件概覽圖:
Protobuf 是 Protocol Buffers 的簡稱,它是 Google 公司開發(fā)的一種數(shù)據(jù)描述語言,并于 2008 年對外開源。Protobuf 剛開源時的定位類似于 XML、JSON 等數(shù)據(jù)描述語言,通過附帶工具生成代碼并實現(xiàn)將結(jié)構(gòu)化數(shù)據(jù)序列化的功能。我們需要利用 protoc 生成服務(wù)端代碼。
o get github.com/golang/protobuf/protoc-gen-go
go install github.com/micro/micro/v2
在項目根目錄下創(chuàng)建 proto 文件夾,用來存放 protobuf 文件
在 proto 文件夾下創(chuàng)建 greeter.proto 文件
文件內(nèi)容如下:
在服務(wù)端中使用 protobuf 文件定義了一個服務(wù)叫做 Greeter 的處理器,它有一個接收 HelloRequest 并返回 HelloResponse 的 Hello 方法。
syntax = "proto3"; package helloworld; service Greeter { rpc Hello(HelloRequest) returns (HelloResponse) {} } message HelloRequest { string name = 1; } message HelloResponse { string greeting = 2; }
生成相應(yīng)的 Go 代碼
protoc --micro_out=. --go_out=. proto/greeter.proto
在 proto 目錄下,生成了 pb.go 以及 pb.micro.go 兩個文件
創(chuàng)建 server.go 并運行
package main import ( "context" helloworld "go-micro-nacos-demo1/proto" "github.com/micro/go-micro/v2" "github.com/micro/go-micro/v2/logger" "github.com/micro/go-micro/v2/registry" nacos "github.com/micro/go-plugins/registry/nacos/v2" ) type Helloworld struct{} // Call is a single request handler called via client.Call or the generated client code func (e *Helloworld) Hello(ctx context.Context, req *helloworld.HelloRequest, rsp *helloworld.HelloResponse) error { logger.Info("Received Helloworld.Call request") return nil } func main() { addrs := make([]string, 1) addrs[0] = "console.nacos.io:80" registry := nacos.NewRegistry(func(options *registry.Options) { options.Addrs = addrs }) service := micro.NewService( // Set service name micro.Name("my.micro.service"), // Set service registry micro.Registry(registry), ) helloworld.RegisterGreeterHandler(service.Server(), new(Helloworld)) service.Run() }
在 Nacos console 中可以看到 my.micro.service 成功注冊
創(chuàng)建 client.go (為了方便演示,本文在同一項目下創(chuàng)建了 cient.go)。
package main import ( "context" "fmt" helloworld "go-micro-nacos-demo1/proto" "github.com/micro/go-micro/v2" "github.com/micro/go-micro/v2/registry" nacos "github.com/micro/go-plugins/registry/nacos/v2" ) const serverName = "my.micro.service" func main() { addrs := make([]string, 1) addrs[0] = "console.nacos.io:80" r := nacos.NewRegistry(func(options *registry.Options) { options.Addrs = addrs }) // 定義服務(wù),可以傳入其它可選參數(shù) service := micro.NewService( micro.Name("my.micro.service.client"), micro.Registry(r)) // 創(chuàng)建新的客戶端 greeter := helloworld.NewGreeterService(serverName, service.Client()) // 調(diào)用greeter rsp, err := greeter.Hello(context.TODO(), &helloworld.HelloRequest{Name: "John"}) if err != nil { fmt.Println(err) } //獲取所有服務(wù) fmt.Println(registry.ListServices()) //獲取某一個服務(wù) services, err := registry.GetService(serverName) if err != nil { fmt.Println(err) } //監(jiān)聽服務(wù) watch, err := registry.Watch() fmt.Println(services) // 打印響應(yīng)請求 fmt.Println(rsp.Greeting) go service.Run() for { result, err := watch.Next() if len(result.Action) > 0 { fmt.Println(result, err) } } }
運行客戶端,在 nacos console 中可以看到客戶端服務(wù)也注冊到了 nacos 中。
server.go 的控制臺中打印了調(diào)用日志。
服務(wù)端:使用 go-micro 創(chuàng)建服務(wù)端 Demo,并注冊到 nacos 。
registry := nacos.NewRegistry(func(options *registry.Options) { options.Addrs = addrs }) service := micro.NewService( // Set service name micro.Name("my.micro.service"), // Set service registry micro.Registry(registry), ) service.Run()
使用 go-micro 創(chuàng)建客戶端 Demo ,注冊到 nacos :
r := nacos.NewRegistry(func(options *registry.Options) { options.Addrs = addrs }) service := micro.NewService( micro.Name("my.micro.service.client"), micro.Registry(r))
客戶端調(diào)用:
// 創(chuàng)建新的客戶端 greeter := helloworld.NewGreeterService(serverName, service.Client()) // 調(diào)用greeter rsp, err := greeter.Hello(context.TODO(), &helloworld.HelloRequest{Name: "John"})
查詢服務(wù)列表:
services,err:=registry.ListServices()
獲取某一個服務(wù):
service, err := registry.GetService(serverName)
訂閱服務(wù):
watch, err := registry.Watch() for { result, err := watch.Next() if len(result.Action) > 0 { fmt.Println(result, err) } }
關(guān)于微服務(wù)框架Go-Micro 集成Nacos的服務(wù)注冊是怎樣的就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。