Go：使用 go-micro 构建微服务（二）

Freedom123

发布于 2024-03-29 14:35:03

4950

文章被收录于专栏：DevOpsDevOps

1. 什么是go micro#

1.1 go micro作用

它是一个可插入的RPC框架，用于在Go中编写微服务。开箱即用，您将收到：

服务发现: 应用程序自动注册到服务发现系统
负载平衡: 客户端负载平衡，用于平衡服务实例之间的请求
同步通信: 提供请求 / 响应传输层。
异步通信: 内置发布 / 订阅功能。
消息编码: 基于消息的内容类型头的编码 / 解码。
RPC 客户机/服务器包: 利用上述功能并公开接口来构建微服务

1.2 go micro架构组成#

Go 微体系结构可以描述为三层堆栈

顶层由客户端-服务器模型和服务抽象组成。

服务器: 用于编写服务的构建块
客户端: 提供了向服务请求的接口。

底层由以下类型的插件组成：

代理: 为异步发布/订阅通信提供消息代理的接口。
编解码器: 用于编码/解码消息。支持的格式包括 json，bson，protobuf，msgpack 等。
注册表: 提供服务发现机制(默认为 Consul)
选择器: 建立在注册表上的负载平衡抽象。它允许使用诸如随机，轮循，最小康等算法来 “选择” 服务。
传输 - 服务之间同步请求 / 响应通信的接口。

Go Micro还提供了Sidecar等功能。这使您可以使用Go以外的语言编写的服务 Sidecar提供服务注册，gRPC编码/解码和HTTP处理程序。它支持多种语言。

2. go micro入门#

最简单的用法大概如下，结合net/http标准库监听路由

package main

import (
	"github.com/micro/go-micro/web"
	"net/http"
)

func main() {

	server := web.NewService(web.Address(":8081")) // 路由
	server.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		w.Write([]byte("hello go micro"))
	})
	_ = server.Run()
}

也可以集成第三方web框架作为路由

gin

package main

import (
	"net/http"

	"github.com/gin-gonic/gin"
	"github.com/micro/go-micro/web"
)

func main() {
    // 使用gin作为路由
	r := gin.Default()
	r.GET("/user", func(c *gin.Context) {
		c.String(http.StatusOK, "user api")
	})

	server := web.NewService(
		web.Address(":8081"),                                // 端口
		web.Metadata(map[string]string{"protocol": "http"}), // 元信息
		web.Handler(r)) // 路由
		
	_ = server.Run()
}

3. 结合consul进行服务注册/发现#

微服务里最重要的关键一步就是服务注册，常用的有consul、etcd、zookeeper、eureka

我们这里使用consul

3.1 consul的安装#

这里直接使用docker安装

docker run -d --name=cs -p 8500:8500 consul agent -server -bootstrap -ui -client 0.0.0.0

然后再访问端口8500，如下现实安装成功

3.2 服务注册代码示例

github.com/micro/go-micro/registry/consul，上面这个在1.14.0版本之后删除了，要用这个github.com/micro/go-plugins/registry/consul，或者换成etcd作为注册中心

package main

import (
	"net/http"

	"github.com/gin-gonic/gin"
	"github.com/micro/go-micro/registry"
	"github.com/micro/go-micro/web"
	"github.com/micro/go-plugins/registry/consul"
)

func main() {
    // 添加consul地址
	cr := consul.NewRegistry(
		registry.Addrs("127.0.0.1:8500"))
    
    // 使用gin作为router
	router := gin.Default()
	router.GET("/user", func(c *gin.Context) {
		c.String(http.StatusOK, "user api")
	})
    
    // 初始化go micro
	server := web.NewService(
		web.Name("productService"),                          // 当前微服务服务名
		web.Registry(cr),                                    // 注册到consul
		web.Address(":8081"),                                // 端口
		web.Metadata(map[string]string{"protocol": "http"}), // 元信息
		web.Handler(router)) // 路由

	_ = server.Run()
}

把上述代码运行起来，再去consul界面查看，发现productService服务添加成功

3.3 服务发现代码示例

package main

import (
	"fmt"
	"log"

	"github.com/micro/go-micro/client/selector"
	"github.com/micro/go-micro/registry"
	"github.com/micro/go-plugins/registry/consul"
)

func main() {
	// 1.连接到consul
	cr := consul.NewRegistry(registry.Addrs("127.0.0.1:8500"))

	// 2.根据service name获取对应的微服务列表
	services, err := cr.GetService("productService")
	if err != nil {
		log.Fatal("cannot get service list")
	}

	// 3.使用random随机获取其中一个实例
	next := selector.Random(services)
	svc, err := next()
	if err != nil {
		log.Fatal("cannot get service")
	}

	fmt.Println("[测试输出]:", svc.Id, svc.Address, svc.Metadata)
}

然后使用goland先启动服务注册中的productService的微服务，再启动服务发现中的代码。服务发现将会输出如下，服务发现成功：