1. Consul简介

  1. 是什么：微服务的服务注册中心 Consul官网

Consul是一套开源的分布式服务发现和配置管理系统，由HashiCorp公司采用Go语言开发

  • 提供了微服务系统中心的服务治理，配置中心，控制总线等功能。这些功能中的每一个都可以根据需要单独使用，也可以一起使用，以构建全方位的服务网格。
  • 总之Consul提供了一种完整的服务网格解决方案。
  • 它具有很多优点：
    • 包括，基于raft协议，比较简洁；支持健康检查，同时支持HTTP和DNS协议支持跨数据中心的WAN集群。
    • 提供图形界面 跨平台，支持Linux，MAC，Windows
  1. 能干嘛：The key features of Consul are:
  • Service Discovery：服务发现，提供HTTP和DNS两种发现方式
  • Health Checking: 健康检查，支持多种方式，HTTP，TCP，Docker，Shell脚本定制化
  • KV Store: Key，Value的存储方式
  • Secure Service Communication: 安全的服务交流
  • Multi Datacenter:多数据中心
  • 可视化web界面
  1. 下载

下载页面

  1. 中文文档

中文文档

2. 安装并运行Consul

下载zip完成后解压，只有一个exe文件。在解压目录下打开cmd，输入consul --version 即可查看consul版本
image.png
使用开发者模式启动consul agent -dev
访问可视化页面：localhost:8500
image.png

3. 生产者服务注册：consul

3.1 新建Module支付服务：cloud-providerconsul-payment8006

3.2 pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>jdk8cloud2021</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-providerconsul-payment8006</artifactId>
  14.     <properties>
  15.         <maven.compiler.source>8</maven.compiler.source>
  16.         <maven.compiler.target>8</maven.compiler.target>
  17.     </properties>
  19.     <dependencies>
  20.         <!--SpringCloud consul-server -->
  21.         <dependency>
  22.             <groupId>org.springframework.cloud</groupId>
  23.             <artifactId>spring-cloud-starter-consul-discovery</artifactId>
  24.         </dependency>
  25.         <!-- SpringBoot整合Web组件 -->
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-web</artifactId>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter-actuator</artifactId>
  33.         </dependency>
  34.         <!--日常通用jar包配置-->
  35.         <dependency>
  36.             <groupId>org.springframework.boot</groupId>
  37.             <artifactId>spring-boot-devtools</artifactId>
  38.             <scope>runtime</scope>
  39.             <optional>true</optional>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>org.projectlombok</groupId>
  43.             <artifactId>lombok</artifactId>
  44.             <optional>true</optional>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-test</artifactId>
  49.             <scope>test</scope>
  50.         </dependency>
  51.     </dependencies>
  52. </project>

3.3 yml

  1. ###consul服务端口号
  2. server:
  3.   port: 8006
  5. spring:
  6.   application:
  7.     name: consul-provider-payment
  8.   ####consul注册中心地址
  9.   cloud:
  10.     consul:
  11.       host: localhost
  12.       port: 8500
  13.       discovery:
  14.         service-name: ${spring.application.name}

3.4 主启动类

  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. public class PaymentMain8006 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(PaymentMain8006.class, args);
  6.     }
  7. }

3.5 业务类(controller)

  1. @RestController
  2. @Slf4j
  3. public class PaymentController {
  4.     @Value("${server.port}")
  5.     private String serverPort;
  7.     @RequestMapping(value = "/payment/consul")
  8.     public String paymentConsul() {
  9.         return "springcloud with consul: " + serverPort + "\t" + UUID.randomUUID().toString();
  10.     }
  11. }

3.6 测试

启动8006服务
image.pngimage.png

4 消费者服务注册

4.1 新建cloud-consumerconsul-order80

4.2 pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>jdk8cloud2021</artifactId>
  7.         <groupId>com.atguigu.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumerconsul-order80</artifactId>
  14.     <properties>
  15.         <maven.compiler.source>8</maven.compiler.source>
  16.         <maven.compiler.target>8</maven.compiler.target>
  17.     </properties>
  18.     <dependencies>
  19.         <!--SpringCloud consul-server -->
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-consul-discovery</artifactId>
  23.         </dependency>
  24.         <!-- SpringBoot整合Web组件 -->
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-web</artifactId>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-actuator</artifactId>
  32.         </dependency>
  33.         <!--日常通用jar包配置-->
  34.         <dependency>
  35.             <groupId>org.springframework.boot</groupId>
  36.             <artifactId>spring-boot-devtools</artifactId>
  37.             <scope>runtime</scope>
  38.             <optional>true</optional>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.projectlombok</groupId>
  42.             <artifactId>lombok</artifactId>
  43.             <optional>true</optional>
  44.         </dependency>
  45.         <dependency>
  46.             <groupId>org.springframework.boot</groupId>
  47.             <artifactId>spring-boot-starter-test</artifactId>
  48.             <scope>test</scope>
  49.         </dependency>
  50.     </dependencies>
  52. </project>

4.3 yml

  1. ###consul服务端口号
  2. server:
  3.   port: 80
  5. spring:
  6.   application:
  7.     name: cloud-consumer-order
  8.   ####consul注册中心地址
  9.   cloud:
  10.     consul:
  11.       host: localhost
  12.       port: 8500
  13.       discovery:
  14.         #hostname: 127.0.0.1
  15.         service-name: ${spring.application.name}

4.4 主启动类

  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. public class OrderConsulMain80 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(OrderConsulMain80.class, args);
  6.     }
  7. }

4.5 配置类 配置Bean RestTemplate

  1. @Configuration
  2. public class ApplicationContextConfig {
  3.     @Bean
  4.     @LoadBalanced
  5.     public RestTemplate getRestTemplate() {
  6.         return new RestTemplate();
  7.     }
  8. }

4.6 业务类controller

  1. @RestController
  2. @Slf4j
  3. public class OrderConsulController {
  4.     public static final String INVOKE_URL = "http://cloud-provider-pament";
  6.     @Resource
  7.     private RestTemplate restTemplate;
  9.     @GetMapping("/consumer/payment/consul")
  10.     public String paymentInfo() {
  11.         String result = restTemplate.getForObject(INVOKE_URL, String.class);
  12.         System.out.println("消费者调用支付服务(consule)--->result:" + result);
  13.         return result;
  14.     }
  15. }

4.7 测试

image.pngimage.png