【SpringCloud笔记】（4）服务注册中心之Consul

Consul

概述

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

提供微服务系统中的服务治理、配置中心、控制总线等功能。

这些功能中的每一个都可以根据需要单独使用，也可以一起使用构建全方位的服务网格

官网：https://www.consul.io/intro/index.html

中文：https://www.springcloud.cc/spring-cloud-consul.html

下载地址：https://www.consul.io/downloads.html

功能：

服务发现：提供HTTP和DNS两种发现方式

健康监测：支持多种方式，HTTP、TCP、Docker、Shell脚本定制化

KV存储：Key、Value的存储方式

多数据中心：Consul支持多数据中心

可视化Web界面

安装与运行

window安装

下载完成后只有一个consul.exe文件，实际上是不用安装的，在exe文件所在目录打开dos窗口使用即可。

使用开发模式启动：consul agent -dev

访问8500端口，即可访问首页

使用docker启动consul容器

拉取镜像：docker pull consul:1.6.1

启动镜像：docker run -d --restart=always -p 8500:8500  -e  CONSUL_BIND_INTERFACE='eth0'

 --name=consulone consul:1.6.1 agent  -server -bootstrap -ui -client='0.0.0.0'

访问首页：http://192.168.254.130:8500/ui

创建微服务

服务提供者cloud-providerconsul-payment8006注册进consul

pom文件

<artifactId>cloud-providerconsul-payment8006</artifactId>

<dependencies>
    <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
    <dependency>
        <groupId>com.mzr.springcloud</groupId>
        <artifactId>cloud-api-commons</artifactId>
        <version>${project.version}</version>
    </dependency>
    <!--SpringCloud consul-server -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-consul-discovery</artifactId>
    </dependency>
    <!-- SpringBoot整合Web组件 -->
    <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>
</dependencies>

yml文件

server:
  port: 8006

spring:
  application:
    name: consul-provider-payment
  cloud:
    consul:
      #host: localhost
      #我使用的docker启动consul，所以这里host为虚拟机ip，如果使用的windows安装填localhost即可
      host: 192.168.254.130
      port: 8500
      discovery:
        service-name: ${spring.application.name}

主启动类

@SpringBootApplication
@EnableDiscoveryClient
public class PaymentMain8006 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8006.class, args);}
}

controller层

@RestController
@Slf4j
public class PaymentController
{
    @Value("${server.port}")
    private String serverPort;

    @RequestMapping(value = "/payment/consul")
    public String paymentConsul()
    {
        return "springcloud with consul: "+serverPort+"\t   "+ UUID.randomUUID().toString();
    }
}

启动测试

可以看到服务提供者已经注册进consul

服务提供者cloud-consumerconsul-order80注册进consul

pom文件

<artifactId>cloud-consumerconsul-order80</artifactId>

    <dependencies>
        <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
        <dependency>
            <groupId>com.mzr.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!--SpringCloud consul-server -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- SpringBoot整合Web组件 -->
        <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>
    </dependencies>

yml文件

server:
  port: 80

spring:
  application:
    name: consul-consumer-order
  cloud:
    consul:
      host: 192.168.254.130
      port: 8500
      discovery:
        service-name: ${spring.application.name}

主启动类

@SpringBootApplication
@EnableDiscoveryClient
public class OrderConsulMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderMain80.class, args);
    }
}

配置bean

@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

}

controller层

@RestController
@Slf4j
public class OrderController {

    public static final String INVOKE_URL = "http://cloud-provider-payment";

    @Resource
    private RestTemplate restTemplate;

    @RequestMapping("/customer/payment/consul")
    public String paymentInfo(){
        String result = restTemplate.getForObject(INVOKE_URL + "/payment/consul",String.class);
        return result;
    }
}