17.SpringCloud學習筆記--Bus消息總線

Bus消息總線簡介

Spring Cloud Bus 配合 Spring Cloud Config 使用可以實現配置的動態刷新。

在這里插入圖片描述

Spring Cloud Bus是用來將分布式系統的節點與輕量級消息系統鏈接起來的框架，它整合了Java的事件處理機制和消息中間件的功能。Spring Clud Bus目前支持RabbitMQ和Kafka。

Spring Cloud Bus能管理和傳播分布式系統間的消息，就像一個分布式執行器，可用于廣播狀態更改、事件推送等，也可以當作微服務間的通信通道。通過廣播可實現通知一個客戶端或者配置中心服務端能讓所有的客戶端都更新以獲取配置中心最新的內容。

在這里插入圖片描述

總線

在微服務架構的系統中，通常會使用輕量級的消息代理來構建一個共用的消息主題，并讓系統中所有微服務實例都連接上來。由于該主題中產生的消息會被所有實例監聽和消費，所以稱它為消息總線。在總線上的各個實例，都可以方便地廣播一些需要讓其他連接在該主題上的實例都知道的消息。

實現原理

ConfigClient實例都監聽MQ中同一個topic(默認是Spring Cloud Bus)。當一個服務刷新數據的時候，它會把這個信息放入到Topic中，這樣其它監聽同一Topic的服務就能得到通知，然后去更新自身的配置。

Bus之RabbitMQ環境配置

部署

在 Docker 中部署 RabbitMQ

參考：

https://hub.docker.com/_/rabbitmq

docker pull rabbitmq:3.7-management
#15672是管理界面的端口，5672是服務的端口
docker run -dit --name rmq37m -e RABBITMQ_DEFAULT_USER=guest -e RABBITMQ_DEFAULT_PASS=guest -p 15672:15672 -p 5672:5672 rabbitmq:3.7-management
#-d: 后臺運行容器，并返回容器ID
#-i: 以交互模式運行容器，通常與 -t 同時使用
#-t: 為容器重新分配一個偽輸入終端，通常與 -i 同時使用
#-e: 設置環境變量
#-p: 指定端口映射，格式為：主機(宿主)端口:容器端口

測試

訪問 http://192.168.25.157:15672/ 可進入 RabbitMQ 的管理頁面，根據 RABBITMQ_DEFAULT_USER=guest 和 RABBITMQ_DEFAULT_PASS=guest 可知 Username / Password 為 guest / guest

Bus動態刷新全局廣播的設計思想和選型

前期工作

1、建Module

cloud-config-client-3366

2、改POM

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>demo.yangxu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-config-client-3366</artifactId>
    <dependencies>
        
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</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-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

3、寫YML

bootstrap.yml

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    #Config客戶端配置
    config:
      label: master #分支名稱
      name: config #配置文件名稱
      profile: dev #讀取后綴名稱   上述3個綜合：master分支上config-dev.yml的配置文件被讀取http://config-3344.com:3344/master/config-dev.yml
      uri: http://config-3344.com:3344 #配置中心地址


#服務注冊到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

# 暴露監控端點
management:
  endpoints:
    web:
      exposure:
        include: "*"

4、主啟動

ConfigClientMain3366

package demo.yangxu.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class ConfigClientMain3366 {
    public static void main(String[] args)
    {
        SpringApplication.run(ConfigClientMain3366.class,args);
    }
}

5、業務類

controller

ConfigClientController

package demo.yangxu.springcloud.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

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

設計思想

1、利用消息總線觸發一個客戶端 /bus/refresh，從而刷新所有客戶端的配置

在這里插入圖片描述

2、利用消息總線觸發一個服務端ConfigServer的 /bus/refresh端點，從而刷新所有客戶端的配置

在這里插入圖片描述

推薦使用第二種思想，原因是第一種思想：

打破了微服務的職責單一性，因為微服務本身是業務模塊，本不應該承擔配置刷新的職責
破壞了微服務各節點的對等性
有一定的局限性。例如，微服務在遷移時，它的網絡地址常常會發生變化，如果此時想要做到自動刷新，就會增加更多的修改

Bus動態刷新全局廣播配置實現

給cloud-config-center-3344配置中心服務端添加消息總線支持

POM

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>demo.yangxu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-config-center-3344</artifactId>

    <dependencies>
        <!--添加消息總線RabbitMQ支持-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</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-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

YML

application.yml

server:
  port: 3344

spring:
  application:
    name:  cloud-config-center #注冊進Eureka服務器的微服務名
  cloud:
    config:
      server:
        git:
          uri: [email protected]:telyfox/springcloud-config.git #GitHub上面的git倉庫名字
          ####搜索目錄
          search-paths:
            - springcloud-config
        #配置倉庫默認的分支,配置后生效
        default-label: master

      ####讀取分支，配置后無效，原因不明
      label: master


  #rabbitmq相關配置
  rabbitmq:
    host: 192.168.25.157
    port: 5672
    username: guest
    password: guest

#服務注冊到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

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

給cloud-config-client-3355客戶端添加消息總線支持

POM

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>demo.yangxu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-config-client-3355</artifactId>

    <dependencies>
        <!--添加消息總線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>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</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-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

YML

