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

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

快速开始

Go-Micro服务端

安装 protoc

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 namemicro.Name("my.micro.service"),// Set service registrymicro.Registry(registry),
)
helloworld.RegisterGreeterHandler(service.Server(), new(Helloworld))
service.Run()

}

7、在 Nacos console 中可以看到 my.micro.service 成功注册。

Go-Micro客户端

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 的控制台中打印了调用日志。

Go-Micro集成Nacos 功能说明

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

client.go

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

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