Spring Cloud Config與Bus整合實現(xiàn)微服務配置自動刷新功能

更新時間：2024年10月18日 15:01:26 作者：布說在見

通過整合SpringCloud Config與Spring Cloud Bus,實現(xiàn)了微服務配置的自動刷新功能,這個機制允許一個微服務實例在配置更新時通過消息總線通知其他所有實例同步更新,從而保持配置的一致性并提升系統(tǒng)的運維效率

Config與Bus整合自動刷新

微服務A的所有實例都通過Spring Cloud Bus消息總線連接到了一起，每個實例都會從Config Server訂閱配置更新事件并獲取配置信息。當其中一個微服務節(jié)點的/ous/refresh端點被請求時，該實例就會向Spring Cloud Bus消息總線發(fā)送一個配置更新事件，其他實例通過Spring Cloud Bus消息總線獲得該事件后也會從Config Server獲取最新的配置信息并更新配置。

步驟：

1.安裝RabbitMQ并啟動

2.添加依賴

3.修改配置文件

4.改造Config Client

5.測試運行

步驟1：安裝RabbitMQ并啟動 RabbitMQ的安裝

1.下載erlang，原因在于RabbitMQ服務端代碼是使用并發(fā)式語言erlang編寫的，下載地址：erlang，雙擊.eerlangxe文件進行安裝就好，安裝完成之后創(chuàng)建一個名為ERLANG_HOME的環(huán)境變量，其值指向erlang的安裝目錄，同時將%ERLANG_HOME%\bin加入到Path中。

最后打開cmd命令行，輸入erl，如果出現(xiàn)erlang的版本信息就表示erlang語言環(huán)境安裝成功

2.下載RabbitMQ，下載地址：RabbitMQ，同樣雙擊.exe進行安裝就好(注意：默認的安裝目錄是C:/Program Files/…，這個目錄中是存在空格符的，我們需要改變安裝目錄，貌似RabbitMQ安裝目錄中是不允許有空格的)。

3.安裝RabbitMQ-Plugins，這個相當于是一個管理界面，方便我們在瀏覽器界面查看RabbitMQ各個消息隊列以及exchange的工作情況，安裝方法是：打開命令行cd進入rabbitmq的sbin目錄，輸入：rabbitmq-plugins enable rabbitmq_management命令，稍等會會發(fā)現(xiàn)出現(xiàn)plugins安裝成功的提示，默認是安裝6個插件。

4.插件安裝完之后，在瀏覽器輸入http://localhost:15672進行驗證，你會看到下面界面，輸入用戶名：guest，密碼：guest 就可以進入管理界面。

步驟2：創(chuàng)建項目

Eureka Server，config-server，config-client

創(chuàng)建Eureka Server

1）使用Spring Initializr方式創(chuàng)建一個名稱為eureka-server的Spring Boot項目，將Artifact命名為eureka-server，在pom.xml文件中添加Eureka Server依賴。

方便測試效果，新建一個eureka-server項目作為Config Server的注冊中心，
將eureka-server端口號設置為8761。

在加載不出來添加，要與springboot版本相符

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.bushuo</groupId>
    <artifactId>eureka-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka-server</name>
    <description>Demo project for Spring Boot</description>
    <url/>
    <licenses>
        <license/>
    </licenses>
    <developers>
        <developer/>
    </developers>
    <scm>
        <connection/>
        <developerConnection/>
        <tag/>
        <url/>
    </scm>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>
                spring-cloud-starter-netflix-eureka-server
            </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>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.SR2</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

2）：添加Eureka的相關配置

在全局配置文件application.yml中添加Eureka的相關配置信息。

fetch-registry:
設置false 時，該Eureka客戶端不會從Eureka Server獲取服務注冊表的信息。這意味著它不會嘗試拉取其他服務的信息，通常這在自身就是Server的情況下使用。register-with-eureka:
設置為 false 時，Eureka 客戶端不注冊到 Eureka Server。即不將自身信息注冊到服務注冊表。在 Eureka Server 節(jié)點配置中常用，因 Eureka Server 本身無需注冊到其他 Eureka Server，單實例時是。

3）：在項目啟動類添加@EnableEurekaServer注解

在項目啟動類EurekaServerApplication上添加@EnableEurekaServer注解開啟Eureka Server功能。

4）測試運行 http://localhost:8761

創(chuàng)建config-server

在config-4下創(chuàng)建config-server，添加依賴，添加配置，在啟動類添加注解

可以參考操作
依賴

配置bootstrap

添加啟動類注解

步驟3：添加依賴

Config Server和Config Client與Spring Cloud Bus整合實現(xiàn)配置自動刷新。改造Config Server與Config Client，在各自的pom.xml配置文件中添加spring-cloud-starter-bus-amqp依賴實現(xiàn)配置自動更新與spring-boot-starter-actuator依賴監(jiān)控系統(tǒng)健康情況的工具。

        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-amqp</artifactId>
         <version>2.0.0.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

修改配置文件

改造Config Server和Config Client的配置文件，在配置文件中設置rabbitmq屬性的相關配置，包括主機地址、端口號、用戶名和密碼，如下所示。

spring:
  application:
    name: config-client
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/nobyebye/hello.git
          username: #自己的gitee用戶名
          password: #密碼
          label: master
  profiles:
    active: dev
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
server:
  port: 8001
management:
  endpoints:
    web:
      exposure:
        include: "bus-refresh"