Spring Cloud（五）：Consul服务注册与发现

矫情吗；* 2022-11-07 11:43 148阅读 0赞

## 1. Consul简介 ##

Consul是一套开源的分布式服务发现和配置管理系统，由HashiCorp公司使用Go语言开发。  
提供了微服务系统中的服务治理、配置中心、控制总线等功能，这些功能每一个都可以根据需要单独使用，也可以一起使用构建全方位的服务网络，总之，Consul提供了一种完整的服务网格解决方案。

具有很多优点：包括：基于raft协议，比较简洁。支持健康检查，同时支持HTTP和DNS协议 支持跨数据中心的WAN集群 提供图形界面，跨平台，支持windows、linux、mac。

*  服务发现：提供HTTP和DNS两种发现方式
 *  健康监测：支持多种协议，HTTP、TCP、Docker、Shell脚本定制化
 *  KV存储：key , Value的存储方式
 *  多数据中心：Consul支持多数据中心
 *  可视化Web界面

## 2. Consul安装 ##

教程：https://www.springcloud.cc/spring-cloud-consul.html

### 2.1 docker版 ###

下载地址：https://www.consul.io/downloads.html  
太慢可以使用docker安装

docker pull consul:1.6.1

docker run --name consul -p 8500:8500  -d consul:1.6.1

访问：consul所在主机ip:8500  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]

### 2.2 Windows 版 ###

*  下载完成后只有一个consul.exe文件，硬盘路径下双击运行，查看版本信息

consul --version

*  使用开发模式启动

consul agent -dev

访问：http;//localhost:8500

## 3 服务提供者 ##

### 3.1 建module ###

新建 cloud-providerconsul-payment8006 模块

### 3.2 改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>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloud-providerconsul-payment8006</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-consul-discovery</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
    </project>

### 3.3 建yml ###

server:
      port: 8006
    
    spring:
      application:
        name: consul-provider-payment
    
    # consul注册中心地址
      cloud:
        consul:
          host: localhost #consul所在服务器的ip
          port: 8500
          discovery:
            #hostname: 127.0.0.1
            service-name: ${
        spring.application.name}
            heartbeat:
              enabled: true

### 3.4 主启动类 ###

package com.lele.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * @author: lele
     * @date: 2021/3/12 7:17
     * @description:
     */
    @SpringBootApplication
    @EnableDiscoveryClient
    public class PaymentMain8006 {
        
    
        public static void main(String[] args) {
        
            SpringApplication.run(PaymentMain8006.class, args);
        }
    }

### 3.5 controller ###

package com.lele.springcloud.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.UUID;
    
    /**
     * @author: lele
     * @date: 2021/3/12 7:19
     * @description:
     */
    @RestController
    @Slf4j
    public class PaymentController {
        
    
        @Value("${server.port}")
        private String serverPort;
    
        @RequestMapping(value = "/payment/consul")
        public String paymentConsul() {
        
            return "spring cloud with consul:" + serverPort + "\t" + UUID.randomUUID().toString();
        }
    }

### 3.6 测试 ###

启动 8006，访问 http://localhost:8006/payment/consul  
![在这里插入图片描述][2021031207294721.png]

## 4. 服务消费者 ##

### 4.1 建module ###

新建 cloud-consumerconsul-order80 模块

### 4.2 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>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloud-consumerconsul-order80</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-consul-discovery</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
    </project>

### 4.3 yml ###

server:
      port: 80
    
    spring:
      application:
        name: cloud-consumer-order
      cloud:
        consul:
          host: localhost
          port: 8500
          discovery:
            service-name: ${
        spring.application.name}
            heartbeat:
              enabled: true

### 4.4 主启动类 ###

package com.lele.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * @author: lele
     * @date: 2021/3/13 18:49
     * @description:
     */
    @SpringBootApplication
    @EnableDiscoveryClient  //该注解用于向使用consul或者zookeeper作为注册中心时注册服务
    public class OrderConsulMain80 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(OrderConsulMain80.class, args);
        }
    }

*  ApplicationContextConfig

package com.lele.springcloud.config;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * @author: lele
     * @date: 2021/3/13 18:56
     * @description:
     */
    @Configuration
    public class ApplicationContextConfig {
        
        @Bean
        @LoadBalanced
        public RestTemplate getRestTemplate() {
        
            return new RestTemplate();
        }
    }

### 4.5 controller ###

package com.lele.springcloud.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import javax.annotation.Resource;
    
    /**
     * @author: lele
     * @date: 2021/3/13 19:00
     * @description:
     */
    @RestController
    @Slf4j
    public class OrderConsulController {
        
        public static final String INVOKE_URL = "http://consul-provider-payment";
    
        @Resource
        private RestTemplate restTemplate;
    
        @GetMapping(value = "/consumer/payment/consul")
        public String paymentInfo() {
        
            String result = restTemplate.getForObject(INVOKE_URL+"/payment/consul", String.class);
            return result;
        }
    }

### 4.6 测试 ###

启动 8006，访问 http://localhost:8006/payment/consul；  
![在这里插入图片描述][20210313215716803.png]

再启动 Consul80，访问 http://localhost/consumer/payment/consul  
![在这里插入图片描述][20210313215726474.png]

## 5. 三个注册中心异同点 ##

**CAP**

*  C:Consistency(强一致性)
 *  A:Availability(可用性)
 *  P:Partition tolerance(分区容错)  
    CAP理论关注粒度是数据，而不是整体系统设计的策略。

**经典CAP图**

*  最多只能同时较好的满足两个；
 *  CAP理论的核心是：一个分布式系统不可能同时很好的满足一致性、可用性和分区容错性这三个需求，因此，根据CAP原理将NoSQL数据库分成了满足CA原则、满足CP原则和满足AP原则三大类：
    
     *  CA-单点集群，满足一致性，可用性的系统，通常在可扩展性上不太强大
     *  CP-满足一致性，分区容错性的系统，通常性能不是特别高
     *  AP-满足可用性，分区容错性的系统，通常可能对一致性要求低一些。  
        ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]

**AP(Eureka)**  
AP架构，当网络分区出现后，为了保证可用性，系统B可以返回旧值，保证系统的可用性。  
结论：违背了一致性C的要求，只满足了可用性和分区容错，即AP。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]

**CP(Zookeeper/Consul)**  
CP架构，当网络分区出现后，为了保证一致性，就必须拒接请求，否则无法保证一致性  
结论：违背了可用性A的要求，只满足一致性和分区容错，即CP。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]: /images/20221023/dc4b824d78cd4bf48978dfb5d9ef4828.png
[2021031207294721.png]: /images/20221023/3bf726b6357e484ba3a078d481da7a55.png
[20210313215716803.png]: /images/20221023/39aeb3a153c24114b3c8e3c6638d6615.png
[20210313215726474.png]: /images/20221023/a9be2811265344e5bea974f5a2f9373e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]: /images/20221023/fb45608c9439432fb0b0ecf838f8c34d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]: /images/20221023/82b6aea3181f43ee8c9eb3705600811d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]: /images/20221023/2dff98bacd834b2fa33ed6c62d6af5d6.png