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
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
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;
再启动 Consul80,访问 http://localhost/consumer/payment/consul
5. 三个注册中心异同点
CAP
- C:Consistency(强一致性)
- A:Availability(可用性)
- P:Partition tolerance(分区容错)
CAP理论关注粒度是数据,而不是整体系统设计的策略。
经典CAP图
- 最多只能同时较好的满足两个;
- CAP理论的核心是:一个分布式系统不可能同时很好的满足一致性、可用性和分区容错性这三个需求,因此,根据CAP原理将NoSQL数据库分成了满足CA原则、满足CP原则和满足AP原则三大类:
- CA-单点集群,满足一致性,可用性的系统,通常在可扩展性上不太强大
- CP-满足一致性,分区容错性的系统,通常性能不是特别高
- AP-满足可用性,分区容错性的系统,通常可能对一致性要求低一些。
AP(Eureka)
AP架构,当网络分区出现后,为了保证可用性,系统B可以返回旧值,保证系统的可用性。
结论:违背了一致性C的要求,只满足了可用性和分区容错,即AP。
CP(Zookeeper/Consul)
CP架构,当网络分区出现后,为了保证一致性,就必须拒接请求,否则无法保证一致性
结论:违背了可用性A的要求,只满足一致性和分区容错,即CP。