Spring Cloud 消息总线的简单搭建

Spring Cloud 消息总线，也被称为 Spring Cloud Bus，它可以用于广播配置文件的更改或者服务之间的通讯，也可以用于监控。本篇示例的内容是用 Spring Cloud Bus 实现通知微服务架构的配置文件的更改。

1. 前提

2. 这个示例是基于 分布式配置中心（高可用）文章里的，如果在案例里有不懂得地方可以看前一篇文章：

https://blog.csdn.net/qq_41946543/article/details/103374533

3. 消息总线需要用到 rabbitmq 消息队列，如果不会使用 rabbitmq 的话，可以去看看我的另外一篇文章：

https://blog.csdn.net/qq_41946543/article/details/103376152

2. 开始构建项目

首先创建一个 Config Server 项目

2. 导入 dependency

<!--消息总线-->
<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-config-server</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 <exclusions>
 <exclusion>
 <groupId>org.junit.vintage</groupId>
 <artifactId>junit-vintage-engine</artifactId>
 </exclusion>
 </exclusions>
</dependency>
​

3. 入口类

@EnableEurekaClient
@EnableConfigServer
@SpringBootApplication
public class ConfigserverApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigserverApplication.class, args);
    }

}

​

4. 配置文件

server.port=8881
spring.application.name=config-server
# configserver git配置
# 仓库的地址，如果私有仓库 那么需要配置账号和密码
spring.cloud.config.server.git.uri=https://github.com/VULCAN2019/SpringCloudConfig.git
# 仓库的账号和密码
#spring.cloud.config.server.git.username=
#spring.cloud.config.server.git.password=
# 存放配置文件的目录
spring.cloud.config.server.git.search-paths=resp
# 使用的git分支
spring.cloud.config.label=master

# 指定注册中心地址
eureka.client.service-url.defaultZone=http://localhost:8761/eureka

​

其次构建一个 Config Client

2. 导入 dependency

<!--消息总线-->
<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 <exclusions>
 <exclusion>
 <groupId>org.junit.vintage</groupId>
 <artifactId>junit-vintage-engine</artifactId>
 </exclusion>
 </exclusions>
</dependency>
​

3. 入口类

@EnableEurekaClient
@RestController
@RefreshScope  //刷新作用域
@SpringBootApplication
public class SpringcloudserverApplication {

    @Value("${name}")
    private String name;

    @GetMapping("/test")
    public String test(){
        return name;
    }

    public static void main(String[] args) {
        SpringApplication.run(SpringcloudserverApplication.class, args);
    }

}

​

4. 配置文件 bootstrap.properties

server.port=8882
spring.application.name=config-client
# 指明远程仓库的分支
spring.cloud.config.label=master
# dev开发环境配置文件，test测试环境，pro正式环境
spring.cloud.config.profile=dev
# 配置文件名称 必须是 bootstrap.properties/yml
eureka.client.service-url.defaultZone=http://localhost:8761/eureka
# 表示从注册中心中获取内容
spring.cloud.config.discovery.enabled=true
# 表示注册中心中配置中心的服务名称
spring.cloud.config.discovery.service-id=config-server


# rabbitmq消息队列的服务器ip
spring.rabbitmq.host=121.40.176.56
# 放行bus/refresh接口
management.endpoints.web.exposure.include=bus-refresh

​

测试的时候，在保证项目能够从 git 仓库里面取到值为前提下，再测试 config client 重新读取配置文件的操作，测试方法有多种，这里我使用的是 idea 里面集成的 HTTP Client 来进行测试的，在工具栏的 Tools --> HTTP Client --> Test RESTful web service

HTTP method：POST

Host/port：http://localhost:8882

Path：/actuator/bus-refresh

点击运行，过几秒钟后得到的是就说明已经刷新成功了，然后再次去访问/test 接口，查看返回值是否已经为修改过的值