关于coffeescript:微服务框架GoMicro集成Nacos实战之服务注册与发现

简介： 本文次要介绍如何应用 Golang 生态中的微服务框架 Go-Micro(v2) 集成 Nacos 进行服务注册与发现。(Go-Micro 目前曾经是 v3 版本，但因为某些起因我的项目曾经更名为 nitro 具体起因大家能够去 github 中查看)

Go Micro 是一个基于 Go 语言编写的、用于构建微服务的根底框架，提供了分布式开发所需的外围组件，包含 RPC 和事件驱动通信等。

它的设计哲学是「可插拔」的插件化架构，其外围专一于提供底层的接口定义和根底工具，这些底层接口能够兼容各种实现。例如 Go Micro 默认通过 consul 进行服务发现，通过 HTTP 协定进行通信，通过 protobuf 和 json 进行编解码，以便你能够基于这些开箱提供的组件疾速启动，然而如果需要的话，你也能够通过合乎底层接口定义的其余组件替换默认组件，比方通过 nacos, etcd 或 zookeeper 进行服务发现，这也是插件化架构的劣势所在：不须要批改任何底层代码即可实现下层组件的替换。

Micro 是一个微服务工具包，包含：

提供并将 HTTP 申请路由到相应微服务的 API 网关。它充当微服务拜访的繁多入口，将 HTTP 申请转换为 RPC 并转发给相应的服务也能够用作反向代理。

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

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

Hubot 格调的 bot，位于您的微服务平台中，能够通过 Slack，HipChat，XMPP 等进行交互。它通过消息传递提供 CLI 的性能。能够增加其余命令来主动执行常见的操作工作。

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

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

go-micro 是组件化的框架，每一个根底性能都是一个 interface，不便扩大。同时，组件又是分层的，下层基于上层性能向上提供服务，整体形成 go-micro 框架。go-micro 框架的形成组件有：

提供服务发现机制：解析服务名字至服务地址。目前反对的注册核心有 consul、etcd、zookeeper、dns、gossip 等。

选择器通过抉择提供负载平衡机制。当客户端向服务器发出请求时，它将首先查问服务的注册表。这通常会返回一个示意服务的正在运行的节点列表。选择器将抉择这些节点中的一个用于查问。屡次调用选择器将容许应用均衡算法。目前的办法是循环法，随机哈希和黑名单。

公布和订阅的可插入接口，服务之间基于消息中间件的异步通信形式，默认应用 http 形式，线上通常应用消息中间件，如 Nats、Kafka、RabbitMQ 和 http（用于开发）。

通过点对点传输音讯的可插拔接口。目前的实现是 http，rabbitmq 和 nats。通过提供这种形象，运输能够无缝地换出。

服务之间音讯的编码 / 解码。

提供 go-micro 的 micro/go-plugins 插件。

服务器是构建正在运行的微服务的接口。它提供了一种提供 RPC 申请的办法。该组件基于下面的 Registry/Selector/Transport/Broker 组件，对外提供一个对立的服务申请入口。

提供一种制作 RPC 查问的办法拜访微服务的客户端。它联合了注册表，选择器，代理和传输。它还提供重试，超时，应用上下文等。相似 Server 组件，它也是通过 Registry/Selector/Transport/Broker 组件实现查找服务、负载平衡、同步通信、异步音讯等性能。

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

Protobuf 是 Protocol Buffers 的简称，它是 Google 公司开发的一种数据描述语言，并于 2008 年对外开源。Protobuf 刚开源时的定位相似于 XML、JSON 等数据描述语言，通过附带工具生成代码并实现将结构化数据序列化的性能。咱们须要利用 protoc 生成服务端代码。

装置 Go-Micro/v2

新建 golang 我的项目 (服务端)
1、在我的项目根目录下创立 proto 文件夹，用来寄存 protobuf 文件
2、在 proto 文件夹下创立 greeter.proto 文件

3、文件内容如下：
在服务端中应用 protobuf 文件定义了一个服务叫做 Greeter 的处理器, 它有一个接管 HelloRequest 并返回 HelloResponse 的 Hello 办法。

4、生成相应的 Go 代码

5、在 proto 目录下，生成了 pb.go 以及 pb.micro.go 两个文件

6、创立 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()

}

7、在 Nacos console 中能够看到 my.micro.service 胜利注册。

1、创立 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)
    }
}

}

2、运行客户端，在 nacos console 中能够看到客户端服务也注册到了 nacos 中。

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

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()

应用 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 客户端参数可参考:

原文链接
本文为阿里云原创内容，未经容许不得转载。

关于coffeescript:微服务框架GoMicro集成Nacos实战之服务注册与发现

相干背景常识

Go-Micro

Go-Micro 概述

API

Web

Sidecar

Bot

CLI

Go-Micro 组件

Registry

Selector

Broker

Transport

Codec

Plugins

Server

Client

Nacos

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

疾速开始

Go-Micro 服务端

装置 protoc

Go-Micro 客户端

Go-Micro 集成 Nacos 性能阐明

client.go

总结