作者?| 張斌斌

導(dǎo)讀：本文主要介紹如何使用 Golang 生態(tài)中的微服務(wù)框架 Go-Micro(v2) 集成 Nacos 進行服務(wù)注冊與發(fā)現(xiàn)。(Go-Micro 目前已經(jīng)是 v3 版本，但由于某些原因項目已經(jīng)更名為 nitro 具體原因大家可以去 github 中查看。)

相關(guān)背景知識

1. Go-Micro

Go Micro 是一個基于 Go 語言編寫的、用于構(gòu)建微服務(wù)的基礎(chǔ)框架，提供了分布式開發(fā)所需的核心組件，包括 RPC 和事件驅(qū)動通信等。

它的設(shè)計哲學(xué)是「可插拔」的插件化架構(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)上層組件的替換。

1）Micro 概述

Micro 是一個微服務(wù)工具包，包括：

• API

提供并將 HTTP 請求路由到相應(yīng)微服務(wù)的 API 網(wǎng)關(guān)。它充當(dāng)微服務(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。”（可以配置）添加到名稱中，在注冊表中查找它，然后將進行反向代理。

• Sidecar

go-micro 的 HTTP 接口版本，這是將非 Go 應(yīng)用程序集成到微環(huán)境中的一種方式。

• Bot

Hubot 風(fēng)格的 bot，位于您的微服務(wù)平臺中，可以通過 Slack，HipChat，XMPP 等進行交互。它通過消息傳遞提供 CLI 的功能。可以添加其他命令來自動執(zhí)行常見的操作任務(wù)。

• CLI

一個直接的命令行界面來與你的微服務(wù)進行交互，它提供了一種觀察和與運行環(huán)境交互的方式。

2）Go-Micro 組件

用于在 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

選擇器通過選擇提供負載均衡機制。當(dāng)客戶端向服務(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ù)、負載均衡、同步通信、異步消息等功能。

2. Nacos

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)及其組件概覽圖：

快速開始

1. Go-Micro 服務(wù)端

1）安裝 protoc

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

2）安裝 Go-Micro/v2

go install github.com/micro/micro/v2

3）新建 golang 項目(服務(wù)端)

• 在項目根目錄下創(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 namemicro.Name("my.micro.service"),// Set service registrymicro.Registry(registry),)helloworld.RegisterGreeterHandler(service.Server(), new(Helloworld))service.Run() }

• 在 Nacos console 中可以看到 my.micro.service 成功注冊

2. Go-Micro 客戶端

• 創(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)用greeterrsp, 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)用日志。

3. Go-Micro 集成 Nacos 功能說明

1）server.go

服務(wù)端:使用 go-micro 創(chuàng)建服務(wù)端 Demo，并注冊到 nacos 。

registry := nacos.NewRegistry(func(options *registry.Options) {options.Addrs = addrs})service := micro.NewService(// Set service namemicro.Name("my.micro.service"),// Set service registrymicro.Registry(registry),)service.Run()

2）client.go

使用 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)用greeterrsp, 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)}}

總結(jié)

使用 Go-Micro 集成 Nacos 完成服務(wù)注冊與發(fā)現(xiàn)是比較簡單容易上手的，本項目中 client.go 使用的 nacos 客戶端是 go-mirco 提供的默認配置。

go-micro 的 registry 接口自由度較高，我們可以利用 context 完成 nacos 客戶端參數(shù)的配置, 如何使用 context 設(shè)置 nacos 客戶端參數(shù)可參考:https://github.com/micro/go-plugins/blob/master/registry/nacos/nacos_test.go)

相關(guān)鏈接

• 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 釘釘社區(qū)交流群：30438813, 23191211(Nacos golang 生態(tài)交流群)
• Nacos-SDK-Go 項目地址：https://github.com/nacos-group/nacos-sdk-go

作者簡介

張斌斌（Github賬號：sanxun0325）Nacos Commiter，Sentinel-Golang Contributor，現(xiàn)任職 OpenJaw 微服務(wù)團隊。目前主要負責(zé) Nacos，Sentinel-Golang 社區(qū)相關(guān)項目的開發(fā)工作，以及 Nacos在Golang 微服務(wù)生態(tài)中的推廣集成工作。

“阿里巴巴云原生關(guān)注微服務(wù)、Serverless、容器、Service Mesh 等技術(shù)領(lǐng)域、聚焦云原生流行技術(shù)趨勢、云原生大規(guī)模的落地實踐，做最懂云原生開發(fā)者的公眾號。”

總結(jié)

以上是生活随笔為你收集整理的微服务框架 Go-Micro 集成 Nacos 实战之服务注册与发现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。