微服务框架 Go-Micro 集成 Nacos 实战之服务注册与发现

朴灿烈づ我的快乐病毒、 2022-12-20 01:57 162阅读 0赞

![1.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 并转发给相应的服务也可以用作反向代理。

![2.png][]

*  **Web**

UI 是 go-micro 的 web 版本，允许通过 UI 交互访问环境。在未来，它也将是一种聚合微型 Web 服务的方式。它包含一种 Web 应用程序的代理方式。将 /\[name\] 通过注册表路由到相应的服务。Web UI 将前缀“go.micro.web。”（可以配置）添加到名称中，在注册表中查找它，然后将进行反向代理。

![3.png][]

*  **Sidecar**

go-micro 的 HTTP 接口版本，这是将非 Go 应用程序集成到微环境中的一种方式。

![4.png][]

*  **Bot**

Hubot 风格的 bot，位于您的微服务平台中，可以通过 Slack，HipChat，XMPP 等进行交互。它通过消息传递提供 CLI 的功能。可以添加其他命令来自动执行常见的操作任务。

![5.png][]

*  **CLI**

一个直接的命令行界面来与你的微服务进行交互，它提供了一种观察和与运行环境交互的方式。

### 2）Go-Micro 组件 ###

用于在 Go 中编写微服务的插件式 RPC 框架。它提供了用于服务发现，客户端负载平衡，编码，同步和异步通信库。go-micro 是一个独立的库，可以独立于其他工具包使用。

![6.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 组件实现查找服务、负载均衡、同步通信、异步消息等功能。

## 2. Nacos ##

Nacos 是一个更易于构建云原生应用的动态服务发现、配置管理和服务管理的平台，Nacos 脱胎于阿里巴巴内部的 ConfigServer 和 Diamond ，是它们的开源实现。经历过双十一流量峰值和阿里巴巴经济体超大规模容量的考验，沉淀了阿里巴巴软负载团队在这个领域十年的经验，在稳定性和功能性上都有很好的保障。

Nacos 逻辑架构及其组件概览图：

![7.png][]

# 快速开始 #

## 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 文件

![8.png][]

*  文件内容如下：

在服务端中使用 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 两个文件

![9.png][]

*  创建 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 成功注册

![10.png][]

## 2. Go-Micro 客户端 ##

*  创建 client.go （为了方便演示，本文在同一项目下创建了 cient.go）。

![11.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)
            }
        }
    }

*  运行客户端，在 nacos console 中可以看到客户端服务也注册到了 nacos 中。

![12.png][]

*  server.go 的控制台中打印了调用日志。

![13.png][]

## 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-][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][https_github.com_asim_nitro]
 *  **Nacos**: [https://nacos.io/zh-cn/index.html][https_nacos.io_zh-cn_index.html]
 *  **Nacos 钉钉社区交流群**：30438813, 23191211(Nacos golang 生态交流群)
 *  **Nacos-SDK-Go 项目地址**：[https://github.com/nacos-group/nacos-sdk-go][https_github.com_nacos-group_nacos-sdk-go]

## 作者简介 ##

**张斌斌**（Github账号：sanxun0325）Nacos Commiter，Sentinel-Golang Contributor，现任职 OpenJaw 微服务团队。目前主要负责 Nacos，Sentinel-Golang 社区相关项目的开发工作，以及 Nacos在Golang 微服务生态中的推广集成工作。

> “[阿里巴巴云原生][Link 1]关注微服务、Serverless、容器、Service Mesh 等技术领域、聚焦云原生流行技术趋势、云原生大规模的落地实践，做最懂云原生开发者的公众号。”

[1.png]: /images/20221120/1bf6b781f1104c0ebc653156c4bd2b55.png
[2.png]: /images/20221120/e3b17742b9b74357b4e73df88efee3f1.png
[3.png]: /images/20221120/8a4decba183147c3865f6b2ecb0a4dab.png
[4.png]: /images/20221120/d8e0656336e843f582400cd135487faa.png
[5.png]: https://img-blog.csdnimg.cn/img_convert/01379bdc579560654c0cdc7408ed7410.png
[6.png]: https://img-blog.csdnimg.cn/img_convert/eb04f0e1e0cc0eb2d107af63befbd89f.png
[7.png]: https://img-blog.csdnimg.cn/img_convert/322e890ff93bb7a4d5adcdd80f266ed5.png
[8.png]: https://img-blog.csdnimg.cn/img_convert/72f905078daac369edbea401c5e2eb33.png
[9.png]: https://img-blog.csdnimg.cn/img_convert/13f86b743a3db35e2f28113e561b1038.png
[10.png]: https://img-blog.csdnimg.cn/img_convert/45b5d4f3cc57a39e4750af5f3d19a755.png
[11.png]: https://img-blog.csdnimg.cn/img_convert/0fc374a5432e03757df6867ca75c2929.png
[12.png]: https://img-blog.csdnimg.cn/img_convert/745bfd65ec0bc4aa75a3cf459acef690.png
[13.png]: https://img-blog.csdnimg.cn/img_convert/c6357664e882604dbbe4b4daa88c9d65.png
[https_github.com_micro_go-]: https://github.com/micro/go-
[https_github.com_asim_nitro]: https://github.com/asim/nitro
[https_nacos.io_zh-cn_index.html]: https://nacos.io/zh-cn/index.html
[https_github.com_nacos-group_nacos-sdk-go]: https://github.com/nacos-group/nacos-sdk-go
[Link 1]: http://mp.weixin.qq.com/s?__biz=MzUzNzYxNjAzMg==&mid=2247495998&idx=2&sn=bf06b9fce41924049c42f27c55d306c5&chksm=fae6faf1cd9173e7000ad2686a35702d71a6828ed94f9432444743443babf9dcfded1c59ab75&token=1794504628&lang=zh_CN#rd