使用consul四大特性
1. 服务发现：利用服务注册，服务发现功能来实现服务治理。
2. 健康检查：利用consul注册的检查检查函数或脚本来判断服务是否健康，若服务不存在则从注册中心移除该服务，减少故障服务请求。
3. k/v数据存储：存储kv数据，可以作为服务配置中心来使用。
4. 多数据中心：可以建立多个consul集群通过inter网络进行互联，进一步保证数据可用性。
通过docker安装consul
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
docker pull consul:latest//运行单机docker run -d --restart=always --name consul -d -p 8500:8500 consul/*8500 http 端口，用于 http 接口和 web ui8300 server rpc 端口，同一数据中心 consul server 之间通过该端口通信8301 serf lan 端口，同一数据中心 consul client 通过该端口通信8302 serf wan 端口，不同数据中心 consul server 通过该端口通信8600 dns 端口，用于服务发现-bbostrap-expect 2: 集群至少两台服务器，才能选举集群leader-ui：运行 web 控制台-bind： 监听网口，0.0.0.0 表示所有网口，如果不指定默认未127.0.0.1，则无法和容器通信-client ： 限制某些网口可以访问*///集群docker run --name consul1 -d -p 8500:8500 -p 8300:8300 -p 8301:8301 -p 8302:8302 -p 8600:8600 consul:latest agent -server -bootstrap-expect 2 -ui -bind=0.0.0.0 -client=0.0.0.0docker run --name consul2 -d -p 8501:8500 consul agent -server -ui -bind=0.0.0.0 -client=0.0.0.0 -join 172.17.0.2docker run --name consul2 -d -p 8502:8500 consul agent -server -ui -bind=0.0.0.0 -client=0.0.0.0 -join 172.17.0.2 |
实现代码
以下代码实现一个服务注册，服务发现，配置共享的功能：
|
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
|
package mainimport ( "net" "github.com/gin-gonic/gin" "fmt" "log" "net/http" consulapi "github.com/hashicorp/consul/api")const ( consulAddress = "192.168.100.19:8500" serviceId = "111")func main() { r := gin.Default() // consul健康检查回调函数 r.GET("/", func(c *gin.Context) { c.JSON(200, gin.H{ "message": "ok", }) }) go http.ListenAndServe(":8081", r) // 注册服务到consul ConsulRegister() // 从consul中发现服务 ConsulFindServer() ConsulCheckHeath() ConsulKVTest() // 取消consul注册的服务 //ConsulDeRegister() var str string fmt.Scan(&str)}// 注册服务到consulfunc ConsulRegister() { // 创建连接consul服务配置 config := consulapi.DefaultConfig() config.Address = consulAddress client, err := consulapi.NewClient(config) if err != nil { log.Fatal("consul client error : ", err) } // 创建注册到consul的服务到 registration := new(consulapi.AgentServiceRegistration) registration.ID = serviceId // 服务节点的名称 registration.Name = "go-consul-test" // 服务名称 registration.Port = 8081 // 服务端口 registration.Tags = []string{"go-consul-test"} // tag，可以为空 registration.Address = "192.168.3.42" // 服务 IP 要确保consul可以访问这个ip // 增加consul健康检查回调函数 check := new(consulapi.AgentServiceCheck) check.HTTP = fmt.Sprintf("http://%s:%d", registration.Address, registration.Port) check.Timeout = "5s" check.Interval = "5s" // 健康检查间隔 check.DeregisterCriticalServiceAfter = "30s" // 故障检查失败30s后 consul自动将注册服务删除 registration.Check = check // 注册服务到consul err = client.Agent().ServiceRegister(registration) if err == nil { fmt.Println("ConsulRegister done") }}// 取消consul注册的服务func ConsulDeRegister() { // 创建连接consul服务配置 config := consulapi.DefaultConfig() config.Address = consulAddress client, err := consulapi.NewClient(config) if err != nil { log.Fatal("consul client error : ", err) } client.Agent().ServiceDeregister(serviceId)}// 从consul中发现服务func ConsulFindServer() { // 创建连接consul服务配置 config := consulapi.DefaultConfig() config.Address = consulAddress client, err := consulapi.NewClient(config) if err != nil { log.Fatal("consul client error : ", err) } // 获取所有service services, _ := client.Agent().Services() for _, value := range services { fmt.Println("address:", value.Address) fmt.Println("port:", value.Port) } fmt.Println("=================================") // 获取指定service service, _, err := client.Agent().Service(serviceId, nil) if err == nil { fmt.Println("address:", service.Address) fmt.Println("port:", service.Port) } if err == nil { fmt.Println("ConsulFindServer done") }}func ConsulCheckHeath() { // 创建连接consul服务配置 config := consulapi.DefaultConfig() config.Address = consulAddress client, err := consulapi.NewClient(config) if err != nil { log.Fatal("consul client error : ", err) } // 健康检查 a, b, _ := client.Agent().AgentHealthServiceByID(serviceId) fmt.Println("val1:", a) fmt.Println("val2:", b) fmt.Println("ConsulCheckHeath done")}func ConsulKVTest() { // 创建连接consul服务配置 config := consulapi.DefaultConfig() config.Address = consulAddress client, err := consulapi.NewClient(config) if err != nil { log.Fatal("consul client error : ", err) } // KV, put值 values := "test" key := "go-consul-test" client.KV().Put(&consulapi.KVPair{Key: key, Flags: 0, Value: []byte(values)}, nil) // KV get值 data, _, _ := client.KV().Get(key, nil) fmt.Println("data:", string(data.Value)) // KV list datas, _, _ := client.KV().List("go", nil) for _, value := range datas { fmt.Println("val:", value) } keys, _, _ := client.KV().Keys("go", "", nil) fmt.Println("key:", keys) fmt.Println("ConsulKVTest done")}func localIP() string { addrs, err := net.InterfaceAddrs() if err != nil { return "" } for _, address := range addrs { if ipnet, ok := address.(*net.IPNet); ok && !ipnet.IP.IsLoopback() { if ipnet.IP.To4() != nil { return ipnet.IP.String() } } } return ""} |
运行结果
以上就是go使用consul实现服务发现及配置共享实现详解的详细内容，更多关于go consul服务发现配置共享的资料请关注服务器之家其它相关文章！
原文链接：https://www.cnblogs.com/majiang/p/14290357.html
