SpringCloud Bus消息总线

青旅半醒 2022-01-28 11:37 329阅读 0赞

# [SpringCloud Bus消息总线][SpringCloud Bus] #

在微服务架构中，通常会使用轻量级的消息代理来构建一个共用的消息主题来连接各个微服务实例，它广播的消息会被所有在注册中心的微服务实例监听和消费，也称消息总线。

SpringCloud中也有对应的解决方案，SpringCloud Bus 将分布式的节点用轻量的消息代理连接起来，可以很容易搭建消息总线，配合SpringCloud config 实现微服务应用配置信息的动态更新。

消息总线其实**通过消息中间主题模式**，**他使用广播消息的机制被所有在注册中心微服务实例进行监听和消费**。以广播形式将消息推送给所有注册中心服务列表

消息代理属于中间件。设计代理的目的就是为了能够从应用程序中传入消息，并执行一些特别的操作。开源产品很多如ActiveMQ、Kafka、RabbitMQ、RocketMQ等  
目前springCloud仅支持RabbitMQ和Kafka。本文采用RabbitMQ实现这一功能。

图示：

![1179709-20190119191719457-1789141287.png][]

通过客户端去通知每个服务 更新配置文件

升级  通过消息总线的方式：

![1179709-20190119192610112-760283771.png][]

**消息总线**框架底层是MQ实现的，引入相应的jar包，底层框架实现好了，每个服务里面引入了相应的jar包后，自动创建队列 绑定交换机等等

配置文件的应用场景就很符合。

环境搭建：

![1179709-20190119193422153-558979071.png][]

每个服务对于分布式配置中心来说是 client端

配置文件环境 dev test  pre prd

配置文件命名规范  client服务名称（注册中心名称）-版本.yml

![1179709-20190119194108877-1076643824.png][]

创建好这个文件

互联网项目场景中的配置文件 不是存放在本底的  是存放在远程服务器

写在本地 需要重启服务器  ！！

下面开始搭建分布式配置中心 SpringCloude  组件  Config

1、配置文件存放在git 或者 svn

2、搭建分布式配置中心服务

3、客户端读取分布式配置中心服务

configServer端：

配置文件：

![1179709-20190119200043593-486666518.png][]

pom：

<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">
      <modelVersion>4.0.0</modelVersion>
      <groupId>com.toov5</groupId>
      <artifactId>SpringCloud-eureka-server</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.1.RELEASE</version>
        </parent>
        
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Finchley.M7</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
                
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
            
        </dependencies> 
        
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/libs-milestone</url>
                <snapshots>
                    <enabled>false</enabled>
                </snapshots>
            </repository>
        </repositories>
      
    </project>

yml:

###服务注册到eureka地址
    eureka:
      client:
        service-url:
               defaultZone: http://localhost:8100/eureka
    spring:
      application:
        ####注册中心应用名称
        name: config-server
      cloud:
        config:
          server:
            git:
              ###git环境地址
              uri: https://gitee.com/toov5/distributed_configuration_file.git
              ####搜索目录
              search-paths:
                - Test  
          ####读取分支      
          label: master
    ####端口号      
    server:
      port: 8888

启动：

package com.toov5.app;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.config.server.EnableConfigServer;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    @EnableConfigServer
    public class AppServerConfig {
       
        public static void main(String[] args) {
            SpringApplication.run(AppServerConfig.class, args);
        }
    }

启动Eureka后启动 configServer

访问地址： http://127.0.0.1:8888//appConfig-dev.yml

![1179709-20190119213752163-1113577232.png][]

Client端：

pom:

<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">
      <modelVersion>4.0.0</modelVersion>
      <groupId>com.toov5</groupId>
      <artifactId>SpringCloud_config_client</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.1.RELEASE</version>
        </parent>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-config-client</artifactId>
                <version>2.0.2.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
                <version>2.0.2.RELEASE</version>
            </dependency>
    
        </dependencies>
        
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/libs-milestone</url>
                <snapshots>
                    <enabled>false</enabled>
                </snapshots>
            </repository>
        </repositories>
      
    </project>

Controller：

package com.toov5.controller;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class IndexController {
         @Value("${userAge}")  //配置中心的 我们这个字段在本地没有配置
         private String userAge;
         
         @RequestMapping("/getUserAge")
         public String getUerAge() {
              return userAge;
         }
    }

启动类：

package com.toov5.controller;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class AppClientConfig {
      public static void main(String[] args) {
        SpringApplication.run(AppClientConfig.class, args);
    }
    }

yml:

对应命名规范去配置!

spring:
      application: 
        ####注册中心应用名称    对应命名规范去配置 appConfig-dev.yml
        name:  appConfig
      cloud:
        config:
        ####读取后缀
          profile: dev   #对应命名规范去配置
          ####读取config-server注册地址
          discovery:
            service-id: config-server   ##服务的名字
            enabled: true
    #####    eureka服务注册地址    
    eureka:
      client:
        service-url:
               defaultZone: http://localhost:8100/eureka    
    server:
      port: 8882

访问结果：

![1179709-20190119221154392-842899295.png][]

如果此时 修改了配置文件，刷新出来的还是不变的！缓存到当前的jvm中了  重启client端就OK了   可以做定时刷新

升级： 不重启服务器自动刷新

1.手动通知刷新单个jvm值

