Web基础配置篇（十五）: Consul单机、集群的安装使用及作为配置中心使用

ゞ浴缸里的玫瑰 2023-06-06 03:58 108阅读 0赞

## Web基础配置篇（十五）: Consul单机、集群的安装使用及作为配置中心使用 ##

### 一、概述 ###

Consul是一个服务网格（微服务间的 TCP/IP，负责服务之间的网络调用、限流、熔断和监控）解决方案，它是一个一个分布式的，高度可用的系统，而且开发使用都很简便。它提供了一个功能齐全的控制平面，主要特点是：服务发现、健康检查、键值存储、安全服务通信、多数据中心。

consul之所以广为JAVA开发知，要归功于SpringCloud，SpringCloud可以基于Consul实现服务注册发现，也可以基于Consul实现配置中心动态配置功能。

在[《SpringCloud技术指南系列（四）服务注册发现之Consul服务注册》][SpringCloud_Consul]和[《SpringCloud技术指南系列（八）配置管理之Consul配置中心》][SpringCloud_Consul 1]一文中，已经介绍了SpringCloud如何使用consul做注册中心和配置中心。

本篇重点介绍下consul的安装、配置、集群建立方式，并介绍Consul的接口，教你如何脱离SpringCloud使用consul。

首发地址：

[品茗IT: https://www.pomit.cn/p/2288575659993601][IT_ https_www.pomit.cn_p_2288575659993601]

**如果大家正在寻找一个java的学习环境，或者在开发中遇到困难，可以[加入我们的java学习圈，点击即可加入][java]，共同学习，节约学习时间，减少很多在学习中遇到的难题。**

## 二、准备工作 ##

### 2.1 Consul下载 ###

*  Consul可以在[Consul官网][Consul] 查看下载地址，windows和linux上用不同一个安装包，需要根据需要下载；
 *  windows可以在[https://releases.hashicorp.com/consul/1.6.1/consul\_1.6.1\_windows\_amd64.zip][https_releases.hashicorp.com_consul_1.6.1_consul_1.6.1_windows_amd64.zip] 这里下载。
 *  Linux可以在[https://releases.hashicorp.com/consul/1.6.1/consul\_1.6.1\_linux\_amd64.zip][https_releases.hashicorp.com_consul_1.6.1_consul_1.6.1_linux_amd64.zip] 这里下载：

![在这里插入图片描述][format_png]

### 2.2 解压 ###

*  windows解压后就一个consul.exe文件；
 *  Linux解压后就一个consul文件；
 *  文件可以直接运行。

## 三、Consul单机 ##

### 3.1 开发者模式 ###

运行命令：

`consul agent -dev`

然后就启动了，就这么简单，可以通过`http://127.0.0.1:8500`来访问这个consul的ui界面。

但是，这种模式一般是自己开发的时候用的，因为它不带记忆功能，也不能与其他consul互通。

### 3.3 Client模式 ###

Consul 的 Client模式，就是客户端模式。是 Consul 节点的一种模式，这种模式下，所有注册到当前节点的服务会被转发到  
Server，本身是不持久化这些信息。

**Client模式不能脱离Server单独运行，因此无法实现单机模式**

### 3.3 Server模式 ###

Consul 的 Server 模式，表明这个 Consul 是个 Server ，这种模式下，功能和 Client  
都一样，唯一不同的是，它会把所有的信息持久化的本地，这样遇到故障，信息是可以被保留的。

运行命令：

`consul agent -server -bootstrap-expect 1 -data-dir /soft/data/consul -node=consulServer1 -bind=10.247.63.210 -ui -rejoin -config-dir=/soft/config/consul/ -client 0.0.0.0`

然后就启动了，就这么简单。

可以通过`http://10.247.63.210:8500`来访问这个consul的ui界面。

*  \-server ： 定义agent运行在server模式
 *  \-bootstrap-expect ：在一个datacenter中期望提供的server节点数目，当该值提供的时候，consul一直等到达到指定sever数目的时候才会引导整个集群，该标记不能和bootstrap共用
 *  \-bind：该地址用来在集群内部的通讯，集群内的所有节点到地址都必须是可达的，默认是0.0.0.0
 *  \-node：节点在集群中的名称，在一个集群中必须是唯一的，默认是该节点的主机名
 *  \-ui： 开启consul的界面；
 *  \-rejoin：使consul忽略先前的离开，在再次启动后仍旧尝试加入集群中。
 *  \-config-dir：配置文件目录，里面所有以.json结尾的文件都会被加载
 *  \-client：consul服务侦听地址，这个地址提供HTTP、DNS、RPC等服务，默认是127.0.0.1所以不对外提供服务，如果你要对外提供服务改成0.0.0.0

**Server模式可以单独运行，实现单机模式，bootstrap-expect为1即可。**

## 四、Consul集群 ##

集群和单机的启动方式是一样的，只需要指定并接入到其他Server即可。

### 4.1 集群Server ###

我这里使用3台机器作为集群测试，两台在linux上，一台在windows上。

**Server1：**

`consul agent -server -bootstrap-expect 3 -data-dir /soft/data/consul -node=consulServer1 -bind=10.247.63.210 -ui -rejoin -config-dir=/soft/config/consul/ -client 0.0.0.0`

**Server2：**

`consul agent -server -bootstrap-expect 3 -data-dir /soft/data/consul -node=consulServer2 -bind=10.247.62.76 -ui -rejoin -config-dir=/soft/config/consul/ -client 0.0.0.0 -join 10.247.63.210`

**Server3：**

`consul.exe agent -server -bootstrap-expect 3 -data-dir E:/data/consul/data/ -node=consulServer3 -bind=10.247.62.91 -ui -rejoin -config-dir=E:/data/consul/config/ -client 0.0.0.0 -join 10.247.63.210`

**注意：上面命令在windows上不能使用powershell启动consul，用cmd就可以。**

![在这里插入图片描述][format_png 1]

我停掉windows的consul：

![在这里插入图片描述][format_png 2]

如上图所示，用`consul members`命令查看consul集群状态，有三个consul。

上图中failed的那个consul是我停掉的windows的consul。停掉以后，另外两个server仍然不断重连：

![在这里插入图片描述][format_png 3]

### 4.1 集群Client ###

将停掉的server改为client加入到集群中去。

`consul.exe agent -data-dir E:/data/consul/data/ -node=cc1 -bind=10.247.62.91 -ui -config-dir=E:/data/consul/config/ -client 0.0.0.0 -join 10.247.63.210`

![在这里插入图片描述][format_png 4]

可以看到，停掉的server还是failed。另外，其他两个server仍然不断重连停掉的server3.

**client的ui打开后是啥也没有的：**

![在这里插入图片描述][format_png 5]

**server的consul打开之后是能看到service等内容的。**

## 五、Consul的API列表 ##

consul的主要接口是RESTful HTTP API，该API可以用来增删查改nodes、services、checks、configguration。所有的endpoints主要分为以下类别：

kv - Key/Value存储
    agent - Agent控制
    catalog - 管理nodes和services
    health - 管理健康监测
    session - Session操作
    acl - ACL创建和管理
    event - 用户Events
    status - Consul系统状态

### 5.1 agent ###

agent endpoints用来和本地agent进行交互，一般用来服务注册和检查注册，支持以下接口:

/v1/agent/checks : 返回本地agent注册的所有检查(包括配置文件和HTTP接口)
    /v1/agent/services : 返回本地agent注册的所有 服务
    /v1/agent/members : 返回agent在集群的gossip pool中看到的成员
    /v1/agent/self : 返回本地agent的配置和成员信息
    /v1/agent/join/<address> : 触发本地agent加入node
    /v1/agent/force-leave/<node>>: 强制删除node
    /v1/agent/check/register : 在本地agent增加一个检查项，使用PUT方法传输一个json格式的数据
    /v1/agent/check/deregister/<checkID> : 注销一个本地agent的检查项
    /v1/agent/check/pass/<checkID> : 设置一个本地检查项的状态为passing
    /v1/agent/check/warn/<checkID> : 设置一个本地检查项的状态为warning
    /v1/agent/check/fail/<checkID> : 设置一个本地检查项的状态为critical
    /v1/agent/service/register : 在本地agent增加一个新的服务项，使用PUT方法传输一个json格式的数据
    /v1/agent/service/deregister/<serviceID> : 注销一个本地agent的服务项

### 5.2 catalog ###

catalog endpoints用来注册/注销nodes、services、checks:

/v1/catalog/register : 注册一个node, service, check
    /v1/catalog/deregister : 注销node, service, check
    /v1/catalog/datacenters : 列出所有dc
    /v1/catalog/nodes : 列出某节点的dc
    /v1/catalog/services : 列出某dc的服务
    /v1/catalog/service/<service> : 列出某服务的所有节点
    /v1/catalog/node/<node> : 列出某节点的所有服务

### 5.3 health ###

health endpoints用来查询健康状况相关信息，该功能从catalog中单独分离出来:

/v1/healt/node/<node>: 返回node所定义的检查，可用参数?dc=
    /v1/health/checks/<service>: 返回和服务相关联的检查，可用参数?dc=
    /v1/health/service/<service>: 返回给定datacenter中给定node中service
    /v1/health/state/<state>: 返回给定datacenter中指定状态的服务，state可以是"any", "unknown", "passing", "warning", or "critical"

### 5.4 session ###

session endpoints用来create、update、destory、query sessions.

/v1/session/create: 创建一个session
    /v1/session/destroy/<session>: 销毁session
    /v1/session/info/<session>: 查询session
    /v1/session/node/<node>: 列出某节点所有session
    /v1/session/list:  列出所有session

### 5.5 event ###

event endpoints用来fire新的events、查询已有的events:

/v1/event/fire/<name>: 触发一个新的event，用户event需要name和其他可选的参数，使用PUT方法
    /v1/event/list: 返回agent知道的events

### 5.6 status ###

status endpoints用来或者consul 集群的信息:

/v1/status/leader : 返回当前集群的Raft leader
    /v1/status/peers : 返回当前集群中同事

## 六、配置中心 ##

打开consul的界面，如：`http://10.247.63.210:8500`。

*  点击 Key/Value, 新建config目录（新建目录和新建文件是一样的，只不过新建目录后面要加/）；
 *  然后在config目录下新建consulConfig目录（上面的spring.cloud.consul.config.defaultContext）。；
 *  然后在consulConfig目录下新建data文件，写入yaml配置。

![在这里插入图片描述][format_png 6]

比如这里写了个welcom.value配置。

welcom:
       value: vbvcbbb

**注意：直接在网页上写配置，可能会有问题，建议在yaml编辑器里写好了粘贴过来。**

## 七、脱离SpringCloud使用服务注册发现 ##

在我的开源项目[consul-proxy][]：[https://www.pomit.cn/consul-proxy][consul-proxy] 中，就脱离了SpringCloud使用服务注册发现。

### 7.1 依赖 ###

可以使用ecwid.consul对consul进行操作，其实就是对上面的consul的api列表进行操作。

<dependency>
    	<groupId>com.ecwid.consul</groupId>
    	<artifactId>consul-api</artifactId>
    	<version>${consul.version}</version>
    </dependency>

### 7.2 服务注册 ###

首先，组装服务信息，主要是地址、端口、名称信息，然后使用ConsulClient的agentServiceRegister注册相应的服务即可。

ConsulClient client = new ConsulClient(consulProperties.getHost(), consulProperties.getPort());
    NewService service = new NewService();
    service.setId(consulProperties.getInstanceId());
    service.setAddress(consulProperties.getHostname());
    service.setName(consulProperties.getApplicationName());
    service.setTags(createTags());
    
    service.setPort(consulProperties.getApplicationPort());
    setCheck(service);
    try { 
    	client.agentServiceRegister(service);
    	log.info("服务已注册：{}", service);
    } catch (ConsulException e) { 
    	log.warn("Error registering service with consul: " + service, e);
    
    	log.info("重新提交注册：{}", service);
    	client.agentServiceRegister(service);
    }

### 7.3 服务发现 ###

使用ConsulClient的getHealthServices获取健康服务即可。

ConsulClient client = new ConsulClient(consulProperties.getHost(), consulProperties.getPort());
    Response<List<HealthService>> catalogServiceList = client.getHealthServices(serviceId, true, null);
    List<HealthService> list = catalogServiceList.getValue();

这里只是查出来所有可用的节点，如果需要使用负载均衡服务调用，需要另外的组件进行配合，比如ribbon。

[品茗IT-博客专题:https://www.pomit.cn/lecture.html][IT-_https_www.pomit.cn_lecture.html]汇总了[Spring专题][Spring]、[Springboot专题][Springboot]、[SpringCloud专题][SpringCloud]、[web基础配置][web]专题。

### 快速构建项目 ###

Spring项目快速开发工具：

[一键快速构建Spring项目工具][Spring 1]

[一键快速构建SpringBoot项目工具][SpringBoot]

[一键快速构建SpringCloud项目工具][SpringCloud 1]

[一站式Springboot项目生成][Springboot 1]

[Mysql一键生成Mybatis注解Mapper][Mysql_Mybatis_Mapper]

[Spring组件化构建][Spring 1]

[SpringBoot组件化构建][SpringBoot]

[SpringCloud服务化构建][SpringCloud 1]

喜欢这篇文章么，喜欢就加入我们一起讨论Java Web吧！  
![品茗IT交流群][IT]

[SpringCloud_Consul]: https://www.pomit.cn/p/2058409372387841
[SpringCloud_Consul 1]: https://www.pomit.cn/p/2110739747924481
[IT_ https_www.pomit.cn_p_2288575659993601]: https://www.pomit.cn/p/2288575659993601
[java]: https://jq.qq.com/?_wv=1027&k=52sgH1J
[Consul]: https://www.consul.io/downloads.html
[https_releases.hashicorp.com_consul_1.6.1_consul_1.6.1_windows_amd64.zip]: https://releases.hashicorp.com/consul/1.6.1/consul_1.6.1_windows_amd64.zip
[https_releases.hashicorp.com_consul_1.6.1_consul_1.6.1_linux_amd64.zip]: https://releases.hashicorp.com/consul/1.6.1/consul_1.6.1_linux_amd64.zip
[format_png]: /images/20230601/6136507936a7479b9ee63d75dac63111.png
[format_png 1]: /images/20230601/67a0b00b88ae4f478da4bfd353122887.png
[format_png 2]: /images/20230601/5042c61a2fd645499c0058904b8bef0c.png
[format_png 3]: /images/20230601/b2c33e044872438c93769cfc3ebb4cee.png
[format_png 4]: /images/20230601/6cbd9e4ae433468894e12baa64c97714.png
[format_png 5]: /images/20230601/617ae83bb7764f69bc148ffe5e381cbd.png
[format_png 6]: /images/20230601/00f9c01dfb794f6eb1f55df907c3adde.png
[consul-proxy]: https://www.pomit.cn/consul-proxy
[IT-_https_www.pomit.cn_lecture.html]: https://www.pomit.cn/lecture.html
[Spring]: https://www.pomit.cn/lecture/springunion.html
[Springboot]: https://www.pomit.cn/lecture/springbootfull.html
[SpringCloud]: https://www.pomit.cn/lecture/springcloudfull.html
[web]: https://www.pomit.cn/lecture/webbasics.html
[Spring 1]: https://www.pomit.cn/java/spring/spring.html
[SpringBoot]: https://www.pomit.cn/java/spring/springboot.html
[SpringCloud 1]: https://www.pomit.cn/java/spring/springcloud.html
[Springboot 1]: https://www.pomit.cn/java/java/sqlToSpringboot.html
[Mysql_Mybatis_Mapper]: https://www.pomit.cn/java/java/sqlToMybatis.html
[IT]: /images/20230601/ecafc4a632fc4b86bf1f1731052410fa.png