查看原文
其他

Spring Cloud(二)Consul 服务治理实现

搜云库 搜云库技术团队 2019-04-07

Spring Cloud Consul 项目是针对Consul的服务治理实现。Consul是一个分布式高可用的系统,具有分布式、高可用、高扩展性。

Consul 简介

Consul 是 HashiCorp 公司推出的开源工具,用于实现分布式系统的服务发现与配置。与其他分布式服务注册与发现的方案,Consul的方案更“一站式” ,内置了服务注册与发现框 架、具有以下性质:

  • 分布一致性协议实现、

  • 健康检查、

  • Key/Value存储、

  • 多数据中心方案,

不再需要依赖其他工具(比如ZooKeeper等)。

使用起来也较 为简单。Consul使用Go语言编写,因此具有天然可移植性(支持Linux、windows和Mac OS X);安装包仅包含一个可执行文件,方便部署,与Docker等轻量级容器可无缝配合 。 基于 Mozilla Public License 2.0 的协议进行开源. Consul 支持健康检查,并允许 HTTP 和 DNS 协议调用 API 存储键值对. 一致性协议采用 Raft 算法,用来保证服务的高可用. 使用 GOSSIP 协议管理成员和广播消息, 并且支持 ACL 访问控制.

Consul 的使用场景

  • docker 实例的注册与配置共享

  • coreos 实例的注册与配置共享

  • vitess 集群

  • SaaS 应用的配置共享

  • 与 confd 服务集成,动态生成 nginx 和 haproxy 配置文件

Consul 的优势

使用 Raft 算法来保证一致性, 比复杂的 Paxos 算法更直接. 相比较而言, zookeeper 采用的是 Paxos, 而 etcd 使用的则是 Raft. 支持多数据中心,内外网的服务采用不同的端口进行监听。 多数据中心集群可以避免单数据中心的单点故障,而其部署则需要考虑网络延迟, 分片等情况等. zookeeper 和 etcd 均不提供多数据中心功能的支持. 支持健康检查. etcd 不提供此功能. 支持 http 和 dns 协议接口. zookeeper 的集成较为复杂, etcd 只支持 http 协议. 官方提供web管理界面, etcd 无此功能.

Consul 的角色

client: 客户端, 无状态, 将 HTTP 和 DNS 接口请求转发给局域网内的服务端集群.server: 服务端, 保存配置信息, 高可用集群, 在局域网内与本地客户端通讯, 通过广域网与其他数据中心通讯. 每个数据中心的 server 数量推荐为 3 个或是 5 个.

由于Spring Cloud Consul项目的实现,我们可以轻松的将基于Spring Boot的微服务应用注册到Consul上,并通过此实现微服务架构中的服务治理。

搭建环境

参考

  • Spring Cloud 官方文档

  • Consul 官方文档

要想利用Consul提供的服务实现服务的注册与发现,我们需要搭建Consul Cluster 环境。

在Consul方案中,每个提供服务的节点上都要部署和运行Consul的agent,所有运行Consul agent节点的集合构成Consul Cluster。

Consul agent有两种运行模式:Server和Client。这里的Server和Client只是Consul集群层面的区分,与搭建在Cluster之上 的应用服务无关。

以Server模式运行的Consul agent节点用于维护Consul集群的状态,官方建议每个Consul Cluster至少有3个或以上的运行在Server mode的Agent,Client节点不限。

环境配置如下:

Centos 7.3

主机名称IP作用是否允许远程访问
node1192.168.252.121consul server
node2192.168.252.122consul client
node3192.168.252.123consul client

关闭防火墙

  1. systemctl stop firewalld.service

Consul 最新版的下载地址:
https://releases.hashicorp.com/consul/1.0.1/consul1.0.1linux_amd64.zip

下载,然后unzip 解压,得到唯一,一个可执行文件

  1. cd /opt/

  2. wget https://releases.hashicorp.com/consul/1.0.1/consul_1.0.1_linux_amd64.zip

  3. unzip consul_1.0.1_linux_amd64.zip

  4. cp consul /usr/local/bin/

查看是否安装成功

  1. [root@node1 opt]# consul

