SpringCloud学习——消息总线Bus

Posted 2021-07-24 Johnny*

@TOC

消息总线Spring Cloud Bus

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

什么是总线

在微服务架构的系统中，通常会使用轻量级的消息代理来构建一个共用的消息主题，并让系统中所有微服务实例都连接上来。由于该主题产生的消息会被所有实例监听和消费，所以称他为消息总线。

基本原理

ConfigClient实例都监听MQ中同一个topic（默认是springCloudBus），当一个服务刷新数据时，它会把这个消息放入topic中，这样监听同一topic的服务就能得到通知，然后更新自身的配置。

动态刷新全局广播

全局广播的设计思想

两种设计思路：
第二种更好，第一种不好的原因：

1. 打破了微服务的职责单一性，因为微服务本身是业务模块，它不应该承担配置刷新的职责
2. 破坏了微服务各节点的对等性
3. 有一定的局限性。例如，微服务在迁移时，它的网络地址经常会发生变化，此时如果要想做到 自动刷新，那就会增加更多的修改。
   步骤：
   
4. 3344、3355、3366端引入rabbitmq依赖，添加消息总线RabbitMQ支持

       <!--添加消息总线RabbitMQ支持-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>

2. 3344端配置rabbitmq

测试：

运维工程师发送

实现一次发送，出处生效

定点通知

如果只想通知某些主机，而不是全部实例，可以使用定点通知
destination为服务名称:端口号