Spring Cloud 消息总线的简单搭建

本贴最后更新于 1553 天前,其中的信息可能已经沧海桑田

CZXawlrTA9nvQjP

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

1. 前提

  1. 这个示例是基于 分布式配置中心(高可用)文章里的,如果在案例里有不懂得地方可以看前一篇文章:

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

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

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

2. 开始构建项目

首先创建一个 Config Server 项目
  1. 导入 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>
  1. 入口类
@EnableEurekaClient
@EnableConfigServer
@SpringBootApplication
public class ConfigserverApplication {

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

}

  1. 配置文件
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

  1. 导入 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>
  1. 入口类
@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);
    }

}

  1. 配置文件 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 接口,查看返回值是否已经为修改过的值

  • Spring

    Spring 是一个开源框架,是于 2003 年兴起的一个轻量级的 Java 开发框架,由 Rod Johnson 在其著作《Expert One-On-One J2EE Development and Design》中阐述的部分理念和原型衍生而来。它是为了解决企业应用开发的复杂性而创建的。框架的主要优势之一就是其分层架构,分层架构允许使用者选择使用哪一个组件,同时为 JavaEE 应用程序开发提供集成的框架。

    938 引用 • 1456 回帖 • 163 关注

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...