Java之 Spring Cloud 微服务搭建 Consul（第一个阶段）SpringBoot项目实现商品服务器端是调用

Posted 2022-03-01 北芳科技

SpringCloud学习目录点击跳转对应的文章
Java之 Spring Cloud 微服务搭建（第一个阶段）【一】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务 Eureka （第一个阶段）【二】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务搭建Ribbon（第一个阶段）【三】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务搭建 Consul（第一个阶段）【四】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务搭建 Feign组件（第二个阶段）【一】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务搭建 Hystrix （第二个阶段）【二】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务搭建Sentinel （第二个阶段）【三】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务搭建网关 nginx，Zuul（第三个阶段）【一】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务搭建网关SpringCloud Gateway微服务网关GateWay（第三个阶段）【二】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务的链路追踪 Sleuth 和 Zipkin（第三个阶段）【三】【SpringBoot项目实现商品服务器端是调用】
Java之 Spring Cloud 微服务的 Spring Cloud Stream（第四个阶段）【一】【SpringBoot项目实现商品服务器端调用】
Java之 Spring Cloud 微服务的 SpringCloud Config 配置中心（第四个阶段）【二】【SpringBoot项目实现商品服务器端调用】
Java之 Spring Cloud 微服务的开源配置中心Apollo（第四个阶段）【三】【SpringBoot项目实现商品服务器端调用】

Eureka替换方案Consul

