雲計算

微服務框架Go-Micro集成Nacos實戰之服務註冊與發現

相關背景知識

Go-Micro

Go Micro 是一個基於 Go 語言編寫的、用於構建微服務的基礎框架,提供了分佈式開發所需的核心組件,包括 RPC 和事件驅動通信等。

它的設計哲學是「可插拔」的插件化架構,其核心專注於提供底層的接口定義和基礎工具,這些底層接口可以兼容各種實現。例如 Go Micro 默認通過 consul 進行服務發現,通過 HTTP 協議進行通信,通過 protobuf 和 json 進行編解碼,以便你可以基於這些開箱提供的組件快速啟動,但是如果需要的話,你也可以通過符合底層接口定義的其他組件替換默認組件,比如通過 nacos, etcd 或 zookeeper 進行服務發現,這也是插件化架構的優勢所在:不需要修改任何底層代碼即可實現上層組件的替換。

Go-Micro概述

Micro是一個微服務工具包,包括:

API

提供並將 HTTP 請求路由到相應微服務的 API 網關。它充當微服務訪問的單一入口,將HTTP 請求轉換為 RPC 並轉發給相應的服務也可以用作反向代理。

image.png

Web

UI 是 go-micro 的 web 版本,允許通過 UI 交互訪問環境。在未來,它也將是一種聚合微型 Web 服務的方式。它包含一種 Web 應用程序的代理方式。將 /[name] 通過註冊表路由到相應的服務。Web UI 將前綴“go.micro.web。”(可以配置)添加到名稱中,在註冊表中查找它,然後將進行反向代理。
image.png

Sidecar

go-micro 的 HTTP 接口版本,這是將非 Go 應用程序集成到微環境中的一種方式。
image.png

Bot

Hubot 風格的 bot,位於您的微服務平臺中,可以通過 Slack,HipChat,XMPP 等進行交互。它通過消息傳遞提供 CLI 的功能。可以添加其他命令來自動執行常見的操作任務。
image.png

CLI

一個直接的命令行界面來與你的微服務進行交互,它提供了一種觀察和與運行環境交互的方式。

Go-Micro 組件

用於在 Go 中編寫微服務的插件式 RPC 框架。它提供了用於服務發現,客戶端負載平衡,編碼,同步和異步通信庫。go-micro 是一個獨立的庫,可以獨立於其他工具包使用。
image.png
go-micro 是組件化的框架,每一個基礎功能都是一個 interface ,方便擴展。同時,組件又是分層的,上層基於下層功能向上提供服務,整體構成 go-micro 框架。go-micro框架的構成組件有:

Registry

提供服務發現機制:解析服務名字至服務地址。目前支持的註冊中心有 consul、etcd、 zookeeper、dns、gossip 等。

Selector

選擇器通過選擇提供負載均衡機制。當客戶端向服務器發出請求時,它將首先查詢服務的註冊表。這通常會返回一個表示服務的正在運行的節點列表。選擇器將選擇這些節點中的一個用於查詢。多次調用選擇器將允許使用平衡算法。目前的方法是循環法,隨機哈希和黑名單。

Broker

發佈和訂閱的可插入接口,服務之間基於消息中間件的異步通信方式,默認使用http方式,線上通常使用消息中間件,如 Nats、Kafka、RabbitMQ 和 http(用於開發)。

Transport

通過點對點傳輸消息的可插拔接口。目前的實現是 http,rabbitmq 和 nats 。通過提供這種抽象,運輸可以無縫地換出。

Codec

服務之間消息的編碼/解碼。

Plugins

提供 go-micro 的 micro/go-plugins 插件。

Server

服務器是構建正在運行的微服務的接口。它提供了一種提供 RPC 請求的方法。該組件基於上面的 Registry/Selector/Transport/Broker 組件,對外提供一個統一的服務請求入口。

Client

提供一種製作 RPC 查詢的方法訪問微服務的客戶端。它結合了註冊表,選擇器,代理和傳輸。它還提供重試,超時,使用上下文等。類似 Server 組件,它也是通過 Registry/Selector/Transport/Broker 組件實現查找服務、負載均衡、同步通信、異步消息等功能。

Nacos

Nacos 是一個更易於構建雲原生應用的動態服務發現、配置管理和服務管理的平臺,Nacos 脫胎於阿里巴巴內部的 ConfigServer 和 Diamond ,是它們的開源實現。經歷過雙十一流量峰值和阿里巴巴經濟體超大規模容量的考驗,沉澱了阿里巴巴軟負載團隊在這個領域十年的經驗,在穩定性和功能性上都有很好的保障。

