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

快速開始

Go-Micro服務端

安裝 protoc

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

安裝 Go-Micro/v2

新建 golang 項目(服務端)
一、在項目根目錄下建立 proto 文件夾，用來存放 protobuf 文件
二、在 proto 文件夾下建立 greeter.proto 文件

三、文件內容以下：
在服務端中使用 protobuf 文件定義了一個服務叫作 Greeter 的處理器,它有一個接收 HelloRequest 並返回 HelloResponse 的 Hello 方法。

四、生成相應的 Go 代碼

五、在 proto 目錄下，生成了 pb.go 以及 pb.micro.go 兩個文件

六、建立 server.go 並運行

package main
import (
"context" helloworld "go-micro-nacos-demo1/proto" " http://github.com/micro/go-micro/v2" " http://github.com/micro/go-micro/v2/logger" " http://github.com/micro/go-micro/v2/registry" nacos " http://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 成功註冊。

Go-Micro客戶端

一、建立 client.go （爲了方便演示本文章在同一項目下建立了 cient.go）。

package main
import (
"context" "fmt" helloworld "go-micro-nacos-demo1/proto" " http://github.com/micro/go-micro/v2" " http://github.com/micro/go-micro/v2/registry" nacos " http://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 的控制檯中打印了調用日誌。

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 :

客戶端調用：

// 建立新的客戶端
greeter := helloworld.NewGreeterService(serverName, service.Client()) // 調用greeter rsp, err := greeter.Hello(context.TODO(), &helloworld.HelloRequest{Name: "John"})

查詢服務列表：

獲取某一個服務：

訂閱服務：

總結

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

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

原文連接

本文爲阿里雲原創內容，未經容許不得轉載。

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

相關背景知識

快速開始

總結