springcloud bus

spring cloud bus配合spring cloud config可以實現配置的動態刷新

作用：

• 管理和傳播分布式系統間的消息
• 廣播狀態更改，事件推送等
• 做微服務間的通信通道

基本原理：

configClient實例都監聽MQ中同一個topic（默認是springcloudBus）當一個服務刷新數據時，他會把這個消息放入到topic中，這樣其他監聽同一個topic的服務就能得到通知，然后去更新自身的配置

原理

demo搭建

服務端搭建

添加依賴：

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

修改配置文件：

server:
  port: 3355

spring:
  application:
    name: cloud-config-center
  cloud:
    config:
      server:
        git:
          #uri: #Github上的git倉庫名字
          uri: https://gitee.com/XXXXX/springcloud-config.git
          ##搜索目錄.這個目錄指的是github上的目錄
          search-paths:
            - springcloud-config
          username: XXXXX
          password: XXXXX
      ##讀取分支
      label: master
#rabbit相關配置 15672是web管理界面的端口，5672是MQ訪問的端口
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

eureka:
  client:
    service-url:
      defaultZone: http://eureka7779.com:7779/eureka/

#rabbitmq相關設置 ，暴露 bus刷新配置的端點
management:
  endpoints:
    web:
      exposure:
        include: 'bus-refresh'

客戶端搭建

客戶端修改pom文

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

配置文件修改：

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    #Config客戶端配置
    config:
      label: master #分支名稱
      name: config #配置文件名稱
      profile: dev #讀取后綴名稱 上訴3個綜合就是 master分支上 config-dev.yml
      uri: http://config-3355.com:3355 # 配置中心地址
  #rabbit相關配置 15672是web管理界面的端口，5672是MQ訪問的端口
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
eureka:
  client:
    service-url:
      defaultZone:  http://eureka7779.com:7779/eureka/
#暴露監控端點
management:
  endpoints:
    web:
      exposure:
        include: "*"

測試：

修改配置為bus：

此時，bus的優勢就是對比原來的config需要有多少機器就curl多少次，bus只需要手動一次curl即可

結果：