还记得在上篇文章中使用Config配置中心的时候,如果远程配置文件修改了,那么需要post刷新请求,配置客户端才会获取最新的配置。这个问题就是如果配置中心修改了,我们需要向每个微服务刷新,大大提高了操作难度。而消息总线Bus使用消息队列中的发布订阅模式来帮我们解决了这个问题。
1. 简介
Spring Cloud Bus将分布式系统的节点与轻量级消息代理链接。这可以用于广播状态更改(例如配置更改)或其他管理指令。一个关键的想法是,Bus就像一个扩展的Spring Boot应用程序的分布式执行器,但也可以用作应用程序之间的通信渠道。当前唯一的实现是使用AMQP代理作为传输,但是相同的基本功能集(还有一些取决于传输)在其他传输的路线图上。(复制的官方文档)
简单的来说通过消息中间件作为传输,来广播命令。
接下来就是项目案例了,在本例中使用RabbitMQ作为消息中间件。
2. 安装RabbitMQ
安装rabbitmq可直接在docker中docker search rabbitmq进行下载启动,此处不过多介绍。
启动成功后的RabbitMQ,在浏览器中输入http://localhost:15672//可以看到如下界面,就说明RabbitMQ安装和启动成功.
3. 配置中心config-server-8600
我们依旧通过config-server-8600项目来作为配置中心,要对Bus的支持,我们需要引入一些依赖并修改配置。
3.1 pom.xml引入依赖
config-server-8600中需要引入消息总线和监控中心的依赖
org.springframework.cloud spring-cloud-starter-bus-amqp org.springframework.boot spring-boot-starter-actuator
然后总的pom.xml内容如下
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"> springcloudtest com.elio.springcloud 1.0-SNAPSHOT 4.0.0 springcloud-config-server-8600 org.springframework.cloud spring-cloud-config-server org.springframework.cloud spring-cloud-starter-bus-amqp org.springframework.boot spring-boot-starter-actuator org.springframework.cloud spring-cloud-starter-netflix-eureka-client org.springframework.boot spring-boot-starter-web
3.2 修改application.yml配置文件
需要加入RabbitMQ的相关配置,还有就是暴露刷新接口。注意:
- 其中rabbitmq的服务端口是5672,而15672支持客户端的接口,不要配置错了。
- bus-refresh 将会是刷新接口的地址,接下来会通过http://localhost:8600/actuator/bus-refresh接口来进行刷新
rabbitmq:
host: localhost rabbitmq主机
port: 5672 rabbitmq端口,注意是5672而不是15672
username: guest 用户名
password: guest 密码
management:
endpoints:
web:
exposure:
include: bus-refresh 指定刷新地址
然后总的application.yml配置内容如下
server:
port: 8600 端口号
spring:
application:
name: springcloud-config-server 应用名称
cloud:
config:
server:
git:
uri: https: git地址
username: git账号名
password: git账号密码
rabbitmq:
host: localhost rabbitmq主机
port: 5672 rabbitmq端口,注意是5672而不是15672
username: guest 用户名
password: guest 密码
eureka:
instance:
instance-id: ${spring.application.name}:${server.port}
client:
fetch-registry: true
register-with-eureka: true
service-url:
defaultZone: http://localhost:8300/eureka/,http://localhost:8301/eureka/
management:
endpoints:
web:
exposure:
include: bus-refresh 指定刷新地址
4. 配置客户端product-provider-8100
完成了配置中心的配置后,接下来就是要配置客户端product-provider-8100了。
4.1 修改pom.xml引入依赖
org.springframework.cloud spring-cloud-starter-bus-amqp org.springframework.boot spring-boot-starter-actuator
4.2 修改bootstrap.yml配置文件
bootstrap.yml 只用加入rabbitMQ的相关配置即可
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
总的bootstrap.yml内容如下
spring:
cloud:
config:
name: configtest 获取配置文件的名称
profile: pro 配置的策略pro-生产 test-测试 dev-开发
label: master 分支
discovery:
enabled: true 开启配置信息发现
service-id: springcloud-config-server 指定配置中心的service-id
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
eureka:
instance:
instance-id: ${spring.application.name}:${server.port}
client:
fetch-registry: true
register-with-eureka: true
service-url:
defaultZone: http://localhost:8300/eureka/,http://localhost:8301/eureka/
management:
endpoints:
web:
exposure:
include: refresh,health
4.3 确定访问接口
获取远程配置文件的接口是没有变动的,记得要加上@RefreshScope注解
@RestController@Slf4j@RequestMapping("/")@RefreshScopepublicclassProductProviderController{@ResourceprivateProductServiceproductService;@Value("${spring.application.name}")privateStringinstantName;@Value("${server.port}")privateStringport;@Value("${hello}")privateStringhello;@GetMapping("product/provider/get/config/info")publicResultgetConfigInfo()throwsException{returnnewResult(200,"",this.hello);}}
5. 测试
依次启动eureka-server-8300,eureka-server-8301,config-server-8600,product-provider-8100项目后,接下来进行以下步骤:
修改码云上的configtest-pro.yml文件,文件内容修改成如下
hello: hello from configtest-pro modified three times
然后打开cmd窗口,输入以下命令
curl -X POST http://localhost:8600/actuator/bus-refresh
- 然后浏览器地址中输入product-provider-8100的访问接口http://localhost:8100/product/provider/get/config/info
最终测试结果和预期的一样,在这个例子中笔者只用一个微服务来做测试,其实多个微服务效果一样,可以通过消息总件的形式,就能够实现广播配置文件变动事件了。
6.总结
本文简单的介绍了如何通过Bus + RabbitMQ来实现动态刷新,具体的原理和工作流程本文没有叙述,希望对只是想通过小实践来学习的同学有所帮助。
声明:本文部分素材转载自互联网,如有侵权立即删除 。
2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!
3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!
4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!
5. 如有链接无法下载、失效或广告,请联系管理员处理!
6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需!
7. 如遇到加密压缩包,请使用WINRAR解压,如遇到无法解压的请联系管理员!
8. 精力有限,不少源码未能详细测试(解密),不能分辨部分源码是病毒还是误报,所以没有进行任何修改,大家使用前请进行甄别
丞旭猿论坛
暂无评论内容