（第四篇）spring cloud之Consul注冊中心

一、介紹

二、安裝

三、整合代碼使用

1、創建服務提供者8006

2、創建服務消費者80

3、Eureka、zookeeper和consul的異同點

一、介紹

????????Consul 是一套開源的分布式服務發現和配置管理系統，由 HashiCorp 公司用 Go 語言開發。它提供了微服務系統中的服務治理、配置中心、控制總線等功能。這些功能中的每一個都可以根據需要單獨使用

????????優點包括：基于 raft 協議，比較簡潔；支持健康檢查, 同時支持 HTTP 和 DNS 協議支持跨數據中心的 WAN 集群提供圖形界面跨平臺，支持 Linux、Mac、Windows。

官網https://www.consul.io/intro/index.html服務發現：提供HTTP和DNS兩種發現方式。

健康檢查：支持多種方式，HTTP、TCP、Docker、Shell腳本定制化監控

kv存儲：Key、Value的存儲方式

多數據中心以及可視化Web界面

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

二、安裝

下載consul文件，window雙擊，Linux先修改權限，然后./consul

查看本版信息

./consul --version

已開發模式啟動

./consul agent -dev?-ui -client=0.0.0.0

訪問：http://192.168.10.40:8500

三、整合代碼使用

1、創建服務提供者8006

（1）、創建模塊cloud-providerconsul-payment8006

（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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.hk.cloudstudy</groupId><artifactId>SecondSpringCloud</artifactId><version>1.0-SNAPSHOT</version></parent><groupId>com.shxls</groupId><artifactId>cloud-providerconsul-payment8006</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><!--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><!--日常通用jar包配置--><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）添加yml文件

###consul服務端口號
server:port: 8006spring:application:name: consul-provider-payment####consul注冊中心地址cloud:consul:host: 192.168.10.40port: 8500discovery:#hostname: 127.0.0.1service-name: ${spring.application.name}heartbeat:enabled: true

（4）添加啟動類

package com.hk.cloudstudy;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient
public class PaymentMain8006 {public static void main(String[] args) {SpringApplication.run(PaymentMain8006.class,args);}
}

（5）創建controller

package com.hk.cloudstudy.controller;import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.UUID;@RestController
public class PaymentController {@Value("${server.port}")private String serverPort;@GetMapping("/payment/consul")public String paymentInfo() {return "springcloud with consul: "+serverPort+"\t\t"+ UUID.randomUUID().toString();}
}

（6）啟動

訪問? ?http://localhost:8006/payment/consul

2、創建服務消費者80

（1）、創建服務cloud-consumerconsul-order80

（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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.hk.cloudstudy</groupId><artifactId>SecondSpringCloud</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>cloud-consumerconsul-order80</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><!--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><!--日常通用jar包配置--><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）創建yml文件

###consul服務端口號
server:port: 80spring:application:name: cloud-consumer-order####consul注冊中心地址cloud:consul:host: 192.168.10.40port: 8500discovery:#hostname: 127.0.0.1service-name: ${spring.application.name}heartbeat:enabled: true

（4）添加啟動類

package com.hk.cloudstudy;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient //該注解用于向使用consul或者zookeeper作為注冊中心時注冊服務
public class OrderConsulMain80 {public static void main(String[] args) {SpringApplication.run(OrderConsulMain80.class,args);}
}

（5）配置bean

package com.hk.cloudstudy.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;@Configuration
public class ApplicationContextBean {@Bean@LoadBalancedpublic RestTemplate getRestTemplate() {return new RestTemplate();}
}

（6）創建controller

package com.hk.cloudstudy.controller;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;@RestController
public class OrderConsulController {public static final String INVOKE_URL = "http://consul-provider-payment";@Autowiredprivate RestTemplate restTemplate;@GetMapping(value = "/consumer/payment/consul")public String paymentInfo() {String result = restTemplate.getForObject(INVOKE_URL+"/payment/consul", String.class);System.out.println("消費者調用支付服務(consule)--->result:" + result);return result;}
}

（7）啟動調用