bootstrap.yml

server:
  port: 3355

spring:
  application:
    name: config-client
  cloud:
    #Config客戶端配置
    config:
      label: master #分支名稱
      name: config #配置文件名稱
      profile: dev #讀取后綴名稱   上述3個綜合：master分支上config-dev.yml的配置文件被讀取http://config-3344.com:3344/master/config-dev.yml
      uri: http://config-3344.com:3344 #配置中心地址

  #rabbitmq相關配置 15672是Web管理界面的端口；5672是MQ訪問的端口
  rabbitmq:
    host: 192.168.25.157
    port: 5672
    username: guest
    password: guest


#服務注冊到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

# 暴露監控端點
management:
  endpoints:
    web:
      exposure:
        include: "*"

給cloud-config-client-3366客戶端添加消息總線支持

POM

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>demo.yangxu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-config-client-3366</artifactId>
    <dependencies>
        <!--添加消息總線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>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</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-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

YML

bootstrap.yml

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    #Config客戶端配置
    config:
      label: master #分支名稱
      name: config #配置文件名稱
      profile: dev #讀取后綴名稱   上述3個綜合：master分支上config-dev.yml的配置文件被讀取http://config-3344.com:3344/master/config-dev.yml
      uri: http://config-3344.com:3344 #配置中心地址

  #rabbitmq相關配置 15672是Web管理界面的端口；5672是MQ訪問的端口
  rabbitmq:
    host: 192.168.25.157
    port: 5672
    username: guest
    password: guest

#服務注冊到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

# 暴露監控端點
management:
  endpoints:
    web:
      exposure:
        include: "*"

測試

啟動

cloud-eureka-server7001（EurekaMain7001）
cloud-config-center-3344（ConfigCenterMain3344）
cloud-config-client-3355（ConfigClientMain3355）
cloud-config-client-3366（ConfigClientMain3366）

運維工程師

修改GitHub上配置文件

發送POST請求

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

一次修改，廣播通知，處處生效

配置中心

http://config-3344.com:3344/config-dev.yml

客戶端

http://localhost:3355/configInfo

http://localhost:3366/configInfo

在 RabbitMQ Management 的 Exchanges 可以看到 SpringCloudBus

在這里插入圖片描述

Bus動態刷新定點通知

不想全部通知，只想定點通知

只通知3355，不通知3366

公式：

http://config-3344.com:3344/actuator/bus-refresh/{destination}

destination值為{spring.application.name}:{server.port}

/bus/refresh請求不再發送到具體的服務實例上，而是發送給 config server 并通過 destination 參數類指定需要更新配置的服務或實例。

curl -X POST "http://192.168.25.142:3344/actuator/bus-refresh/config-client:3355"

通知多個的寫法：

curl -X POST "http://192.168.25.142:3344/actuator/bus-refresh/config-client:3355" "http://192.168.25.142:3344/actuator/bus-refresh/config-client:3366"

流程圖：

在這里插入圖片描述

本文鏈接：https://blog.csdn.net/gaoxiaokun4282/article/details/107741095

智能推薦

freemarker + ItextRender 根據模板生成PDF文件

1. 制作模板 2. 獲取模板，并將所獲取的數據加載生成html文件 2. 生成PDF文件其中由兩個地方需要注意，都是關于獲取文件路徑的問題，由于項目部署的時候是打包成jar包形式，所以在開發過程中時直接安照傳統的獲取方法沒有一點文件，但是當打包后部署，總是出錯。于是參考網上文章，先將文件讀出來到項目的臨時目錄下，然后再按正常方式加載該臨時文件；還有一個問題至今沒有解決，就是關于生成PDF文件...

電腦空間不夠了？教你一個小秒招快速清理 Docker 占用的磁盤空間！

Docker 很占用空間，每當我們運行容器、拉取鏡像、部署應用、構建自己的鏡像時，我們的磁盤空間會被大量占用。如果你也被這個問題所困擾，咱們就一起看一下 Docker 是如何使用磁盤空間的，以及如何回收。 docker 占用的空間可以通過下面的命令查看： TYPE 列出了docker 使用磁盤的 4 種類型： Images：所有鏡像占用的空間，包括拉取下來的鏡像，和本地構建的。 Con...

requests實現全自動PPT模板

http://www.1ppt.com/moban/ 可以免費的下載PPT模板，當然如果要人工一個個下，還是挺麻煩的，我們可以利用requests輕松下載訪問這個主頁，我們可以看到下面的樣式點每一個PPT模板的圖片，我們可以進入到詳細的信息頁面，翻到下面，我們可以看到對應的下載地址點擊這個下載的按鈕，我們便可以下載對應的PPT壓縮包那我們就開始做吧首先，查看網頁的源代碼，我們可以看到每一...

SpringMvc自定義類型轉換器步驟

...

Linux C系統編程-線程互斥鎖（四）

互斥鎖互斥鎖也是屬于線程之間處理同步互斥方式，有上鎖/解鎖兩種狀態。互斥鎖函數接口 1）初始化互斥鎖 pthread_mutex_init() man 3 pthread_mutex_init (找不到的情況下首先 sudo apt-get install glibc-doc sudo apt-get install manpages-posix-dev) 動態初始化 int pthread_...