出现如下结果,表示安装成功

  1. Usage: consul [--version] [--help] <command> [<args>]

  2. Available commands are:

  3.    agent          Runs a Consul agent

  4.    catalog        Interact with the catalog

  5.    event          Fire a new event

  6.    exec           Executes a command on Consul nodes

  7.    force-leave    Forces a member of the cluster to enter the "left" state

  8.    info           Provides debugging information for operators.

  9.    join           Tell Consul agent to join cluster

  10.    keygen         Generates a new encryption key

  11.    keyring        Manages gossip layer encryption keys

  12.    kv             Interact with the key-value store

  13.    leave          Gracefully leaves the Consul cluster and shuts down

  14.    lock           Execute a command holding a lock

  15.    maint          Controls node or service maintenance mode

  16.    members        Lists the members of a Consul cluster

  17.    monitor        Stream logs from a Consul agent

  18.    operator       Provides cluster-level tools for Consul operators

  19.    reload         Triggers the agent to reload configuration files

  20.    rtt            Estimates network round trip time between nodes

  21.    snapshot       Saves, restores and inspects snapshots of Consul server state

  22.    validate       Validate config files/directories

  23.    version        Prints the Consul version

  24.    watch          Watch for changes in Consul

检查版本

  1. [root@node1 opt]# consul version

  1. Consul v1.0.1

  2. Protocol 2 spoken by default, understands 2 to 3 (agent will automatically use protocol >2 when speaking to compatible agents)

Consul常用命令

命令解释示例
agent运行一个consul agentconsul agent -dev
join将agent加入到consul集群consul join IP
members列出consul cluster集群中的membersconsul members
leave将节点移除所在集群consul leave

consul agent 命令的常用选项

-data-dir

  • 作用:指定agent储存状态的数据目录

  • 这是所有agent都必须的

  • 对于server尤其重要,因为他们必须持久化集群的状态

-config-dir

  • 作用:指定service的配置文件和检查定义所在的位置

  • 通常会指定为”某一个路径/consul.d”(通常情况下,.d表示一系列配置文件存放的目录)

-config-file

  • 作用:指定一个要装载的配置文件

  • 该选项可以配置多次,进而配置多个配置文件(后边的会合并前边的,相同的值覆盖)

-dev

  • 作用:创建一个开发环境下的server节点

  • 该参数配置下,不会有任何持久化操作,即不会有任何数据写入到磁盘

  • 这种模式不能用于生产环境(因为第二条)

-bootstrap-expect

  • 作用:该命令通知consul server我们现在准备加入的server节点个数,该参数是为了延迟日志复制的启动直到我们指定数量的server节点成功的加入后启动。

-node

  • 作用:指定节点在集群中的名称

  • 该名称在集群中必须是唯一的(默认采用机器的host)

  • 推荐:直接采用机器的IP

-bind

  • 作用:指明节点的IP地址

  • 有时候不指定绑定IP,会报 Failedtogetadvertise address:MultipleprivateIPsfound.Pleaseconfigure one. 的异常

-server

  • 作用:指定节点为server

  • 每个数据中心(DC)的server数推荐至少为1,至多为5

  • 所有的server都采用raft一致性算法来确保事务的一致性和线性化,事务修改了集群的状态,且集群的状态保存在每一台server上保证可用性

  • server也是与其他DC交互的门面(gateway)

-client

  • 作用:指定节点为client,指定客户端接口的绑定地址,包括:HTTP、DNS、RPC

  • 默认是127.0.0.1,只允许回环接口访问

  • 若不指定为-server,其实就是-client

-join

  • 作用:将节点加入到集群

-datacenter(老版本叫-dc,-dc已经失效)

  • 作用:指定机器加入到哪一个数据中心中

启动服务

我们尝试一下:

-dev表示开发模式运行,使用-client参数可指定允许客户端使用什么ip去访问,例如-client192.168.252.121表示可以使用

http://192.168.252.121:8500/ui/ 去访问。

  1. consul agent -dev -client 192.168.252.121

Consul 的高可用

Consul Cluster集群架构图如下:

这边准备了三台Centos 7.3的虚拟机,主机规划如下,供参考:

主机名称IP作用是否允许远程访问
node1192.168.252.121consul server
node2192.168.252.122consul client
node3192.168.252.123consul client

搭建步骤

命令参数,参看上面详细介绍