2. 消息总线通知整个微服务刷新

1. 通过监控中心

手动actuator端点刷新数据

引入mavn 到client

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

yml

开启监控服务

management:
      endpoints:
        web:
          exposure:
            include: "*"

此时的yml:

然后Controller 加上 刷新的注解   @RefreshScope

package com.toov5.controller;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.context.config.annotation.RefreshScope;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RefreshScope
    public class IndexController {
         @Value("${userAge}")  //配置中心的 我们这个字段在本地没有配置
         private String userAge;
         
         @RequestMapping("/getUserAge")
         public String getUerAge() {
              return userAge;
         }
    }

对应的值 不用重启就可以刷新了

启动后：修改git的文件值

发送post请求：

http://127.0.0.1:8882/actuator/refresh

![1179709-20190119222639023-758094538.png][]

有个缺点，如果configClient做个集群

如要去刷新每个 服务的值！  postman 搞一遍

升级：这样就需要消息总线了！

SpringCloud整合rabbitmq 和 kafka

本文采用的是rabbitmq去作为案例讲解：

rabbitmq 的加交换机有四种： fanout  direct  topic  head

在这个体系中  微服务有多少个 就会在MQ中创建多少个队列，当手动刷新一个服务时候，会通过rabbitmq 去把消息同时发给交换机，然后通过交换机发送给其他的微服务 。

![1179709-20190119225059196-1611273251.png][]

环境的搭建：

引入maven： bus的核心jar包

client和servler端都需要引入

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

如果报错添加：

<dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-bus-parent</artifactId>
                    <version>2.0.0.RC2</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

客户端需要yml开启bus刷新：client端

###开启bus刷新
    management:
      endpoints:
        web:
          exposure:
            include: bus-refresh

同时需要配置mq的连接信息：

此时的client端yml:

spring:
      rabbitmq:
      ####连接地址
        host: 192.168.91.6
       ####端口号  
        port: 5672
       ####账号
        username: admin
       ####密码 
        password: admin
       ### 地址  主机独立的virtualhost
        virtual-host: /admin_toov5
      application: 
        ####注册中心应用名称    对应命名规范去配置 appConfig-dev.yml
        name:  appConfig
      cloud:
        config:
        ####读取后缀
          profile: dev   #对应命名规范去配置
          ####读取config-server注册地址
          discovery:
            service-id: config-server   ##服务的名字
            enabled: true
    #####    eureka服务注册地址    
    eureka:
      client:
        service-url:
               defaultZone: http://localhost:8100/eureka    
    server:
      port: 8882
      
    ###开启bus刷新
    management:
      endpoints:
        web:
          exposure:
            include: bus-refresh

server:

###服务注册到eureka地址
    eureka:
      client:
        service-url:
               defaultZone: http://localhost:8100/eureka
    spring:
      rabbitmq:
      ####连接地址
        host: 192.168.91.6
       ####端口号  
        port: 5672
       ####账号
        username: admin
       ####密码 
        password: admin
       ### 地址  主机独立的virtualhost
        virtual-host: /admin_toov5
      application:
        ####注册中心应用名称
        name: config-server
      cloud:
        config:
          server:
            git:
              ###git环境地址
              uri: https://gitee.com/toov5/distributed_configuration_file.git
              ####搜索目录
              search-paths:
                - Test  
          ####读取分支      
          label: master
    ####端口号      
    server:
      port: 8888
    
    ###开启bus刷新
    management:
      endpoints:
        web:
          exposure:
            include: bus-refresh

底层会帮助创建 mq队列 主题  两个client  一个 server

![1179709-20190119233007985-1230979831.png][]

![1179709-20190120011317306-1272254641.png][]

访问一个接口  8882 的，其他的服务8883也会跟着改了！

http://127.0.0.1:8882/actuator/bus-refresh

就是玩了个  yml+jar包 而已

[SpringCloud Bus]: https://www.cnblogs.com/toov5/p/10293755.html
[1179709-20190119191719457-1789141287.png]: /images/20220128/8bb6f1e2f2394b48826919ccd18d3697.png
[1179709-20190119192610112-760283771.png]: /images/20220128/a57392411e5f4d3aa5d34bc69624eb92.png
[1179709-20190119193422153-558979071.png]: /images/20220128/1d4719a7fe554cd88deb479f81277742.png
[1179709-20190119194108877-1076643824.png]: /images/20220128/879a58ff04304d2d8b24fbcfc31cd9ee.png
[1179709-20190119200043593-486666518.png]: /images/20220128/7a52b0a6b7bf4d98876039ca7cfc6866.png
[1179709-20190119213752163-1113577232.png]: /images/20220128/00714e01ab1f47fa98e8cd5a01b10e87.png
[1179709-20190119221154392-842899295.png]: /images/20220128/a671b701855d47b6b142a8404f2807da.png
[1179709-20190119222639023-758094538.png]: /images/20220128/10e0d307619e46e3ba73cc1336b98bf6.png
[1179709-20190119225059196-1611273251.png]: /images/20220128/ef331edb34264b3e9f8c58f7efa175c8.png
[1179709-20190119233007985-1230979831.png]: /images/20220128/cbe0363d24af43ca97f1a6c969f6447c.png
[1179709-20190120011317306-1272254641.png]: /images/20220128/8e64960093a341d9ac1ff35bc5529a73.png