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

本文轉載自查看原文 2020-11-09 14:29 753 雲原生/ 微服務/ 開源

作者 | 張斌斌

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

快速開始

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)

作者簡介

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

“阿里巴巴雲原生關注微服務、Serverless、容器、Service Mesh 等技術領域、聚焦雲原生流行技術趨勢、雲原生大規模的落地實踐，做最懂雲原生開發者的公眾號。”

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 go微服務框架go-micro深度學習(三) Registry服務的注冊和發現 go-micro registry 服務的注冊和發現 go-micro微服務框架微服務框架go-micro 微服務學習--micro和go-micro 微服務學習（三）--micro和go-micro golang微服務框架go-micro 入門筆記2.4 go-micro service解讀 go微服務框架go-micro深度學習-目錄 golang微服務框架go-micro 入門筆記1.搭建 go-micro環境微服務框架---搭建 go-micro環境

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

相關背景知識

1. Go-Micro

1）Micro 概述

2）Go-Micro 組件

2. Nacos