Spring Cloud Bus 将分布式的节点用轻量的消息代理连接起来。它可以用于广播配置文件的更改或者服务之间的通讯,也可以用于监控。本文要讲述的是用Spring Cloud Bus实现通知微服务架构的配置文件的更改。
一、准备工作
本文还是基于上一篇文章来实现。按照官方文档,我们只需要在配置文件中配置 spring-cloud-starter-bus-amqp ;这就是说我们需要装rabbitMq,点击下载。
二、改造config-client
在pom文件加上起步依赖spring-cloud-starter-bus-amqp,完整的配置文件如下:
4.0.0 com.example da-config-client 0.0.1-SNAPSHOT jar da-config-client Demo project for Spring Boot org.springframework.boot spring-boot-starter-parent 2.0.0.RELEASE UTF-8 UTF-8 1.8 Finchley.M8 org.springframework.cloud spring-cloud-starter-netflix-eureka-client org.springframework.cloud spring-cloud-starter-config org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-actuator org.springframework.cloud spring-cloud-starter-bus-amqp org.springframework.boot spring-boot-starter-test test org.springframework.cloud spring-cloud-dependencies ${spring-cloud.version} pom import org.springframework.boot spring-boot-maven-plugin spring-milestones Spring Milestones https://repo.spring.io/milestone false
在配置文件application.yml中加上RabbitMq的配置,包括RabbitMq的地址、端口,用户名、密码,代码如下:
eureka: client: serviceUrl: defaultZone: http://localhost:1001/eureka/spring: application: name: config-client cloud: bus: trace: enabled: true config: name: didispace #只能文件名 label: master #指明远程仓库的分支 profile: dev #dev开发环境配置文件test测试环境pro正式环境 uri: http://localhost:5001/ #指明配置服务中心的网址 discovery: enabled: true #是从配置中心读取文件 serviceId: config-server #配置中心的服务名 rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guestserver: port: 5002
依次启动eureka-server、config-server、config-client。
访问浏览器显示:
这时我们去将from的值改为“wangwu”,即改变配置文件from的值。如果是传统的做法,需要重启服务,才能达到配置文件的更新。此时,我们只需要发送post请求:,在此请求数据就会发生变化。
另外,/bus/refresh接口可以指定服务,即使用”destination”参数,比如 “/bus/refresh?destination=customers:**” 即刷新服务名为customers的所有服务,不管ip。