SpringCloud之消息总线

时间  2021-01-05
标签 git github web spring bootstrap api 网络 架构 并发 app 栏目 主板 繁體版
原文   原文链接

【前面的话】书接上文SpringCloud之Config，若是没有看过能够先移步去看一下。在上一篇文章中提到了配置刷新的问题，若是须要刷新配置就须要客户端执行refresh，咱们能够利用webhook的机制每次提交代码发送请求来刷新客户端，当客户端愈来愈多的时候，须要每一个客户端都执行一遍，这种方案就不太适合了。使用Spring Cloud Bus能够完美解决这一问题。git

壹、Spring Cloud Bus的简介

Spring cloud bus经过轻量消息代理链接各个分布的节点。这会用在广播状态的变化（例如配置变化）或者其余的消息指令。Spring bus的一个核心思想是经过分布式的启动器对spring boot应用进行扩展，也能够用来创建一个多个应用之间的通讯频道。目前惟一实现的方式是用AMQP消息代理做为通道，一样特性的设置（有些取决于通道的设置）在更多通道的文档中。github

贰、解决方案

方案一：

  • Spring cloud bus被国内不少都翻译为消息总线，也挺形象的。你们能够将它理解为管理和传播全部分布式项目中的消息既可，其实本质是利用了MQ的广播机制在分布式的系统中传播消息，目前经常使用的有Kafka和RabbitMQ。利用bus的机制能够作不少的事情，其中配置中心客户端刷新就是典型的应用场景之一，咱们用一张图来描述bus在配置中心使用的机制。

方案一流程图

根据此图咱们能够看出利用Spring Cloud Bus作配置更新的步骤:web

一、提交代码触发post给客户端A发送/actuator/bus-refresh
    二、客户端A接收到请求从Server端更新配置而且发送给Spring Cloud Bus
    三、Spring Cloud bus接到消息并通知给其它客户端
    四、其它客户端接收到通知，请求Server端获取最新配置
    五、所有客户端均获取到最新的配置

方案二：

  • 在方案一中咱们已经到达了利用消息总线触发一个客户端/actuator/bus-refresh,而刷新全部客户端的配置的目的。但这种方式并不优雅。缘由以下：
打破了微服务的职责单一性。微服务自己是业务模块，它本不该该承担配置刷新的职责。
   破坏了微服务各节点的对等性。
   有必定的局限性。例如，微服务在迁移时，它的网络地址经常会发生变化，此时若是想要作到自动刷新，那就不得不修改WebHook的配置。

所以咱们将方案一的架构模式稍微改变一下spring

方案二流程图

这时Spring Cloud Bus作配置更新步骤以下:bootstrap

一、提交代码触发post请求给bus/refresh
  二、server端接收到请求并发送给Spring Cloud Bus
  三、Spring Cloud bus接到消息并通知给其它客户端
  四、其它客户端接收到通知，请求Server端获取最新配置
  五、所有客户端均获取到最新的配置

下面咱们就采用方案二来改造咱们的工程，这样的话咱们在server端的代码作一些改动，来支持bus/refreshapi

叁、改造服务端

  • 改造上文的config的服务端子工程lovin-config-server，添加RabbitMQ的依赖。下面是改造后的主要的pom依赖:
<parent>
        <artifactId>lovincloud</artifactId>
        <groupId>com.eelve.lovincloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>lovin-config-server</artifactId>
    <packaging>jar</packaging>
    <name>lovinconfigserver</name>
    <version>0.0.1</version>
    <description>配置服务端</description>

    <dependencies>
        <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-security</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>de.codecentric</groupId>
            <artifactId>spring-boot-admin-starter-client</artifactId>
            <version>2.1.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
  • 添加rabbitmq的链接配置
server:
  port: 8886   # 服务端口号
spring:
  application:
    name: lovinconfigserver     # 服务名称
  security:
    basic:
      enabled: true
    user:
      name: lovin
      password: ${REGISTRY_SERVER_PASSWORD:lovin}
  cloud:
    config:
      server:
        git:
          uri: https://github.com/lovinstudio/lovincloud
          search-paths: lovin-config-repo
      label: master
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
eureka:
  client:
    serviceUrl:
      defaultZone: http://lovin:lovin@localhost:8881/eureka/   # 注册到的eureka服务地址

肆、改造配置客户端

  • 改造上文的config的服务端子工程lovin-config-client，添加RabbitMQ的依赖。下面是改造后的主要的pom依赖:
<parent>
        <artifactId>lovincloud</artifactId>
        <groupId>com.eelve.lovincloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>lovin-config-client</artifactId>
    <packaging>jar</packaging>
    <name>lovinconfigclient</name>
    <version>0.0.1</version>
    <description>配置消费端</description>

    <dependencies>
        <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-security</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>de.codecentric</groupId>
            <artifactId>spring-boot-admin-starter-client</artifactId>
            <version>2.1.6</version>
        </dependency>
<!--        <dependency>-->
<!--            <groupId>org.springframework.cloud</groupId>-->
<!--            <artifactId>spring-cloud-config-server</artifactId>-->
<!--        </dependency>-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
            <version>2.1.3.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
  • 添加链接rabbitmq的相关配置
  1. 修改bootstrap.yml添加链接rabbitmq的配置
server:
  port: 8807   # 服务端口号
spring:
  application:
    name: lovinconfigclient     # 服务名称
  security:
    basic:
      enabled: true
    user:
      name: lovin
      password: ${REGISTRY_SERVER_PASSWORD:lovin}
#eureka:
#  client:
#    serviceUrl:
#      defaultZone: http://lovin:lovin@localhost:8881/eureka/   # 注册到的eureka服务地址
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
  1. 修改application.yml开启消息跟踪
spring:
  cloud:
    config:
      name: lovin-config
      profile: dev
      #uri: http://localhost:8886/
      #label: master
      discovery:
        enabled: true
        service-id: lovinconfigserver
    bus:
      trace:
        enabled: true
eureka:
  client:
    serviceUrl:
      defaultZone: http://lovin:lovin@localhost:8881/eureka/   # 注意在高可用的时候须要见注册中心配置移到该文件中，在application.yml中见会读取不到配置

伍、启动测试

  • 1.首先依次启动lovin-eureka-server、lovin-econfig-server、lovin-econfig-client
  • 2.查看lovin-econfig-server查询配置

查看lovin-econfig-server查询配置

  • 3.查看lovin-econfig-client查询配置

查看lovin-econfig-client查询配置

  • 4.修改配置，并提交见token的值由lovin改成lovinupdate

修改token

  • 5.再次查看lovin-econfig-server查询配置

再次查询服务端

  • 6.再次查看lovin-econfig-client查询配置

再次查询客户端

  • 7.刷新消息总线
    因为api变动，url由老版本的/bus/refresh变为actuator/bus-refresh

属性消息总线

  • 8.再次查看lovin-econfig-client查询配置

再次查看客户端配置

咱们能够看到已经刷新成功，至此消息总线配置已经完成网络

陆、局部刷新

某些场景下（例如灰度发布），咱们可能只想刷新部分微服务的配置，此时可经过/actuator/bus-refresh端点的destination参数来定位要刷新的应用程序。架构

  • 例如：/actuator/bus-refresh?destination=customers:8000，这样消息总线上的微服务实例就会根据destination参数的值来判断是否须要要刷新。其中，customers:8000指的是各个微服务的ApplicationContext ID。destination参数也能够用来定位特定的微服务。
  • 例如：/actuator/bus-refresh?destination=customers:**，这样就能够触发customers微服务全部实例的配置刷新。
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程