作者 | 张斌斌

导读：本文主要介绍如何使用 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 namemicro.Name("my.micro.service"),// Set service registrymicro.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())// 调用greeterrsp, 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 namemicro.Name("my.micro.service"),// Set service registrymicro.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())// 调用greeterrsp, 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 等技术领域、聚焦云原生流行技术趋势、云原生大规模的落地实践，做最懂云原生开发者的公众号。”

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

微服务框架Go-Micro集成Nacos实战之服务注册与发现
简介:本文主要介绍如何使用 Golang 生态中的微服务框架 Go-Micro(v2) 集成 Nacos 进行服务注册与发现.(Go-Micro 目前已经是 v3 版本,但由于某些原因项目已经更名为 ...
分布式服务框架学习笔记2 常用的分布式服务框架与通信框架选择
传统垂直架构改造的核心就是要对应用进行服务化,服务化改造使用到的核心技术就是分布式服务框架. 分布式服务框架演进应用从集中式走向分布式大规模系统架构的设计一般原则就是尽可能地拆分,以达到更好的独立 ...
微前端框架qiankun之原理与实战
目录一.微前端概述 1. 基本原理 2. 微前端的主要优势 3. 当前微前端方案的一些缺点二.qiankun与single-spa实现原理 1. single-spa实现原理 (1). 路由问题 ...
微服务框架实施_规划和实施微服务的原则
微服务框架实施 Planning a microservices-based application - where to start from? This architecture is compo ...
白话微服务60秒：吴站长汉奸名册就是注册与发现!
主播:Elaine 今天是白话微服务第一季<服务通信> 第3集<注册与发现> 在传统方式下,当部署服务的多个节点时,一般使用静态配置的方式实现服务信息的设定. 在微服务应用中, ...
腾讯微服务框架-MSEC-部署 - 首个hello word服务
前言第一时间看到腾讯开源了毫秒服务引擎msec,就迫不及待想体验尝试一番,经过两天的折腾,总算是初步搭建好了,并成功输出了第一个hello word程序,搭建过程中遇到了各种编译问题,配置文件问题, ...
华为18级大牛倾情奉送：分布式服务框架和微服务设计原理实战文档，啃完发现涨薪如此简单
前言分布式服务框架不仅仅包含核心的运行时类库,还包括服务划分原则.服务化最佳实践.服务治理.服务监控.服务开发框架等,它是一套完整的解决方案,用来协助应用做服务化改造,以及指导用户如何构建适合自己业 ...
你值得拥有!-阿里P8架构师荣耀典藏：Java多线程与Socket实战微服务框架笔记
先赞再看,谢谢关注小编分享的这份<Java多线程与Socket:实战微服务框架>,综合运用Java多线程.Socket.动态代理等技术来构建微服务框架内容结构本书从实战角度出发,首先 ...
python的flask微服务-flask微服务框架的初步接触
测试2个关联的系统接口时,经常会遇到被测试系统或被测app的处理内部处理流程会依赖另一个系统的接口返回结果,这时, 常用的做法就是写一个模拟测试桩,用作返回请求时的结果.java可以用servicel ...

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

相关背景知识

1. Go-Micro

1）Micro 概述

2）Go-Micro 组件

2. Nacos