Nacos 邏輯架構及其組件概覽圖:

image.png

快速開始

Go-Micro服務端

安裝 protoc

Protobuf 是 Protocol Buffers 的簡稱,它是 Google 公司開發的一種數據描述語言,並於 2008 年對外開源。Protobuf 剛開源時的定位類似於 XML、JSON 等數據描述語言,通過附帶工具生成代碼並實現將結構化數據序列化的功能。我們需要利用 protoc 生成服務端代碼。

image.png
安裝 Go-Micro/v2
image.png

新建 golang 項目(服務端)
1、在項目根目錄下創建 proto 文件夾,用來存放 protobuf 文件
2、在 proto 文件夾下創建 greeter.proto 文件
image.png
3、文件內容如下:
在服務端中使用 protobuf 文件定義了一個服務叫做 Greeter 的處理器,它有一個接收 HelloRequest 並返回 HelloResponse 的 Hello 方法。

image.png
4、生成相應的 Go 代碼
image.png

5、在 proto 目錄下,生成了 pb.go 以及 pb.micro.go 兩個文件
image.png

6、創建 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()

}

7、在 Nacos console 中可以看到 my.micro.service 成功註冊。
image.png

Go-Micro客戶端

1、創建 client.go (為了方便演示本文章在同一項目下創建了 cient.go)。

image.png

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
})
// 定義服務,可以傳入其它可選參數
service := micro.NewService(
    micro.Name("my.micro.service.client"),
    micro.Registry(r))
// 創建新的客戶端
greeter := helloworld.NewGreeterService(serverName, service.Client())
// 調用greeter
rsp, err := greeter.Hello(context.TODO(), &helloworld.HelloRequest{Name: "John"})
if err != nil {
    fmt.Println(err)
}
//獲取所有服務
fmt.Println(registry.ListServices())
//獲取某一個服務
services, err := registry.GetService(serverName)
if err != nil {
    fmt.Println(err)
}
//監聽服務
watch, err := registry.Watch()
fmt.Println(services)
// 打印響應請求
fmt.Println(rsp.Greeting)
go service.Run()
for {
    result, err := watch.Next()
    if len(result.Action) > 0 {
        fmt.Println(result, err)
    }
}

}

2、運行客戶端,在 nacos console 中可以看到客戶端服務也註冊到了 nacos 中。
image.png
3、server.go 的控制檯中打印了調用日誌。
image.png

Go-Micro集成Nacos 功能說明

server.go

服務端:使用 go-micro 創建服務端 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()

client.go

使用 go-micro 創建客戶端 Demo ,註冊到 nacos :

image.png
客戶端調用:

// 創建新的客戶端

greeter := helloworld.NewGreeterService(serverName, service.Client())
// 調用greeter
rsp, err := greeter.Hello(context.TODO(), &helloworld.HelloRequest{Name: "John"})

查詢服務列表:
image.png
獲取某一個服務:
image.png
訂閱服務:
image.png

總結

使用 Go-Micro 集成 Nacos 完成服務註冊與發現是比較簡單容易上手的,本項目中 client.go 使用的 nacos 客戶端是 go-mirco 提供的默認配置。go-micro 的 registry 接口自由度較高,我們可以利用 context 完成 nacos 客戶端參數的配置, 如何使用 context 設置 nacos 客戶端參數 可參考:

https://github.com/micro/go-plugins/blob/master/registry/nacos/nacos_test.go)

相關鏈接

Demo地址:
https://github.com/sanxun0325/go-micro-nacos-demo
Go-Micro:
https://github.com/asim/nitro
Nacos:
https://nacos.io/zh-cn/index.html
Nacos釘釘社區交流群:30438813, 23191211(Nacos golang生態交流群)
Nacos-SDK-Go項目地址:
https://github.com/nacos-group/nacos-sdk-go

作者介紹:

張斌斌,Github賬號:sanxun0325,Nacos Commiter,Sentinel-Golang Contributor,現任職OpenJaw微服務團隊。目前主要負責Nacos,Sentinel-Golang社區相關項目的開發工作,以及Nacos在Golang微服務生態中的推廣集成工作。

Leave a Reply

Your email address will not be published. Required fields are marked *