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

本文涉及的产品
云原生网关 MSE Higress,422元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,118元/月
简介: 本文主要介绍如何使用 Golang 生态中的微服务框架 Go-Micro(v2) 集成 Nacos 进行服务注册与发现。(Go-Micro 目前已经是 v3 版本,但由于某些原因项目已经更名为 nitro 具体原因大家可以去 github 中查看)

相关背景知识

Go-Micro

Go Micro 是一个基于 Go 语言编写的、用于构建微服务的基础框架,提供了分布式开发所需的核心组件,包括 RPC 和事件驱动通信等。

它的设计哲学是「可插拔」的插件化架构,其核心专注于提供底层的接口定义和基础工具,这些底层接口可以兼容各种实现。例如 Go Micro 默认通过 consul 进行服务发现,通过 HTTP 协议进行通信,通过 protobuf 和 json 进行编解码,以便你可以基于这些开箱提供的组件快速启动,但是如果需要的话,你也可以通过符合底层接口定义的其他组件替换默认组件,比如通过 nacos, etcd 或 zookeeper 进行服务发现,这也是插件化架构的优势所在:不需要修改任何底层代码即可实现上层组件的替换。

Go-Micro概述

Micro是一个微服务工具包,包括:

API

提供并将 HTTP 请求路由到相应微服务的 API 网关。它充当微服务访问的单一入口,将HTTP 请求转换为 RPC 并转发给相应的服务也可以用作反向代理。

image.png

Web

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

Sidecar

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

Bot

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

CLI

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

Go-Micro 组件

用于在 Go 中编写微服务的插件式 RPC 框架。它提供了用于服务发现,客户端负载平衡,编码,同步和异步通信库。go-micro 是一个独立的库,可以独立于其他工具包使用。
image.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 组件实现查找服务、负载均衡、同步通信、异步消息等功能。

Nacos

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

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

image.png

快速开始

Go-Micro服务端

安装 protoc

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

image.png
安装 Go-Micro/v2
image.png

新建 golang 项目(服务端)
1、在项目根目录下创建 proto 文件夹,用来存放 protobuf 文件
2、在 proto 文件夹下创建 greeter.proto 文件
image.png
3、文件内容如下:
在服务端中使用 protobuf 文件定义了一个服务叫做 Greeter 的处理器,它有一个接收 HelloRequest 并返回 HelloResponse 的 Hello 方法。

image.png
4、生成相应的 Go 代码
image.png

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

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 成功注册。
image.png

Go-Micro客户端

1、创建 client.go (为了方便演示本文章在同一项目下创建了 cient.go)。

image.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)
    }
}

}

2、运行客户端,在 nacos console 中可以看到客户端服务也注册到了 nacos 中。
image.png
3、server.go 的控制台中打印了调用日志。
image.png

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 :

image.png
客户端调用:

// 创建新的客户端

greeter := helloworld.NewGreeterService(serverName, service.Client())
// 调用greeter
rsp, err := greeter.Hello(context.TODO(), &helloworld.HelloRequest{Name: "John"})

查询服务列表:
image.png
获取某一个服务:
image.png
订阅服务:
image.png

总结

使用 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)

相关链接

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钉钉社区交流群:30438813, 23191211(Nacos golang生态交流群)
Nacos-SDK-Go项目地址:
https://github.com/nacos-group/nacos-sdk-go

作者介绍:

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

【更多精彩】

1.中间件爆款一折起,还有阿里巴巴十年最佳实践深度解密,点击马上了解https://www.aliyun.com/activity/daily/commercial?spm=5176.20960838.0.0.6a54305etoEn4D

2.【填问卷领淘公仔】点击马上填写问卷:
https://survey.aliyun.com/apps/zhiliao/YmW95Gk8bU

【加入行业实战交流钉钉群】

阿里云专门成立了“互联网架构升级实战课”钉钉群,每周邀请一位阿里云专家在群内进行行业最佳实践直播,每天分享行业前沿干货,钉钉扫码马上加入。
image.png

