一. Consul 简单介绍
- Consul 用 go 语言写的服务管理系统,提供了服务治理,配置中心,控制总线等功能,优点: 基于raft协议比较简洁,支持健康检查,支持http和dns协议,支持夸数据中心的wan集群,提供图形化界面,夸平台包括Linux,Mac,Windows
- Consul 下载地址 : http://www.consul.io/downloads.html
- 推荐 Consul 教程中文文档 : http://springcloud.cc/spring-cloud-consul.html
- Consul 默认端口号是 8500
1. Consul 的 windows 单机版安装运行
- 在官网下载windows 64 位 Consul 压缩包,解压到非中文路径下,只有一个".exe"结尾的文件,双击文件运行
- 在文件路径下cmd打开命令行输入 “consul --version” 可以查看版本
- 也可以在路径下进入cmd命令行,输入"consul agent -dev" 命令运行
- 运行成功后也可访问 Consul 图形化界面 “http://localhost:8500/ui/dc1/services”
二. 配置服务注册到 Consul
- 安装启动 Consul
- 服务提供方服务消费方同时引入 Consul 依赖
<!--SpringCloud consul-server-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
- 服务提供方与服务消费方的启动类都要添加 @EnableDiscoveryClient 注解修饰
- 服务消费方创建配置类创建 RestTemplate 注入到容器中,使用 @LoadBalanced 修饰开启Ribbon负载
- 服务消费方通过 RestTemplate 根据服务名称在 Consul 注册中心获取指定服务的调用地址,负载调用
1. 服务提供方 yml 文件配置注册到 Consul
server:
port: 8006 #当前服务端口号
spring:
application:
name: cloud-consul-procider-payment8006 #当前服务名称
#=============向consul注册当前服务配置==============================
cloud:
consul:
host: localhost #当前服务要连接的consul ip 地址
port: 8500 #当前服务要连接的consul 端口号
discovery:
service-name: ${spring.application.name} #当前服务向consul注册暴露的名称
#=============向consul注册当前服务配置 end==============================
2. 服务消费方 yml 文件配置注册到 Consul
server:
port: 80 #当前服务端口号
spring:
application:
name: cloud-consul-consumer-order #当前服务名称
#=============向consul注册当前服务配置==============================
cloud:
consul:
host: localhost #当前服务要注册的 consul ip 地址
port: 8500 #当前服务要注册的 consul 端口号
discovery:
service-name: ${spring.application.name} #当前服务向consul注册时暴露的名称
#=============向consul注册当前服务配置 end==============================
3. 服务消费方配置 RestTemplate 注入到容器中
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 ApplicationContextConfig {
@Bean
@LoadBalanced
public RestTemplate getRestTemplate(){
return new RestTemplate ();
}
}
4. 服务消费方使用 RestTemplate 根据服务名称调用指定服务
import com.common.result.JsonResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.client.RestTemplate;
@Controller
public class OrderController {
@Autowired
private RestTemplate restTemplate;
//服务提供方在Consul上注册的名称
private String serverName="cloud-consul-procider-payment8006";
@RequestMapping(value = "/consumerConsul", method = RequestMethod.GET)
@ResponseBody
public JsonResult getVal(){
return restTemplate.getForObject("http://"+serverName+"/consulTest",JsonResult.class);
}
}
其它配置
spring.cloud.consul.host:配置consul地址
spring.cloud.consul.port:配置consul端口
spring.cloud.consul.discovery.enabled:启用服务发现
spring.cloud.consul.discovery.register:启用服务注册
spring.cloud.consul.discovery.deregister:服务停止时取消注册
spring.cloud.consul.discovery.prefer-ip-address:表示注册时使用IP而不是hostname
spring.cloud.consul.discovery.health-check-interval:健康检查频率
spring.cloud.consul.discovery.health-check-path:健康检查路径
spring.cloud.consul.discovery.health-check-critical-timeout:健康检查失败多长时间后,取消注册
spring.cloud.consul.discovery.instance-id:服务注册标识
问题: 如果服务宕机后,consul节点还存在,查看是否同时配置了:
spring.cloud.consul.discovery.deregister:服务停止时取消注册
spring.cloud.consul.discovery.health-check-critical-timeout:健康检查失败多长时间后,取消注册