視頻學習地址：https://www.bilibili.com/video/BV18E411x7eT
源碼地址：https://gitee.com/zhu_xinmiao/springcloud
spring cloud版本：H版

概述

Bus是什么

Bus的作用

實際上就是原先Config動態刷新中，我們人工輸入的curl刷新提醒，有中間件替我們完成了。

什么是總線

相當于我有一個微信公眾號，大家訂閱了我，我這一更新大家每個人都能收到這個更新。

如果學過消息隊列（RabbitMQ、Kafka…）的話，這就相當于消息隊列的廣播模型。

設計思想

1對應的是Bus是什么標題下的圖

相當于小道消息的廣播通知

2對應的是Bus的作用標題下的圖

相當于中央配置中心的廣播通知

技術選型時我們更應該選擇后者

實現

前期準備

這里使用的消息隊列是RabbitMQ，并且選用的是設計思想中的第二種方法。

新建3366微服務，和3355搭建過程幾乎完全相同，可參考我前一篇博文config部分學習筆記中的搭建過程。

這里唯一的區別是controller中有所不同，但和核心邏輯沒有關聯，只是為了和3355做一個輸出的區分。

@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;
    }
}

搭建總線支持（全局廣播）

改pom

這三個微服務的pom文件中都加上

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

改yml

三個微服務中都加上，這個是spring下面一級的，一定要對齊，不懂的話可以看下我gitee中的源碼。

#spring:
    rabbitmq:
      host: localhost
      port: 5672
      username: guest
      password: guest

在3344的yml中額外加上

#暴露Bus刷新端點
management:
  endpoints:
    web:
      exposure:
        include: "bus-refresh"

這里強調一下，也算是解釋。但凡暴露端點的操作pom依賴中都要帶上以下依賴，同時bus-refresh是actuator中的操作。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

測試

測試時千萬記得打開RabbitMQ，不然3355和3366會跑不起來。

和上一篇config部分學習筆記類似，更改gitee中版本號后會發現3344刷新后直接更新了，而3355和3366沒有更新。

與上一篇不同的是，這次我們不是單獨去給3355，3366分別post，而是直接給3344發一個post請求，來做到一處刷新，處處刷新。

curl -X POST "http://localhost:3344/actuator/bus-refresh"

刷新測試頁面后我們就可以看到，3355和3366的版本號也更新了。

更新前：

更新后：

定點通知

這里我們測試只通知3366，不通知3355

3366更新前：

輸入curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3366"。

這里config-client來自yml中的這里

3366則是端口號，組合起來就是destination中需要填的內容。

更新后：