知識庫 / Spring / Spring Cloud RSS 訂閱

4. Spring Cloud Bus

通過使用 Actuator，我們可以刷新客户端。但是，在雲環境中，我們需要訪問每個客户端並通過訪問 Actuator 端點重新加載配置。

為了解決這個問題，我們可以使用 Spring Cloud Bus。

4.1. 客户端

我們需要更新雲配置客户端，使其能夠訂閲 RabbitMQ 交換機：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    <version>4.1.1</version>
</dependency>

最新版本可在此處找到：https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-bus-amqp。

為了完成配置客户端的更改，我們需要在 application.yml 文件中添加 RabbitMQ 詳細信息並啓用雲總線：

---
spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
  cloud:
    bus:
      enabled: true
      refresh:
        enabled: true

請注意，我們使用的是默認用户名和密碼。這需要在實際生產應用中更新。對於本教程而言，這沒問題。

現在，客户端將擁有另一個端點 ‘/bus-refresh’。調用此端點將導致：

• 從配置服務器獲取最新的配置並對其進行標註 @RefreshScope 更新
• 向 AMQP 交換髮送消息，告知刷新事件
• 所有訂閲節點也將更新其配置

這樣，我們就不需要逐個節點地觸發配置更新。

4.2. 服務器

最後，我們將添加兩個依賴項到配置服務器，以完全自動化配置更改。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-config-monitor</artifactId>
    <version>4.1.1</version>
</dependency>

最新版本可以在這裏找到：這裏。

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    <version>4.1.1</version>
</dependency>

最新版本可在此處找到：https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-stream-rabbit。

我們將使用 spring-cloud-config-monitor 來監控配置更改並使用 RabbitMQ 作為傳輸協議進行事件廣播。

只需要更新 application.properties 並提供 RabbitMQ 詳細信息即可。

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

4.3. GitHub Webhook

一切已就緒。當服務器收到配置更改通知後，它會將此作為消息廣播到 RabbitMQ。客户端將監聽消息並根據配置更改事件進行更新。但是，服務器如何得知修改內容呢？

我們需要配置一個 GitHub Webhook。請前往 GitHub 並打開包含配置屬性的我們的倉庫。現在，請選擇 Settings 和 Webhook。請點擊 Add webhook 按鈕。

Payload URL 是我們配置服務器的 ‘/monitor’ 接口地址。在我們的例子中，URL 類似於：

http://root:s3cr3t@REMOTE_IP:8888/monitor

我們只需要在下拉菜單中更改 Content type 為 application/json。 接下來，請將 Secret 留空，然後點擊 Add webhook 按鈕——之後，我們一切都已就緒。

5. 測試

讓我們確保所有應用程序都在運行。如果返回並檢查客户端，它將顯示 <em user.role</em> 為 <em ‘Programmer’</em>> 且 <em user.password</em> 為 <em d3v3L</em>：

$> curl http://localhost:8080/whoami/Mr_Pink
Hello Mr_Pink! You are a(n) Programmer and your password is 'd3v3L'.

之前，我們必須使用 ‘/refresh’</em/> 端點來刷新配置更改。請打開 properties 文件，將 user.role</em/> 更改回 Developer</em/>，然後提交更改：

user.role=Programmer

$> curl http://localhost:8080/whoami/Mr_Pink
Hello Mr_Pink! You are a(n) Developer and your password is 'd3v3L'.

o.s.cloud.bus.event.RefreshListener: Received remote refresh request. Keys refreshed []