脚本之家，脚本语言编程技术及教程分享平台！
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - Golang使用Consul详解

Golang使用Consul详解

2022-10-19 12:07Small-K Golang

Consul是一个服务发现软件, 提供了服务发现\键值存储\健康检查等功能，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

常用指令

agent指令

  • -bind=0.0.0.0 指定consul所在机器的ip地址
  • -http-port 指定web接口服务端口
  • -client 指定哪些机器可以访问consul, 0.0.0.0表示所有机器
  • -data-dir=path 指定服务数据文件存储位置
  • -dev 开发者模式，直接以默认模式启动consul
  • -node=hostname 服务发现的名字
  • -rejoin consul启动的时候，加入到的consul集群
  • -server 以服务方式开启server， 允许其他的consul连接到开启的consul上，不加则以客户端方式开启
  • -ui 可以谁用web页面来查看服务发现的详情
  • -config-dir 配置文件地址， 如果是文件夹会将所有文件合并，里面可以配置自己所在节点提供的服务
  • -bootstrap-expect 在一个集群中期望提供的server节点数目，当该值提供时， consul一直等到达到指定的server数目才会参加选举，推举自己为leader。这个可以避免不一致和脑裂现象

启动

consul agent -server -bootstrap-expect 1 -ui -rejoin -http-port=8080 -bind="127.0.0.1" -data-dir C:\Windows\tmp

members

查看集群中有多少成员

info

查看当前系欸但信息

leave

优雅关闭consul

reload

重新加载配置文件

常用功能

Consul最重要的的功能就是定义服务, 服务管理和健康检查

定义服务

要定义一个服务, 有两种方式:

  • 通过写配置文件, 让Consul读取
  • 通过接口向Consul服务进行注册

一般我们采用第二种方式, 但我们可以通过第一种方式的书写规则来了解服务定义的一些选项

我们可以通过启动时指定-config-dir来指定配置文件所在位置, 配置文件时json格式, 有多个会合并在一起

例子:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
{
    "service": {
        "name": "redis", // 在consul面板上显示的服务名
        "id": "redis", // 服务id, 一般通过服务id对服务进行管理, 若不指定则会使用name作为id
        "address": "127.0.0.1", // 服务地址
        "port": 80, // 服务运行的端口
        "tags": [
            "primary"
        ], // 服务的标签, 可以作为服务的额外信息
        //   服务健康检查, 后面介绍
        "checks": [
            {
                "args": [
                    "/bin/check_redis",
                    "-p",
                    "7000"
                ],
                "interval": "30s",
                "timeout" : "60s"
            }
        ]
    }
}

服务管理

所谓服务管理就是指服务发现\服务注册\服务注销

consul服务端均提供了相应的http\dns等方式的接口可以方便地操作,

一般我们用go是用官方提供的一个api库进行操作, 对这些http的接口就不再过多赘述, 可以查阅官方文档

Consul API

服务健康检查

健康检查是为了避免服务突然宕机而调用方不知道的情况发生, 原理就是隔一段时间通信一次

consul提供了 tcp\ssl\ttl\udp\script\http等多种方式来进行健康检查,可以在服务注册时指定健康检查的方式

consul根据interval变量来决定多少时间间隔来通讯

根据timeout变量来决定发送请求后多久未收到回应算作失败

这里我们介绍三种, http|tcp|script方式

http方式

?
1
2
3
4
5
6
7
8
9
10
11
12
{
  "check": {
    "id": "api",
    "name": "HTTP API on port 5000",
    "http": "https://localhost:5000/health",   //调用接口
    "method": "POST",            
    "header": { "Content-Type": ["application/json"] },
    "body": "{\"method\":\"health\"}",
    "interval": "10s",   //
    "timeout": "1s"
  }
}

tcp方式

?
1
2
3
4
5
6
7
8
9
{
  "check": {
    "id": "ssh",
    "name": "SSH TCP on port 22",
    "tcp": "localhost:22",
    "interval": "10s",
    "timeout": "1s"
  }
}

script脚本方式

脚本方式略有不同,原理是通过调用脚本,查看脚本的返回值来判断健康检查是否通过

脚本退出代码为 0 : 通过健康检查

1 : 警告 其他: 健康检查失败

?
1
2
3
4
5
6
7
8
9
{
  "check": {
    "id": "mem-util",
    "name": "Memory utilization",
    "args": ["/usr/local/bin/check_mem.py", "-limit", "256MB"],  // 会被拼成 /usr/local/bin/check_mem.py -limit 256MB 来进行调用
    "interval": "10s",
    "timeout": "1s"
  }
}

grpc方式

检查grpc整个server状态

?
1
2
3
4
5
6
7
8
9
{
  "check": {
    "id": "mem-util",
    "name": "Service health status",
    "grpc": "127.0.0.1:12345",
    "grpc_use_tls": true,      //是否使用tls, 默认不使用
    "interval": "10s"
  }
}

只检查服务器上的某一个服务

?
1
2
3
4
5
6
7
8
9
{
  "check": {
    "id": "mem-util",
    "name": "Service health status",
    "grpc": "127.0.0.1:12345/my_service",
    "grpc_use_tls": true,
    "interval": "10s"
  }
}

go使用官方api包来定义服务\查询服务

console的github官网提供了一个go包操作consul服务端的实现, 我们可以使用这个包来实现服务发现

那么编写一个使用consul注册服务的服务端程序的核心逻辑是这样:

  • 创建consul客户端
  • 使用创建的consul客户端连接相应的consul agent
  • 向consul注册服务
  • 运行服务
  • 运行完毕后向consul注销服务

