服务发现之consul
什么是服务发现
服务发现有三个角色，服务提供者，服务消费者，服务中介。服务中介是联系服务提供者和服务消费者的桥梁。服务提供者将自己提供的服务地址注册到服务中介，服务消费者从服务中介那里查找自己想要的服务地址，然后使用这个服务
为什么需要服务发现呢,服务发现解决了什么问题呢?
在微服务架构中，一个大的系统被拆分成许多小的微服务，各微服务之间经常会相互调用，如服务A调用服务B的接口，必须要需要知道服务B网络位置，一个可行的做法是简各微服务的网络位置配置在配置文件中，或者有些配置在数据库中，但是这样会存在如下问题
- 需要配置N个服务的网络位置，加大配置的复杂性
- 服务的网络位置变化，都需要改变每个调用者的配置
- 集群的情况下，难以做负载（反向代理的方式除外）
但是如果有了服务发现机制，所有的服务都将自己的网络位置向服务中介中注册（如下图所示）这样服务消费者需要调用某个服务提供者的服务的时候就只需要访问服务中介获取服务提供者的网络位置，然后就可以访问服务提供者提供的服务了，实现了服务提供者和服务消费者之间的解耦。
consul简介
consul是分布式的、高可用、横向扩展的。consul提供的一些关键特性：
-
service discovery：consul通过DNS或者HTTP接口使服务注册和服务发现变的很容易，一些外部服务，例如saas提供的也可以一样注册。
-
health checking：健康检测使consul可以快速的告警在集群中的操作。和服务发现的集成，可以防止服务转发到故障的服务上面。
-
key/value storage：一个用来存储动态配置的系统。提供简单的HTTP接口，可以在任何地方操作。
-
multi-datacenter：无需复杂的配置，即可支持任意数量的区域。
首先看一张官网上的图片，可以看出consul的集群是由N个SERVER，加上M个CLIENT组成的。而不管是SERVER还是CLIENT，都是consul的一个节点，所有的服务都可以注册到这些节点上，正是通过这些节点实现服务注册信息的共享。
-
CLIENT
CLIENT表示consul的client模式，就是客户端模式。是consul节点的一种模式，这种模式下，所有注册到当前节点的服务会被转发到SERVER，本身是不持久化这些信息。 -
SERVER
SERVER表示consul的server模式，表明这个consul是个server，这种模式下，功能和CLIENT都一样，唯一不同的是，它会把所有的信息持久化的本地，这样遇到故障，信息是可以被保留的。 -
SERVER-LEADER
中间那个SERVER下面有LEADER的字眼，表明这个SERVER是它们的老大，它和其它SERVER不一样的一点是，它需要负责同步注册的信息给其它的SERVER，同时也要负责各个节点的健康监测
consul安装部署
这里主要介绍以容器的方式在单节点上安装部署consul
- 拉取镜像
[root@izwz98qymta5zk0d5fw0mhz ~]# docker pull consul #官方镜像,不指定tag就拉取last
- 查看镜像
[root@izwz98qymta5zk0d5fw0mhz ~]# docker images |grep consul
docker.io/consul latest 9c9974471250 10 days ago 108 MB
- 启动consul
- 启动节点1
[root@izwz98qymta5zk0d5fw0mhz ~]# docker run -d -e 'CONSUL_LOCAL_CONFIG={"skip_leave_on_interrupt": true}' --name=node1
consul agent -server -bind=172.17.0.2 -bootstrap-expect=3 -node=node1
-node：节点的名称
-bind：绑定的一个地址，用于节点之间通信的地址，可以是内外网，必须是可以访问到的地址
-server：这个就是表示这个节点是个SERVER
-bootstrap-expect：这个就是表示期望提供的SERVER节点数目，数目一达到，它就会被激活，然后就是LEADER了
- 启动节点2,3（server模式）
[root@izwz98qymta5zk0d5fw0mhz ~]# docker run -d -e 'CONSUL_LOCAL_CONFIG={"skip_leave_on_interrupt": true}' --name=node2 consul agent -server
-bind=172.17.0.3 -join=172.17.0.2 -node-id=$(uuidgen | awk '{print tolower($0)}') -node=node2
[root@izwz98qymta5zk0d5fw0mhz ~]# docker run -d -e 'CONSUL_LOCAL_CONFIG={"skip_leave_on_interrupt": true}' --name=node3 consul agent -server
-bind=172.17.0.4 -join=172.17.0.2 -node-id=$(uuidgen | awk '{print tolower($0)}') -node=node3 -client=172.17.0.4
- 启动节点4（client模式）
[root@izwz98qymta5zk0d5fw0mhz ~]# docker run -d -e 'CONSUL_LOCAL_CONFIG={"leave_on_terminate": true}' --name=node4 consul agent
-bind=172.17.0.5 -retry-join=172.17.0.2 -node-id=$(uuidgen | awk '{print tolower($0)}') -node=node4
没有-server说明这个节点是CLIENT
- 查看下集群的状态
[root@izwz98qymta5zk0d5fw0mhz ~]# docker exec -t node1 consul members
Node Address Status Type Build Protocol DC Segment
node1 172.17.0.2:8301 alive server 1.4.4 2 dc1 <all>
node2 172.17.0.3:8301 alive server 1.4.4 2 dc1 <all>
node3 172.17.0.4:8301 alive server 1.4.4 2 dc1 <all>
node4 172.17.0.5:8301 alive client 1.4.4 2 dc1 <default>
4个节点都列出来了。Status表示它们的状态，都是alive。Type表示它们的类型，三个SERVER一个CLIENT，和我们之前启动的一样。DC表示数据中心，都是dc1
查看leader节点
[root@izwz98qymta5zk0d5fw0mhz ~]# curl http://172.17.0.4:8500/v1/status/leader
"172.17.0.4:8300"
172.17.0.4 就是 node3节点的IP
consul使用
- 注册服务
调用 http://consul:8500/v1/agent/service/register PUT 注册一个服务。使用curl调用
[root@izwz98qymta5zk0d5fw0mhz ~]# curl http://172.17.0.4:8500/v1/agent/service/register -X PUT -i -H "Content-Type:application/json" -d '{
> "ID": "userServiceId",
> "Name": "userService",
> "Tags": [
> "primary",
> "v1"
> ],
> "Address": "127.0.0.1",
> "Port": 8000,
> "EnableTagOverride": false,
> "Check": {
> "DeregisterCriticalServiceAfter": "90m",
> "HTTP": "http://www.baidu.com",
> "Interval": "10s"
> }
> }'
HTTP/1.1 200 OK
Vary: Accept-Encoding
Date: Wed, 08 May 2019 14:57:41 GMT
Content-Length: 0
- 发现服务
[root@izwz98qymta5zk0d5fw0mhz ~]# curl http://172.17.0.4:8500/v1/catalog/service/userService
[{"ID":"009522ae-2d44-4032-9b7b-14171cada26b",
"Node":"node3",
"Address":"172.17.0.4",
"Datacenter":"dc1",
"TaggedAddresses{"lan":"172.17.0.4",
"wan":"172.17.0.4"},
"NodeMeta":{"consul-network-segment":""
},
"ServiceKind":"",
"ServiceID":"userServiceId",
"ServiceName":"userService",
"ServiceTags":["primary","v1"],
"ServiceAddress":"127.0.0.1",
"ServiceWeights":{
"Passing":1,
"Warning":1
},
"ServiceMeta{},
"ServicePort":8000,
"ServiceEnableTagOverride":false,
"ServiceProxyDestination":"",
"ServiceProxy":{},
"ServiceConnect":{},
"CreateIndex":88,
"ModifyIndex":88
}
]