相关文章
|
1月前
|
Dubbo Java 应用服务中间件
微服务框架Dubbo环境部署实战
微服务框架Dubbo环境部署的实战指南,涵盖了Dubbo的概述、服务部署、以及Dubbo web管理页面的部署,旨在指导读者如何搭建和使用Dubbo框架。
106 17
微服务框架Dubbo环境部署实战
|
15天前
|
JSON Go API
使用Go语言和Gin框架构建RESTful API:GET与POST请求示例
使用Go语言和Gin框架构建RESTful API:GET与POST请求示例
|
15天前
|
Kubernetes Go 持续交付
一个基于Go程序的持续集成/持续部署(CI/CD)
本教程通过一个简单的Go程序示例,展示了如何使用GitHub Actions实现从代码提交到Kubernetes部署的CI/CD流程。首先创建并版本控制Go项目,接着编写Dockerfile构建镜像,再配置CI/CD流程自动化构建、推送Docker镜像及部署应用。此流程基于GitHub仓库,适用于快速迭代开发。
32 3
|
15天前
|
Kubernetes 持续交付 Go
创建一个基于Go程序的持续集成/持续部署(CI/CD)流水线
创建一个基于Go程序的持续集成/持续部署(CI/CD)流水线
|
18天前
|
Kubernetes Nacos 容器
nacos注册不上
我正在使用开源的Nacos,并已在Kubernetes中部署了Nacos服务,通过端口映射可在集群外访问Nacos控制台。Kubernetes使用NodePort类型暴露了8848、9848、9849、7848和9555端口,但在尝试注册时遇到问题,出现“Client not connected, current status: STARTING”的错误,导致启动失败。
|
23天前
|
Kubernetes Java Android开发
用 Quarkus 框架优化 Java 微服务架构的设计与实现
Quarkus 是专为 GraalVM 和 OpenJDK HotSpot 设计的 Kubernetes Native Java 框架,提供快速启动、低内存占用及高效开发体验,显著优化了 Java 在微服务架构中的表现。它采用提前编译和懒加载技术实现毫秒级启动,通过优化类加载机制降低内存消耗,并支持多种技术和框架集成,如 Kubernetes、Docker 及 Eclipse MicroProfile,助力开发者轻松构建强大微服务应用。例如,在电商场景中,可利用 Quarkus 快速搭建商品管理和订单管理等微服务,提升系统响应速度与稳定性。
36 5
|
1月前
|
存储 Java Maven
从零到微服务专家:用Micronaut框架轻松构建未来架构
【9月更文挑战第5天】在现代软件开发中,微服务架构因提升应用的可伸缩性和灵活性而广受欢迎。Micronaut 是一个轻量级的 Java 框架,适合构建微服务。本文介绍如何从零开始使用 Micronaut 搭建微服务架构,包括设置开发环境、创建 Maven 项目并添加 Micronaut 依赖,编写主类启动应用,以及添加控制器处理 HTTP 请求。通过示例代码展示如何实现简单的 “Hello, World!” 功能,并介绍如何通过添加更多依赖来扩展应用功能,如数据访问、验证和安全性等。Micronaut 的强大和灵活性使你能够快速构建复杂的微服务系统。
64 5
|
1月前
|
缓存 Java 应用服务中间件
随着微服务架构的兴起,Spring Boot凭借其快速开发和易部署的特点,成为构建RESTful API的首选框架
【9月更文挑战第6天】随着微服务架构的兴起,Spring Boot凭借其快速开发和易部署的特点,成为构建RESTful API的首选框架。Nginx作为高性能的HTTP反向代理服务器,常用于前端负载均衡,提升应用的可用性和响应速度。本文详细介绍如何通过合理配置实现Spring Boot与Nginx的高效协同工作,包括负载均衡策略、静态资源缓存、数据压缩传输及Spring Boot内部优化(如线程池配置、缓存策略等)。通过这些方法,开发者可以显著提升系统的整体性能,打造高性能、高可用的Web应用。
59 2
|
1月前
|
Cloud Native 安全 Java
Micronaut对决Spring Boot:谁是微服务领域的王者?揭秘两者优劣,选对框架至关重要!
【9月更文挑战第5天】近年来,微服务架构备受关注,Micronaut和Spring Boot成为热门选择。Micronaut由OCI开发,基于注解的依赖注入,内置多种特性,轻量级且启动迅速;Spring Boot则简化了Spring应用开发,拥有丰富的生态支持。选择框架需考虑项目需求、团队经验、性能要求及社区支持等因素。希望本文能帮助您选择合适的微服务框架,助力您的软件开发项目取得成功!
110 2
|
2月前
|
消息中间件 Java 网络架构
AMQP与微服务架构的集成策略
【8月更文第28天】在微服务架构中,各个服务通常通过HTTP/REST、gRPC等协议进行交互。虽然这些方法在很多场景下工作得很好,但在需要高并发、低延迟或需要处理大量消息的情况下,传统的同步调用方式可能无法满足需求。此时,AMQP作为异步通信的一种标准协议,可以提供一种更为灵活和高效的消息传递机制。
27 1