![](https://img.laitimes.com/img/__Qf2AjLwojIjJCLyojI0JCLicmbw5CO3ETZhV2N4EzN2czNwgTO0EmZ0MmNyUmM2MWYhRTM18CX5d2bs92Yl1iclB3bsVmdlR2LcNWaw9CXt92Yu4GZjlGbh5yYjV3Lc9CX6MHc0RHaiojIsJye.png)
作者 | 張斌斌
導讀:本文主要介紹如何使用 Golang 生态中的微服務架構 Go-Micro(v2) 內建 Nacos 進行服務注冊與發現。(Go-Micro 目前已經是 v3 版本,但由于某些原因項目已經更名為 nitro 具體原因大家可以去 github 中檢視。)
相關背景知識
1. Go-Micro
Go Micro 是一個基于 Go 語言編寫的、用于建構微服務的基礎架構,提供了分布式開發所需的核心元件,包括 RPC 和事件驅動通信等。
它的設計哲學是「可插拔」的插件化架構,其核心專注于提供底層的接口定義和基礎工具,這些底層接口可以相容各種實作。例如 Go Micro 預設通過 consul 進行服務發現,通過 HTTP 協定進行通信,通過 protobuf 和 json 進行編解碼,以便你可以基于這些開箱提供的元件快速啟動,但是如果需要的話,你也可以通過符合底層接口定義的其他元件替換預設元件,比如通過 nacos, etcd 或 zookeeper 進行服務發現,這也是插件化架構的優勢所在:不需要修改任何底層代碼即可實作上層元件的替換。
1)Micro 概述
Micro 是一個微服務工具包,包括:
- API
提供并将 HTTP 請求路由到相應微服務的 API 網關。它充當微服務通路的單一入口,将 HTTP 請求轉換為 RPC 并轉發給相應的服務也可以用作反向代理。
- Web
UI 是 go-micro 的 web 版本,允許通過 UI 互動通路環境。在未來,它也将是一種聚合微型 Web 服務的方式。它包含一種 Web 應用程式的代理方式。将 /[name] 通過系統資料庫路由到相應的服務。Web UI 将字首“go.micro.web。”(可以配置)添加到名稱中,在系統資料庫中查找它,然後将進行反向代理。
- Sidecar
go-micro 的 HTTP 接口版本,這是将非 Go 應用程式內建到微環境中的一種方式。
- Bot
Hubot 風格的 bot,位于您的微服務平台中,可以通過 Slack,HipChat,XMPP 等進行互動。它通過消息傳遞提供 CLI 的功能。可以添加其他指令來自動執行常見的操作任務。
- CLI
一個直接的指令行界面來與你的微服務進行互動,它提供了一種觀察和與運作環境互動的方式。
2)Go-Micro 元件
用于在 Go 中編寫微服務的插件式 RPC 架構。它提供了用于服務發現,用戶端負載平衡,編碼,同步和異步通信庫。go-micro 是一個獨立的庫,可以獨立于其他工具包使用。
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 元件實作查找服務、負載均衡、同步通信、異步消息等功能。
2. Nacos
Nacos 是一個更易于建構雲原生應用的動态服務發現、配置管理和服務管理的平台,Nacos 脫胎于阿裡巴巴内部的 ConfigServer 和 Diamond ,是它們的開源實作。經曆過雙十一流量峰值和阿裡巴巴經濟體超大規模容量的考驗,沉澱了阿裡巴巴軟負載團隊在這個領域十年的經驗,在穩定性和功能性上都有很好的保障。
Nacos 邏輯架構及其元件概覽圖:
快速開始
1. Go-Micro 服務端
1)安裝 protoc
Protobuf 是 Protocol Buffers 的簡稱,它是 Google 公司開發的一種資料描述語言,并于 2008 年對外開源。Protobuf 剛開源時的定位類似于 XML、JSON 等資料描述語言,通過附帶工具生成代碼并實作将結構化資料序列化的功能。我們需要利用 protoc 生成服務端代碼。
o get github.com/golang/protobuf/protoc-gen-go
2)安裝 Go-Micro/v2
go install github.com/micro/micro/v2
3)建立 golang 項目(服務端)
- 在項目根目錄下建立 proto 檔案夾,用來存放 protobuf 檔案
- 在 proto 檔案夾下建立 greeter.proto 檔案
- 檔案内容如下:
在服務端中使用 protobuf 檔案定義了一個服務叫做 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;
}
- 生成相應的 Go 代碼
protoc --micro_out=. --go_out=. proto/greeter.proto
- 在 proto 目錄下,生成了 pb.go 以及 pb.micro.go 兩個檔案
- 建立 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 成功注冊
2. Go-Micro 用戶端
- 建立 client.go (為了友善示範,本文在同一項目下建立了 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
})
// 定義服務,可以傳入其它可選參數
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)
}
}
}
- 運作用戶端,在 nacos console 中可以看到用戶端服務也注冊到了 nacos 中。
- server.go 的控制台中列印了調用日志。
3. Go-Micro 內建 Nacos 功能說明
1)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()
2)client.go
使用 go-micro 建立用戶端 Demo ,注冊到 nacos :
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"})
查詢服務清單:
services,err:=registry.ListServices()
擷取某一個服務:
service, err := registry.GetService(serverName)
訂閱服務:
watch, err := registry.Watch()
for {
result, err := watch.Next()
if len(result.Action) > 0 {
fmt.Println(result, err)
}
}
總結
使用 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](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 微服務生态中的推廣內建工作。
“ 阿裡巴巴雲原生 關注微服務、Serverless、容器、Service Mesh 等技術領域、聚焦雲原生流行技術趨勢、雲原生大規模的落地實踐,做最懂雲原生開發者的公衆号。”