在 node1 机器上启动 Consul

  1. cd /opt/

  2. mkdir data

  3. consul agent -data-dir /opt/data -node=192.168.252.121 -bind=0.0.0.0 -datacenter=dc1 -ui -client=192.168.252.121 -server -bootstrap-expect 1 > /dev/null 2>&1 &

在 node2 机器上启动 Consul,并且将node2节点加入到node1节点上

  1. cd /opt/

  2. mkdir data

  3. consul agent -data-dir /opt/data -node=192.168.252.122 -bind=0.0.0.0 -datacenter=dc1 -ui -client=192.168.252.122 -join=192.168.252.121 > /dev/null 2>&1 &

在 node3 机器上启动 Consul,并且将node3节点加入到node1节点上

  1. cd /opt/

  2. mkdir data

  3. consul agent -data-dir /opt/data -node=192.168.252.123 -bind=0.0.0.0 -datacenter=dc1 -ui  -client=192.168.252.123 -join=192.168.252.121 > /dev/null 2>&1 &

在node1上查看当前集群节点:

  1. consul members -rpc-addr=192.168.252.123:8400  

  2. consul leave -rpc-addr=192.168.252.123:8400  

http://192.168.252.121:8500/ui/ 去访问。

项目示例

新建项目: spring-cloud-consul-client

添加依赖

在项目 spring-cloud-consul-client pom.xml中引入需要的依赖内容:

  1. <dependency>

  2.    <groupId>org.springframework.cloud</groupId>

  3.    <artifactId>spring-cloud-starter-consul-discovery</artifactId>

  4. </dependency>

开启服务注册

客户端注册Consul时,它提供有关自身的元数据,如主机和端口,ID,名称和标签。默认情况下,将创建一个HTTP 检查,每隔10秒Consul命中/health端点。如果健康检查失败,则服务实例被标记为关键。

  1. package io.ymq.example.consul;

  2. import org.springframework.boot.SpringApplication;

  3. import org.springframework.boot.autoconfigure.SpringBootApplication;

  4. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

  5. import org.springframework.web.bind.annotation.RequestMapping;

  6. import org.springframework.web.bind.annotation.RestController;

  7. @SpringBootApplication

  8. @EnableDiscoveryClient

  9. @RestController

  10. public class ConsulApplication {

  11.    @RequestMapping("/")

  12.    public String home() {

  13.        return "Hello world";

  14.    }

  15.    public static void main(String[] args) {

  16.        SpringApplication.run(ConsulApplication.class, args);

  17.    }

  18. }

配置文件

在 application.yml配置文件中增加如下信息:如果Consul客户端位于localhost:8500以外,则需要配置来定位客户端

  1. spring:

  2.  application:

  3.    name: consul-client

  4.  cloud:

  5.    consul:

  6.      host: 192.168.252.121

  7.      port: 8500

  8.      discovery:

  9.        healthCheckPath: /

  10.        healthCheckInterval: 5s

如果Consul客户端位于localhost:8500以外的位置,则需要配置来定位客户端。例:

  1. host: 192.168.252.121

  2. port: 8500

HTTP健康检查路径 INSTALL

“10s”和“1m”分别表示10秒和1分

  1. discovery:

  2.    healthCheckPath: ${management.context-path}/health

  3.    healthCheckInterval: 15s

启动服务

到 spring-cloud-consul-client 项目根目录下,执行 mvn cleanpackage,把 target 目录下 生成的 jar spring-cloud-consul-client-0.0.1-SNAPSHOT.jar 上传服务器,发布项目

打包命令

  1. mvn clean package

发布命令

  1. nohup java -jar spring-cloud-consul-client-0.0.1-SNAPSHOT.jar  > /dev/null 2>&1 &

访问服务

http://192.168.252.121:8500/ui/#/dc1/nodes/192.168.252.121

通过上图HTTP健康检查,可以看到服务检测正常

源码下载

GitHub:https://github.com/souyunku/spring-cloud-examples/tree/master/spring-cloud-consul

码云:https://gitee.com/souyunku/spring-cloud-examples/tree/master/spring-cloud-consul

Contact

  • 作者:鹏磊

  • 出处:http://www.ymq.io

  • Email:admin@souyunku.com

  • 版权归作者所有,转载请注明出处

  • Wechat:关注公众号,搜云库,专注于开发技术的研究与知识分享


    您可能也对以下帖子感兴趣

    文章有问题?点此查看未经处理的缓存