• Eureka替换方案Consul
• • 1、Eureka闭源的影响
  • • （1）Eureka闭源影响
    • （2）Eureka的替换方案
  • 2、什么是consul
  • • （1）consul 概述
    • （2）consul与Eureka的区别
    • • 1）一致性
      • 2）开发语言和使用
    • （3）consul的下载与安装
  • 3、consul的基本使用
  • • （1）服务注册与发现
    • • 1）注册服务
      • 2）服务查询
  • 4、consul的入门案例
  • • （1）创建一个新的工程
    • • 1）创建父工程
      • 2）创建子模块
      • • （一）创建product_service子模块
        • （二）创建order_service子模块
        • （三）完善相关概念的代码。在这里我们重点是学习Consul对其功能的内容做省略讲解点击下载上述相关源代码：[https://download.csdn.net/download/qq_44757034/43622658](https://download.csdn.net/download/qq_44757034/43622658)
      • 3）运行测试
  • 5、将微服务注册到注册中心consul
  • • （一）product_service注册到注册中心consul
    • • （1）在product_service当中引入依赖
      • （2）在product_service配置
      • （3）重新运行并测试
    • （二）order_service注册到注册中心consul
    • • （1）在order_service当中引入依赖
      • （2）在order_service配置
      • （3）运行测试
    • （三）调微服务接口
    • • （1）完善order_service当中的OrderApplication
      • （2）修改OrderController
      • （3）运行测试
  • 6、consul高可用集群
  • • （一）Consul的核心知识
    • • （1）Gossip协议
      • （2）RAFT一致性算法
    • （二）Consul 集群搭建
    • • （1） 准备环境
      • （2） 安装consul并启动
      • （3）每个节点加入集群
      • （4）在任意一台服务器中输入 consul members查看集群中的所有节点信息
    • （三） Consul 常见问题
    • • （1）节点和服务注销
      • （2）健康检查与故障转移

Eureka替换方案Consul

1、Eureka闭源的影响

（1）Eureka闭源影响

在Euraka的GitHub上，宣布Eureka 2.x闭源。近这意味着如果开发者继续使用作为 2.x 分支上现有工作repo 一部分发布的代码库和工件，则将自负风险。

（2）Eureka的替换方案

Zookeeper
ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

Consul
consul是近几年比较流行的服务发现工具，工作中用到，简单了解一下。consul的三个主要应用场景：服务发现、服务隔离、服务配置。

Nacos
Nacos 是阿里巴巴推出来的一个新开源项目，这是一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。
Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。 Nacos 是构建以“服务”为中心的现代应用架构 (例如微服务范式、云原生范式) 的服务基础设施。

2、什么是consul

（1）consul 概述

官网地址：https://www.consul.io/

Consul 是 HashiCorp 公司推出的开源工具，用于实现分布式系统的服务发现与配置。

与其它分布式服务注册与发现的方案，Consul 的方案更“一站式”，内置了服务注册与发现框 架、分布一致性协议实现、健康检查、Key/Value 存储、多数据中心方案，不再需要依赖其它工具（比如 ZooKeeper 等）。

使用起来也较 为简单。Consul 使用 Go 语言编写，因此具有天然可移植性(支持Linux、windows和Mac OS X)；安装包仅包含一个可执行文件，方便部署，与 Docker 等轻量级容器可无缝配合。

Consul 的优势：

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

特性：

• 服务发现
• 健康检查
• Key/Value 存储
• 多数据中心

（2）consul与Eureka的区别

1）一致性

Consul强一致性（CP）
服务注册相比Eureka会稍慢一些。因为Consul的raft协议要求必须过半数的节点都写入成功才认为注册成功Leader挂掉时，重新选举期间整个consul不可用。保证了强一致性但牺牲了可用性。Eureka保证高可用和最终一致性（AP）
服务注册相对要快，因为不需要等注册信息replicate到其他节点，也不保证注册信息是否
replicate成功当数据出现不一致时，虽然A, B上的注册信息不完全相同，但每个Eureka节点依然能够正常对外提供服务，这会出现查询服务信息时如果请求A查不到，但请求B就能查到。如此保证了可用性但牺牲了一致性。

2）开发语言和使用

eureka就是个servlet程序，跑在servlet容器中Consul则是go编写而成，安装启动即可

（3）consul的下载与安装

Consul 不同于 Eureka 需要单独安装，访问Consul 官网下载 Consul 的最新版本，我这里是
consul1.5x。根据不同的系统类型选择不同的安装包，从下图也可以看出 Consul 支持所有主流系统。

在linux虚拟中下载consul服务

## 从官网下载的Consul服务
wget https://releases.hashicorp.com/consul/1.5.3/consul_1.5.3_linux_amd64.zip

##使用unzip命令解压
unzip consul_1.5.3_linux_amd64.zip

##测试一下
consul

这里使用的的是Centos7

开启端口号

firewall-cmd --zone=public --add-port=8500/tcp --permanent   # 开放5672端口

firewall-cmd --reload   # 配置立即生效

启动consul服务

##已开发者模式快速启动，-client指定客户端可以访问的ip地址
[root@node01 ~]# ./consul agent -dev -client=0.0.0.0
==> Starting Consul agent...
           Version: 'v1.5.3'
           Node ID: '49ed9aa0-380b-3772-a0b6-b0c6ad561dc5'
         Node name: 'node01'
       Datacenter: 'dc1' (Segment: '<all>')
           Server: true (Bootstrap: false)
       Client Addr: [127.0.0.1] (HTTP: 8500, HTTPS: -1, gRPC: 8502, DNS: 8600)
     Cluster Addr: 127.0.0.1 (LAN: 8301, WAN: 8302)
           Encrypt: Gossip: false, TLS-Outgoing: false, TLS-Incoming: false, 
Auto-Encrypt-TLS: false

启动成功之后访问： http://IP:8500 ，可以看到 Consul 的管理界面

3、consul的基本使用

Consul 支持健康检查,并提供了 HTTP 和 DNS 调用的API接口完成服务注册，服务发现，以及K/V存储这些功能。
接下来通过发送HTTP请求的形式来了解一下Consul

（1）服务注册与发现

1）注册服务

通过Insomnia发送put请求到http://ip:8500/v1/catalog/register地址可以完成服务注册

 "Datacenter": "dc1", 
 "Node": "node01", 
 "Address": "ip地址",
 "Service": 
 "ID":"mysql-01",
 "Service": "mysql", 
 "tags": ["master","v1"], 
 "Address": "ip地址",
 "Port": 3306
 

访问刚刚的管理界面 http://IP:8500

2）服务查询

发送get请求到http://ip:8500/v1/catalog/services查看所有的服务列表

发送get请求到http://ip:8500/v1/catalog/service/服务名查看具体的服务详

4、consul的入门案例

• 提供一个商品微服务
• 提供一个订单系统

将微服务注册到注册中心
服务的消费者从consul

（1）创建一个新的工程

1）创建父工程

引入依赖

<?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">
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.itbluebox</groupId>
    <artifactId>spring_cloud_consul_demo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.6.RELEASE</version>
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-logging</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.4</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>


    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Greenwich.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>


    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

2）创建子模块

（一）创建product_service子模块

引入依赖

<?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>spring_cloud_consul_demo</artifactId>
        <groupId>cn.itbluebox</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>product_service</artifactId>
    <dependencies>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.32</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        
        <!--actuator的健康检查-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
    </dependencies>

</project>

创建包结构

配置文件application.yml

server:
  port: 9001 #端口
spring:
  application:
    name: service-product #服务名称
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8
    username: root
    password: root
  jpa:
    database: MySQL
    show-sql: true
    open-in-view: true

（二）创建order_service子模块

详细代码省略

（三）完善相关概念的代码。在这里我们重点是学习Consul对其功能的内容做省略讲解点击下载上述相关源代码：https://download.csdn.net/download/qq_44757034/43622658

3）运行测试

访问测试:
http://localhost:9002/order/buy/1

5、将微服务注册到注册中心consul

（一）product_service注册到注册中心consul

（1）在product_service当中引入依赖

  <!--springcloud 提供的对基于consul的服务发现-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!--actuator的健康检查-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

（2）在product_service配置

server:
  port: 9001 #端口
spring:
  application:
    name: service-product #服务名称
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&characterEncoding=utf8
    username: root
    password: root
  jpa:
    database: MySQL
    show-sql: true
    open-in-view: true
  ###开始配置consul的服务注册
  cloud:
    consul:
      host: ip #consul服务器的主机地址
      port: 8500 #consul服务器的ip地址
      discovery:
        #是否需要注册
        register: true
        #注册的实例ID (唯一标志)
        instance-id: $spring.application.name-1  #会获取到上面对应的配置信息
        #服务的名称
        service-name: $spring.application.name #会获取到上面对应的配置信息
        #服务的请求端口
        port: $server.port #会获取到上面对应的配置信息
        #指定开启ip地址注册
        prefer-ip-address: true  #会获取到上面对应的配置信息
        #当前服务的请求ip
        ip-address: $spring.cloud.client.ip-address  #会获取到上面对应的配置信息

（3）重新运行并测试

访问http://ip:8500/ui/dc1/services



我们发现
Service Checks是叉

设置Consul的心跳默认关闭，在配置文件中开启即可

        heartbeat:
          enabled: true

重新运行测试

刷新页面

（二）or

以上是关于Java之 Spring Cloud 微服务搭建 Consul（第一个阶段）SpringBoot项目实现商品服务器端是调用的主要内容，如果未能解决你的问题，请参考以下文章

Java之 Spring Cloud 微服务搭建 Consul（第一个阶段）SpringBoot项目实现商品服务器端是调用

Java之 Spring Cloud 微服务搭建Sentinel （第二个阶段）SpringBoot项目实现商品服务器端是调用

Java之 Spring Cloud 微服务搭建 Hystrix （第二个阶段）SpringBoot项目实现商品服务器端是调用

Java之 Spring Cloud 微服务搭建（第一个阶段）SpringBoot项目实现商品服务器端是调用

Java之 Spring Cloud 微服务搭建网关SpringCloud Gateway微服务网关GateWay（第三个阶段）SpringBoot项目实现商品服务器端是调用

Java之 Spring Cloud 微服务搭建网关SpringCloud Gateway微服务网关GateWay（第三个阶段）SpringBoot项目实现商品服务器端是调用