首先我们需要安装consul,到官网下载Consul
Install | Consul | HashiCorp Developer
在解压的consul目录下 执行启动命令
consul agent -dev 启动服务
-dev表示开发模式 -server表示服务模式
启动后在浏览器访问8500端口
http://localhost:8500/可以看到服务管理界面
项目要注册到中心需要做一些改动
一、添加pom依赖
添加cloud依赖
<dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> 添加consul依赖 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-consul-discovery</artifactId> </dependency>
二、添加yml文件中的consul配置
spring: application: name: test-demo #注册到注册中心名称 cloud: consul: host: localhost #注册中心服务ip port: 8500 discovery: heartbeat: enabled: true service-name: ${spring.application.name} prefer-ip-address: true
三、启动类添加注解
@EnableDiscoveryClient 应用可以自动注册到服务注册中心。
@EnableDiscoveryClient
@SpringBootApplication
public class Mis001Application {
public static void main(String[] args) {
SpringApplication.run(Mis001Application.class, args);
}
}
到这里我们就配置好了项目的注册,启动后该服务会自动注册到注册中心
启动项目后我们在注册中心可以看到注册的服务,可以看到我们注册的服务
通过
LoadBalancerClient和DiscoveryClient 可以读取注册中心服务的信息
操作Consul的K/v存储
我们先在Consul中新建一个文件
写完之后点击下面的保存
下面我们修改我们的项目
1.首先我们在pom文件中添加依赖
<!--consul 添加K/V存储-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-consul-config</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
2.在配置文件中添加consul中的config配置信息
spring:
application:
name: test-demo #注册到注册中心名称
cloud:
consul:
host: localhost #注册中心服务ip
port: 8500
discovery:
heartbeat:
enabled: true
service-name: ${spring.application.name}
prefer-ip-address: true
config:
profile-separator: ',' #默认的分隔符为 "," 我们自定义为"-"
format: yaml #文件格式为yml
fail-fast: true
prefix: config #基础文件夹名称
default-context: application
data-key: data
新建Myconfig类
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;
/**
* 获取consult config 的key/vlue
*/
@RefreshScope
@ConfigurationProperties(prefix = "jdbc")
public class MyConfig {
private String username;
private String password;
private My my;
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public My getMy() {
return my;
}
public void setMy(My my) {
this.my = my;
}
}
My 类
public class My {
private String year;
public String getYear() {
return year;
}
public void setYear(String year) {
this.year = year;
}
}
新建ConfigController
@RestController
public class ConfigController {
@Autowired
private MyConfig myConfig;
@RequestMapping("/getMyConfig")
public String getMyConfig(){
return myConfig.toString();
}
@RequestMapping("/getUsername")
public String getUsername(){
return myConfig.getUsername();
}
@RequestMapping("/getYear")
public String getYear(){
return myConfig.getMy().getYear();
}
}
启动类添加注解 使 @ConfigurationProperties 注解的类生效。
@EnableConfigurationProperties({MyConfig.class})
到此我们完成配置,可以启动项目访问我们controller中的方法获取到我们在Consul的配置文件里的值
但是这里有一个问题,开始我配置的内容写到了application-uat配置文件中,启动后获取不到方法,然后我把内容写到bootstrap.yml中就可以访问到了
bootstrap.yml
#bootstrap.yml是系统级的,优先级更加高
spring:
application:
name: test-demo
cloud:
consul:
host: localhost
port: 8500
discovery:
service-name: ${spring.application.name}
prefer-ip-address: true
config:
profile-separator: ',' #默认的分隔符为 "," 我们自定义为"-"
format: yaml #文件格式为yml
fail-fast: true
prefix: config #基础文件夹名称
default-context: application
data-key: data