简介
Consul是一个可以提供服务发现，健康检查，多数据中心，Key/Value存储等功能的分布式服务框架，用于实现分布式系统的服务发现与配置，使用起来也较为简单。Consul基于Golang语言实现，因此具有天然可移植性(支持Linux、Windows和MacOS)。安装包仅包含一个可执行文件，方便部署。Consul具有分布式的、高可用的、可横向扩展的特点。
Consul的功能特性
| 特性 | 描述 |
| 服务发现（Service Discovery） | Consul提供了通过DNS或者HTTP接口的方式来注册服务和发现服务。一些外部的服务通过Consul很容易的找到它所依赖的服务。 |
| 健康检查（Health Checking） | Consul的Client可以提供任意数量的健康检查，既可以与给定的服务相关联（webserver是否返回200 OK），也可以与本地节点相关联（内存利用率是否低于90%）。操作员可以使用这些信息来监视集群的健康状况，服务发现组件可以使用这些信息将流量从不健康的主机路由出去。 |
| Key/Value存储 | 应用程序可以根据自己的需要使用Consul提供的Key/Value存储。 Consul提供了简单易用的HTTP接口，结合其他工具可以实现动态配置、功能标记、领袖选举等等功能。 |
| 安全服务通信 | Consul可以为服务生成和分发TLS证书，以建立相互的TLS连接。意图可用于定义允许哪些服务通信。服务分割可以很容易地进行管理，其目的是可以实时更改的，而不是使用复杂的网络拓扑和静态防火墙规则。 |
| 多数据中心 | Consul支持开箱即用的多数据中心. 这意味着用户不需要担心需要建立额外的抽象层让业务扩展到多个区域。 |
安装Consul
端口详解
- 8500 : http 端口，用于 http 接口和 web ui访问；
- 8300 : server rpc 端口，同一数据中心 consul server 之间通过该端口通信
- 8301 : serf lan 端口，同一数据中心 consul client 通过该端口通信; 用于处理当前datacenter中LAN的gossip通信
- 8302 : serf wan 端口，不同数据中心 consul server 通过该端口通信; agent Server使用，处理与其他datacenter的gossip通信；
- 8600 : dns 端口，用于已注册的服务发现；
参数详解
- –net=host docker参数, 使得docker容器越过了net namespace的隔离，免去手动指定端口映射的步骤
- -server consul支持以server或client的模式运行, server是服务发现模块的核心, client主要用于转发请求
- -advertise 通告地址用于更改我们通告给集群中其他节点的地址。默认情况下，-bind地址是通告的。
- -retry-join 指定要加入的consul节点地址，失败后会重试, 可多次指定不同的地址
- -client Consul将绑定客户端接口的地址，包括HTTP和DNS服务器。默认情况下，这是“127.0.0.1”，只允许回送连接。
- -bind 内部集群通信绑定的地址。这是集群中所有其他节点都应该可以访问的IP地址。默认情况下，这是“0.0.0.0”，集群内的所有节点到地址必须是可达的
- -bootstrap-expect 此标志提供数据中心中预期服务器的数量。不应该提供此值，或者该值必须与群集中的其他服务器一致。指定后，Consul将等待指定数量的服务器可用，然后启动群集。允许自动选举leader，但不能与传统-bootstrap标志一起使用, 需要在server模式下运行。
- -data-dir 此标志为代理存储状态提供了一个数据目录。这对所有代理都是必需的。该目录在重新启动时应该是持久的。这对于在服务器模式下运行的代理尤其重要，因为它们必须能够保持群集状态。此外，该目录必须支持使用文件系统锁定，这意味着某些类型的已装入文件夹（例如VirtualBox共享文件夹）可能不合适
- -node 群集中此节点的名称，这在群集中必须是唯一的，默认情况下是节点的主机名。
- -config-dir 指定配置文件，当这个目录下有 .json 结尾的文件就会被加载
- -enable-script-checks 检查服务是否处于活动状态，类似开启心跳
- -datacenter 数据中心名称。如果未提供，则默认为“dc1”。Consul对多个数据中心拥有一流的支持，但它依赖于正确的配置。同一个数据中心内的节点应该位于单个局域网中。
- -ui - 启用内置的Web UI服务器和所需的HTTP路由。这消除了将Consul Web UI文件与二进制文件分开维护的需要。
- -join 指定ip, 加入到已有的集群中
Mac
brew tap hashicorp/tap brew install hashicorp/tap/consul
CentOS7
sudo yum install -y yum-utils sudo yum-config-manager --add-repo https://rpm.releases.hashicorp.com/RHEL/hashicorp.repo sudo yum -y install consul
Docker搭建集群
拉取镜像
docker pull consul
运行第一个节点
docker run --name consul1 -d -p 8500:8500 -p 8300:8300 -p 8301:8301 -p 8302:8302 -p 8600:8600 consul agent -server -bootstrap-expect 2 -ui -bind=0.0.0.0 -client=0.0.0.0
查看第一个节点的IP
docker inspect --format='{{.NetworkSettings.IPAddress}}' consul1
我这里输出的是：172.17.0.2
运行第二个节点
docker 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.2
运行第三个节点
docker run --name consul3 -d -p 8502:8500 consul agent -server -ui -bind=0.0.0.0 -client=0.0.0.0 -join 172.17.0.2
查看consul集群信息
docker exec -it consul1 consul members
Node Address Status Type Build Protocol DC Segment 01178441e7d7 172.17.0.2:8301 alive server 1.10.1 2 dc1 <all> 1731fb193228 172.17.0.3:8301 alive server 1.10.1 2 dc1 <all> a748da902ab4 172.17.0.4:8301 alive server 1.10.1 2 dc1 <all>
之后可以在浏览器访问8500/8501/8502端口查看UI页面
开发Consul客户端
创建项目引入依赖
创建SpringBoot项目并修改pom为以下内容
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <artifactId>SpringCloud</artifactId> <groupId>com.moti</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>cloud-consul-client</artifactId> <dependencies> <!--引入SpringBoot依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!--引入Consul依赖--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-consul-discovery</artifactId> <version>3.0.3</version> </dependency> <!--健康状况监控依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> </dependencies> </project>
修改配置文件
# 服务端口 server.port=8081 # 指定服务名称 唯一标识（不可以出现下划线） spring.application.name=ConsulClient # 指定Consul服务端信息 spring.cloud.consul.host=localhost spring.cloud.consul.port=8500 spring.cloud.consul.discovery.service-name=${spring.application.name} # 关闭Consul了服务的健康检查[不推荐] # spring.cloud.consul.discovery.register-health-check=false
启动类加入@EnableDiscoveryClient注解
@SpringBootApplication @EnableDiscoveryClient public class ConsulClientApplication { public static void main(String[] args) { SpringApplication.run(ConsulClientApplication.class, args); } }
