SpringCloud Day07--消息总线(SpringCloud Bus )-CFANZ编程社区

文章目录

10. SpringCloud Bus 消息总线

10.1 概述

10.1.1 上一节的回顾和扩展
10.1.2 是什么
10.1.3 能干嘛
10.1.4 为何被称为总线

10.2 RabbitMQ环境配置
10.3 SpringCloud Bus动态刷新全局广播

10.3.1 演示广播效果，增加复杂度
10.3.2 设计思想
10.3.3 动态刷新代码实现
10.3.4 测试

10.4 SpringCloud Bus动态刷新定点通知

10.4.1 理论基础
10.4.2 案例实现
10.4.3 通知总结

10. SpringCloud Bus 消息总线

10.1 概述

10.1.1 上一节的回顾和扩展

分布式自动刷新配置功能
Spring Cloud Bus 配合 Spring Cloud Config 使用可以实现配置的动态刷新。

10.1.2 是什么

Spring Cloud Bus 配合 Spring Cloud Config 使用可以实现配置的动态刷新。

SpringCloud Day07--消息总线(SpringCloud Bus )_spring

Spring Cloud Bus是用来将分布式系统的节点与轻量级消息系统链接起来的框架，它整合了Java的事件处理机制和消息中间件的功能。
Spring Clud Bus目前支持RabbitMQ和Kafka

10.1.3 能干嘛

Spring Cloud Bus能管理和传播分布式系统间的消息，就像一个分布式执行器，可用于广播状态更改、事件推送等，也可以当作微服务间的通信通道。

SpringCloud Day07--消息总线(SpringCloud Bus )_rabbitmq_02

10.1.4 为何被称为总线

什么是总线
在微服务架构的系统中，通常会使用轻量级的消息代理来构建一个共用的消息主题，并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费，所以称它为消息总线。在总线上的各个实例，都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。

基本原理
ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。当一个服务刷新数据的时候，它会把这个信息放入到Topic中，这样其它监听同一Topic的服务就能得到通知，然后去更新自身的配置。

https://www.bilibili.com/video/av55976700?from=search&seid=15010075915728605208

10.2 RabbitMQ环境配置

参考博客—RabbitMQ学习

10.3 SpringCloud Bus动态刷新全局广播

10.3.1 演示广播效果，增加复杂度

建Module—cloud-config-client-3366
POM

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</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-actuator</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    #Config客户端配置
    config:
      label: master #分支名称
      name: config #配置文件名称
      profile: dev #读取后缀名称   上述3个综合：master分支上config-dev.yml的配置文件被读取http://config-3344.com:3344/master/config-dev.yml
      uri: http://localhost:3344 #配置中心地址

#服务注册到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7004.com:7004/eureka  # 集群版



# 暴露监控端点
management:
  endpoints:
    web:
      exposure:
        include: "*"

主启动

@EnableEurekaClient
@SpringBootApplication
public class ConfigClientMain3366
{
    public static void main(String[] args)
    {
        SpringApplication.run(ConfigClientMain3366.class,args);
    }
}

controller

@RestController
@RefreshScope
public class ConfigClientController
{
    @Value("${server.port}")
    private String serverPort;

    @Value("${config.info}")
    private String configInfo;

    @GetMapping("/configInfo")
    public String configInfo()
    {
        return "serverPort: "+serverPort+"\t\n\n configInfo: "+configInfo;
    }

}

10.3.2 设计思想

1）利用消息总线触发一个客户端/bus/refresh,而刷新所有客户端的配置

SpringCloud Day07--消息总线(SpringCloud Bus )_spring cloud_03

2）利用消息总线触发一个服务端ConfigServer的/bus/refresh端点，而刷新所有客户端的配置

SpringCloud Day07--消息总线(SpringCloud Bus )_kafka_04

图二的架构显然更加适合，图一不适合的原因如下:

打破了微服务的职责单一性，因为微服务本身是业务模块，它本不应该承担配置刷新的职责。
破坏了微服务各节点的对等性。
有一定的局限性。例如，微服务在迁移时，它的网络地址常常会发生变化，此时如果想要做到自动刷新，那就会增加更多的修改

10.3.3 动态刷新代码实现

1.给cloud-config-center-3344配置中心服务端添加消息总线支持

<!--添加消息总线RabbitMQ支持-->
<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>

YML—增加RabbitMQ的配置

spring:
 #rabbitmq相关配置 15672是Web管理界面的端口；5672是MQ访问的端口
  rabbitmq:
    host: 192.168.174.128
    port: 5672
    username: admin
    password:

2.给cloud-config-center-3355,3366也进行相同的修改

10.3.4 测试

0.修改Github上配置文件增加版本号

1.访问http://config-3344.com:3344/config-dev.yml,已经进行了更新(因为是和GitHub直连的),访问http://localhost:3355/configInfo http://localhost:3366/configInfo 未进行更新.

2.发送POST请求:curl -X POST “http://localhost:3344/actuator/bus-refresh”

SpringCloud Day07--消息总线(SpringCloud Bus )_kafka_05

访问:http://config-3344.com:3344/config-dev.yml 配置已经进行了更新
访问客户端:http://localhost:3355/configInfo http://localhost:3366/configInfo 获取配置信息，发现都已经刷新了. O(∩_∩)O

结论: 一次修改，广播通知，处处生效

查看RabbitMQ的界面: 每个ConfigClient实例服务都在监听SpringCloudBus

SpringCloud Day07--消息总线(SpringCloud Bus )_spring_06