SpringCloud配置系列目录:前置知识
配置中心包括3个部分 创建存放配置文件信息的git仓库
git文件命名规范 创建新的Spring Cloud Config工程引入相关依赖新建并编辑application.yml配置文件
创建application.yml文件编辑application.yml文件 实现自动刷新
erlang安装
配置erlang环境变量 RabbitMQ安装
启动RabbitMQ进入RabbitMQ管理界面在新建工程的配置文件application.yml添加内容 在新建工程的添加启动类相关注解Config Client(USER-PROVIDER组的微服务)配置
修改Controller方法添加配置文件内容修改配置文件名称添加相关依赖 Spring Cloud Config启动测试
Spring Cloud Config注册成功查看当前git仓库中文件内容查看当前访问请求打印信息修改git文件信息并提交查看CONFIG-SERVER服务的actuator监控信息更新USER-PROVIDER中的配置信息为git中最新的内容
打开Postman并发送post请求查看当前访问请求打印信息
书接上回【Spring Cloud完整组件搭建之路 第四篇 -Zuul】,我们搭建的微服务组件有了Eureka、OpenFeign、Ribbon、Hystrix、Zuul,并且一共已经有了六个服务,现在,有一个问题,如果我想把我微服务中所有USER-CONSUMER和USER-PROVIDER组的微服务的配置文件修改一个共同的内容,我该怎么办?一个个修改yml,并且一个个重启服务?我们现在USER-CONSUMER和USER-PROVIDER组的微服务一共就三个,操作也不麻烦,但如果一共10个呢?20个呢?
SpringCloud配置系列目录:所以,我们需要一个能修改指定的所有微服务配置文件的组件,这样,我们就引入了Spring Cloud Config,接下来我们一起配置一下。
【Spring Cloud完整组件搭建之路-Eureka】
【Spring Cloud完整组件搭建之路 第二篇 -OpenFeign、Ribbon整合】
【Spring Cloud完整组件搭建之路 第三篇 -OpenFeign、Hystrix整合】
【Spring Cloud完整组件搭建之路 第四篇 -Zuul】
创建存放配置文件信息的git仓库存放配置的地方:git 等。config server。从 1 读取配置。config client。是 config server 的客户端 消费配置,也就是要修改配置文件的微服务。
git文件命名规范就是普通创建git仓库的步骤
获取配置规则:根据前缀匹配
/{name}-{profiles}.properties
/{name}-{profiles}.yml
/{name}-{profiles}.json
/{label}/{name}-{profiles}.yml
name 服务名称
profile 环境名称,开发、测试、生产:dev qa prd
lable 仓库分支、默认master分支
我创建的文件名是user-provider-dev.yml,代表user-provider服务下的dev环境
匹配原则:从前缀开始。
创建新的Spring Cloud Config工程根据【Spring Cloud完整组件搭建之路-Eureka】博客中的创建工程的步骤,选择Eureka Discovery Client、Config Server依赖创建完成。
引入相关依赖新建并编辑application.yml配置文件 创建application.yml文件org.springframework.boot spring-boot-starter-actuator org.springframework.cloud spring-cloud-starter-bus-amqp 3.1.0
在src/mian/resource目录下创建application.yml文件即可。
编辑application.yml文件server:
port: 8888
# 打开actuator所有监控参数
management:
endpoints:
web:
exposure:
include: '*'
# 配置git信息
spring:
cloud:
config:
server:
git:
uri: https://gitee.com/hepai123/spring-cloud-config-center.git
username: 账号
password: 密码
# git分支
label: dev
application:
name: CONFIG-SERVER
# 连接eureka服务器
eureka:
client:
serviceUrl:
defaultZone: http://euk-server-two.com:7000/eureka/
实现自动刷新
erlang安装上面的依赖中可以看到我们引入了bus-amqp,这个是用来统一通知所有config-client来进行指定操作的,包括全部刷新本服务的配置文件信息的指令,但是amqp的底层是一个消息队列MQ,直接有这个amqp功能,也就是能和amqp无缝整合的消息中间件有Kafka和RabbitMQ,RabbitMQ面向应用级开发,Kafka则是用于大的数据文件中转开发,所以我们集成RabbitMQ就可以了,所以我们需要进行如下操作:
http://www.erlang.org/downloads
配置erlang环境变量path中添加 %ERLANG_HOME%bin
RabbitMQ安装http://www.rabbitmq.com/install-windows.html
启动RabbitMQ在安装目录的bin目录下cmd,按顺序执行以下内容:
# 开启RabbitMQ节点 rabbitmqctl start_app # 开启RabbitMQ管理模块的插件,并配置到RabbitMQ节点上 rabbitmq-plugins enable rabbitmq_management进入RabbitMQ管理界面
访问地址:http://localhost:15672
用户名密码均为guest
spring:
# 配置rabbitmq信息
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
在新建工程的添加启动类相关注解
@EnableEurekaClient @EnableConfigServerConfig Client(USER-PROVIDER组的微服务)配置 修改Controller方法
在博客【Spring Cloud完整组件搭建之路 第二篇 -OpenFeign、Ribbon整合】中,我们创建了UserProviderController测试接口类,我们将其进行修改,修改后代码如下:
import org.apache.commons.lang.builder.ToStringBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import java.util.Map;
@RestController
@RefreshScope
public class UserProviderController {
@Value("${server.port}")
private String port;
@Value("${hepai.say}")
private String say;
@RequestMapping(value = "/aliveGet",method = RequestMethod.GET)
public String aliveGet(@RequestParam("id") Integer id){
return id + "---"+ port + "aliveGet";
}
@RequestMapping(value = "/noParamGet",method = RequestMethod.GET)
public String noParamGet(){
return port + "aliveGet:" + say;
}
@RequestMapping(value = "/alivePost",method = RequestMethod.POST)
public String alivePost(@RequestBody Map map){
return ToStringBuilder.reflectionToString(map) + "---"+ port + "alivePost";
}
@RequestMapping(value = "/alivePostParam",method = RequestMethod.POST)
public String alivePostParam(@RequestParam Map map){
return ToStringBuilder.reflectionToString(map) + "---"+ port + "alivePostParam";
}
}
添加配置文件内容代码修改点:
添加@RefreshScope注解添加对${hepai.say}配置信息的引入对noParamGet方法的修改,打印最新say信息
注意spring.cloud.config.profile是git文件名的最后一个杠(-)后面的内容
注意spring.cloud.config.label是要更新的git文件所在的git分支
注意spring.cloud.config.discovery.service-id是配置中心的服务名称
spring:
# 使用git仓库中dev结尾的文件,并配置config服务器
cloud:
config:
profile: dev
label: dev
# 可在eureka自动找寻config服务端
discovery:
enabled: true
service-id: CONFIG-SERVER
# 配置rabbitmq信息
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
management:
endpoints:
# 开启Actuator监控eureka服务所有信息,不加此配置只打开health和info
web:
exposure:
include: '*'
修改配置文件名称
添加相关依赖由application.yml修改为bootstrap.yml
Spring Cloud Config启动测试 Spring Cloud Config注册成功 查看当前git仓库中文件内容 查看当前访问请求打印信息 修改git文件信息并提交 查看CONFIG-SERVER服务的actuator监控信息org.springframework.cloud spring-cloud-starter-bootstrap 3.1.0 org.springframework.cloud spring-cloud-starter-bus-amqp 3.1.0 org.springframework.cloud spring-cloud-config-client 3.1.0 org.springframework.boot spring-boot-starter-actuator
更新USER-PROVIDER中的配置信息为git中最新的内容 打开Postman并发送post请求这个busrefresh就是我们要用到的自动刷新的核心方法。
现在这个时候我们的访问请求打印信息依然没有变,还是原先的内容
查看当前访问请求打印信息请求地址:http://config-serverIP:端口号/actuator/busrefresh
最终,在没有重启服务的情况下,配置信息更新成功。