示例代码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package main
import (
    "log"
    "net"
 
    "github.com/hashicorp/consul/api"
)
func main() {
    // 使用默认配置创建consul客户端
    consulClient, err := api.NewClient(api.DefaultConfig())
    if err != nil {
        log.Fatal(err)
    }
    // 注册服务
    // consulClient.Agent()先获取当前机器上的consul agent节点
    consulClient.Agent().ServiceRegister(&api.AgentServiceRegistration{
        ID:      "MyService",
        Name:    "My Service",
        Address: "127.0.0.1",
        Port:    5050,
        Check: &api.AgentServiceCheck{
            CheckID:  "MyService",
            TCP:      "127.0.0.1:5050",
            Interval: "10s",
            Timeout:  "1s",
        },
    })
    // 运行完成后注销服务
    defer consulClient.Agent().ServiceDeregister("MyService")
    l, err := net.Listen("tcp", ":5050")
    if err != nil {
        log.Fatal(err)
    }
    for {
        conn, err := l.Accept()
        if err != nil {
            log.Fatal(err)
        }
        go func() {
            log.Printf("Ip: %s connected", conn.RemoteAddr().String())
        }()
    }
}

我们通过tcp每10秒进行健康检查, 输出窗口每10秒就会输出有新连接到来, 这是consul做的

$ go run .
2022/06/09 20:17:51 Ip: 127.0.0.1:53011 connected
2022/06/09 20:18:01 Ip: 127.0.0.1:53038 connected
2022/06/09 20:18:11 Ip: 127.0.0.1:53045 connected 

那么服务的请求端(客户端)需要通过consul来获取服务的地址和端口,则需要这么几步:

  • 创建consul客户端
  • 使用创建的consul客户端连接相应的consul agent
  • 向consul请求相应服务id的注册信息
  • 如果获取到了相应的注册信息, 就通过地址和端口请求服务

代码示例:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
package main
import (
    "fmt"
    "log"
    "github.com/hashicorp/consul/api"
)
func main() {
    consulClient, err := api.NewClient(api.DefaultConfig())
    if err != nil {
        log.Fatal(err)
    }
    service, _, err := consulClient.Agent().Service("MyService", nil)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Got Service: ip-%s, port-%d", service.Address, service.Port)
}

保证服务端运行的情况运行客户端:

$ go run .
Got Service: ip-127.0.0.1, port-5050

Consul使用Raft算法保证集群一致性

到此这篇关于Golang使用Consul详解的文章就介绍到这了,更多相关Golang Consul内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！

原文链接：https://blog.csdn.net/qq_35621436/article/details/125210475

  • consul
  • golang

    • 延伸 · 阅读

    精彩推荐
    • Golang使用 Go 管理版本的方法示例

      使用 Go 管理版本的方法示例

      这篇文章主要介绍了使用 Go 管理版本的方法示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面...

      帅气猫咪4002020-05-29
    • Golang详解Go语言Slice作为函数参数的使用

      详解Go语言Slice作为函数参数的使用

      Slice切片在Go语言中实质是一种结构体类型，本文详细的介绍了Go语言Slice作为函数参数的使用，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...

      C天外天S4812021-08-12
    • Golang用Go写一个轻量级的ssh批量操作工具的方法

      用Go写一个轻量级的ssh批量操作工具的方法

      这篇文章主要介绍了用Go写一个轻量级的ssh批量操作工具的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧 ...

      freedomkk_qfeng5642020-05-14
    • GolangGo1.18都出泛型了速来围观

      Go1.18都出泛型了速来围观

      泛型允许程序员在强类型程序设计语言中编写代码时使用一些以后才指定的类型，在实例化时作为参数指明这些类型，本文通过例子给大家介绍下如何使用...

      jiangxiaoju8372022-09-07
    • GolangGo语言实现登录验证代码案例

      Go语言实现登录验证代码案例

      这篇文章主要介绍了Go语言实现登录验证代码案例，代码和图文讲解的很清晰，有感兴趣的可以学习下...

      cui_yonghua8262021-04-01
    • GolangVS Code配置Go语言开发环境的详细教程

      VS Code配置Go语言开发环境的详细教程

      这篇文章主要介绍了VS Code配置Go语言开发环境的详细教程，本文通过实例代码图文相结合的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参...

      JasonJI22862020-07-05
    • Golanggolang复用http.request.body的方法示例

      golang复用http.request.body的方法示例

      这篇文章主要给大家介绍了关于golang复用http.request.body的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，...

      ppmoon5782020-05-20
    • Golanggolang编程开发使用sort排序示例详解

      golang编程开发使用sort排序示例详解

      这篇文章主要为大家介绍了go语言编程开发使用sort来排序示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步早日升职加薪...

      秋天的春11742021-12-03
    最近更新
    编辑推荐
    阅读排行
    热门标签
    命令规范 　 指针类型 　 new() 　 make() 　 并发模型 　 切片 　 静态WEB服务器 　 端口扫描器 　 Go语言入门教程 　 基础语 　 Slices 　 Maps 　 Golang编程 　 panic 　 接受者类型 　 嵌入类型 　 Slice 　 Golang教程 　 Golang项目 　 内存模型 　 开发环境搭建 　 大小端判断 　 代码组织结构 　 复合类型 　 GOPATH 　 工作目录 　 实例 　 struct类型 　 并发技术 　 buffered 　
    © 2019-2022 脚本之家 | 服务器之家(www.tuohang.net)旗下站点 版权所有关于我们联系我们版权申明网站地图