SpringCloud 消息总线Bus Hoxton版本

2023-10-18 02:38
文章标签 java spring 版本 springcloud bus 总线 消息 hoxton

本文主要是介绍SpringCloud 消息总线Bus Hoxton版本，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Spring Cloud Bus简介：Spring Cloud Bus即消息总线通过一个轻量级的消息中间件可以连接分布式系统中的各个节点。可以使用该总线来广播某些状态比如配置信息的改变或其他管理指令。AMQP和Kafka实现包含在其中。或者，在类路径上找到的任何Spring Cloud Stream绑定器都可以作为一个现成的传输工具。

本文主要对Spring Cloud Bus的基本使用进行简单总结，其中SpringBoot使用的2.2.2.RELEASE版本，SpringCloud使用的Hoxton.SR1版本。这里将沿用SpringCloud 服务注册与发现Eureka Hoxton版本的eureka-server作为注册中心，并将SpringCloud 分布式配置中心Config Hoxton版本的config-server和config-client的内容复制到新建项目里面，在此基础上添加消息总线实现动态刷新配置。

一、Bus结合RabbitMQ动态刷新配置

RabbitMQ的安装这里就不总结了，笔者这里使用的RabbitMQ容器，不清楚的可以先参考Docker常见应用部署中的RabbitMQ部署。

1.Config服务端添加Bus支持

通过Maven新建一个名为spring-cloud-bus-server的项目，并将config-server的内容复制进来，在此基本上进行改造。

（1）引入依赖

还需引入以下依赖：

<!-- Spring Cloud Bus Amqp 起步依赖 -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<!-- Actuator 起步依赖 -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

（2）编写配置文件

在application.yml中进行如下配置：

server:port: ${PORT:9600}spring:application:name: bus-serversecurity:# 配置spring security登录用户名和密码，给Config配置中心添加认证user:name: rtxtitanvpassword: rtxtitanvcloud:config:server:git:# 指定git远程仓库地址uri: https://github.com/RtxTitanV/springcloud-config-repository.git# 指定git仓库用户名密码，公开仓库可以不指定用户名密码，私有仓库需要指定# 指定git仓库用户名username: rtxtitanv# 指定git仓库密码password: .*********.# 指定是否开启启动时直接从git获取配置，true：开启，false：关闭clone-on-start: true# 指定是否强制从远程仓库拉取，true：是，false：否，默认falseforce-pull: true# 指定配置文件被剪出或克隆到本地文件系统的存放目录basedir: E:\software\DevelopmentTool\IntelliJ IDEA Space\my_project\springcloud-config-repository\localrep# rabbitmq相关配置rabbitmq:# 指定rabbitmq的hosthost: 这里可以填自己的rabbitmq服务器ip# 指定rabbitmq的端口port: 5672# 指定rabbitmq的用户名username: admin# 指定rabbitmq的密码password: admin eureka:client:# 服务注册，是否将服务注册到Eureka注册中心，true：注册，false：不注册register-with-eureka: true# 服务发现，是否从Eureka注册中心获取注册信息，true：获取，false：不获取fetch-registry: true# 配置Eureka注册中心即Eureka服务端的地址，集群地址以,隔开service-url:defaultZone: http://rtxtitanv:rtxtitanv@eureka-server-01:8001/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-02:8002/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-03:8003/eureka/instance:# 将ip地址注册到Eureka注册中心prefer-ip-address: true# 该服务实例在注册中心的唯一实例ID，${spring.cloud.client.ip-address}获取该服务实例ipinstance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${server.port}# 该服务实例向注册中心发送心跳间隔，单位秒，默认30秒lease-renewal-interval-in-seconds: 20# Eureka注册中心在删除此实例之前收到最后一次心跳后的等待时间，单位秒，默认90秒lease-expiration-duration-in-seconds: 60management:endpoints:web:exposure:# 暴露指定端点，bus-refresh为bus刷新配置端点include: 'bus-refresh'

2.Config客户端添加Bus支持

通过Maven新建一个名为spring-cloud-bus-client的项目，并将config-client的内容复制进来，在此基本上进行改造。

（1）引入依赖

还需引入以下依赖：

<!-- Spring Cloud Bus Amqp 起步依赖 -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

（2）编写配置文件

在bootstrap.yml里进行如下配置：

server:port: ${PORT:9700}spring:application:name: bus-clientcloud:config:discovery:# 指定是否启用服务发现访问配置中心服务端，true：启用，false：不启用enabled: true# 指定分布式配置中心服务名称service-id: bus-server# 指定连接配置中心服务端的用户名username: rtxtitanv# 指定连接配置中心服务端的密码password: rtxtitanv# 指定要获取的配置文件的前缀名，对应配置文件中的{application}name: application# 指定要获取的配置文件的环境名，对应配置文件中{profile}profile: dev# 指定要获取的配置文件的分支名，对应{label}，默认为masterlabel: master# 指定是否开启快速失败响应，true：开启，false：关闭fail-fast: true# config客户端重试配置retry:# 指定最大重试次数，默认6max-attempts: 8# 指定最大间隔时间，单位ms，默认2000max-interval: 1200# 指定间隔乘数，默认1.1multiplier: 1.2# 指定初始重试间隔时间，单位ms，默认1000initial-interval: 800# rabbitmq相关配置rabbitmq:# 指定rabbitmq的hosthost: 这里可以填自己的rabbitmq服务器ip# 指定rabbitmq的端口port: 5672# 指定rabbitmq的用户名username: admin# 指定rabbitmq的密码password: admineureka:client:# 服务注册，是否将服务注册到Eureka注册中心，true：注册，false：不注册register-with-eureka: true# 服务发现，是否从Eureka注册中心获取注册信息，true：获取，false：不获取fetch-registry: true# 配置Eureka注册中心即Eureka服务端的地址，集群地址以,隔开service-url:defaultZone: http://rtxtitanv:rtxtitanv@eureka-server-01:8001/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-02:8002/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-03:8003/eureka/instance:# 将ip地址注册到Eureka注册中心prefer-ip-address: true# 该服务实例在注册中心的唯一实例ID，${spring.cloud.client.ip-address}获取该服务实例ipinstance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${server.port}# 该服务实例向注册中心发送心跳间隔，单位秒，默认30秒lease-renewal-interval-in-seconds: 20# Eureka注册中心在删除此实例之前收到最后一次心跳后的等待时间，单位秒，默认90秒lease-expiration-duration-in-seconds: 60management:endpoints:web:exposure:# 暴露指定端点，bus-refresh为bus刷新配置端点include: 'bus-refresh'

3.动态刷新配置测试

（1）启动项目

如果启动时出现An unexpected connection driver error occured错误，是由于RabbitMQ用户没有读写等操作的权限，需要按照下列图中操作设置用户权限，Virtual Host最好设置为斜杠：
Virtual Host设置为斜杠
进入Virtual Host
设置权限
IDEA启动eureka-server集群，bus-server和bus-client集群，访问注册中心，下图为服务注册信息：
服务注册信息
访问RabbitMQ管理页面，,下面动图为访问结果，可以发现Spring Cloud Bus创建了三个连接，一个名为springCloudBus的交换机以及三个以 springCloudBus.anonymous开头的队列：
RabbitMQ中的信息

（2）解决使用安全认证后刷新不了配置问题

在Config配置中心服务加入了SpringSecurity安全认证后，POST请求访问/actuator/bus-refresh端点异常，然后再次访问客户端接口也刷新不了配置，这时需自定义一个继承WebSecurityConfigAdapter的子类：

package com.rtxtitanv.config;import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
import org.springframework.security.config.http.SessionCreationPolicy;/*** @author rtxtitanv* @version 1.0.0* @name com.rtxtitanv.config.WebSecurityConfig* @description WebSecurityConfig* @date 2020/3/13 20:55*/
@EnableWebSecurity
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {@Overrideprotected void configure(HttpSecurity http) throws Exception {http.sessionManagement().sessionCreationPolicy(SessionCreationPolicy.NEVER);// 关闭security的csrf检验http.csrf().disable();// 为了可以使用http://${user}:${password}@${host}:${port}/eureka/这种方式登录，所以必须是httpBasic，// 如果是form方式，不能使用url格式登录http.authorizeRequests().anyRequest().authenticated().and().httpBasic();}
}

（3）动态刷新配置

分别访问http://localhost:9701/getConfig和http://localhost:9702/getConfig，结果见下面动图：
修改配置前
修改application-dev.yml配置文件，具体修改见下图：
修改配置
然后再次访问http://localhost:9701/getConfig和http://localhost:9702/getConfig发现没变化，POST请求访问http://localhost:9701/actuator/bus-refresh后再重试之前的两个链接，根据下面动图的测试过程和结果，说明动态刷新配置成功。
刷新配置1
上面这种向具体服务中的某个实例发送请求，再触发对整个服务集群的动态配置更新，虽然能实现功能，但是指定的实例会不同于集群中的其他应用实例，会增加集群内部的复杂度，不利于后期维护。所以给Config服务端也添加了消息总线支持，这样只需将/actuator/bus-refresh请求直接发到配置中心，这样刷新配置全交给配置中心，普通客户端不需要再触发刷新配置，减少了一些不必要的维护工作。下面再次修改application-dev.yml配置文件，具体修改见下图：
修改配置2
然后再次进行动态配置刷新测试，这次POST请求访问http://localhost:9600/actuator/bus-refresh，根据下面动图的测试过程和结果，,说明动态刷新配置成功。
刷新配置2
如果只需要刷新指定实例的配置按以http://localhost:9600/actuator/bus-refresh/{destination}格式发送POST请求，下面将application-dev.yml内容改为master-config-dev-bus-refresh-3，然后发送POST请求http://localhost:9600/actuator/bus-refresh/bus-client:9701只刷新bus-client:9701实例，根据下面动图的测试过程和结果，说明动态刷新指定实例配置成功。
刷新配置3

4.结合WebHooks全自动刷新配置

在仓库中设置WebHooks，在配置发生变更时WebHooks会自动发送POST请求触发动态刷新配置，下面的URL应设置为能被外部访问的配置中心的地址，不能为localhost，有兴趣的可以测试一下。
设置WebHooks

二、Bus结合Kafka动态刷新配置

Kafka的安装这里就不总结了，笔者是在阿里云上安装的，有不清楚的可以参考阿里云部署Kafka。

1.Config服务端添加Bus支持

（1）引入依赖

还需引入以下依赖：

<!-- Spring Cloud Bus Kafka 起步依赖 -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>

（2）编写配置文件

在application.yml中进行如下配置：

server:port: ${PORT:9600}spring:application:name: bus-serversecurity:# 配置spring security登录用户名和密码，给Config配置中心添加认证user:name: rtxtitanvpassword: rtxtitanvcloud:config:server:git:# 指定git远程仓库地址uri: https://github.com/RtxTitanV/springcloud-config-repository.git# 指定git仓库用户名密码，公开仓库可以不指定用户名密码，私有仓库需要指定# 指定git仓库用户名username: rtxtitanv# 指定git仓库密码password: .*********.# 指定是否开启启动时直接从git获取配置，true：开启，false：关闭clone-on-start: true# 指定是否强制从远程仓库拉取，true：是，false：否，默认falseforce-pull: true# 指定配置文件被剪出或克隆到本地文件系统的存放目录basedir: E:\software\DevelopmentTool\IntelliJ IDEA Space\my_project\springcloud-config-repository\localrep# kafka相关配置kafka:# 指定host/port列表，用于建立和Kafka服务器的连接# 集群可以配置为ip:port,ip:port,ip:port,...,ip:portbootstrap-servers: 这里可以填自己的Kafka服务器ip:9092eureka:client:# 服务注册，是否将服务注册到Eureka注册中心，true：注册，false：不注册register-with-eureka: true# 服务发现，是否从Eureka注册中心获取注册信息，true：获取，false：不获取fetch-registry: true# 配置Eureka注册中心即Eureka服务端的地址，集群地址以,隔开service-url:defaultZone: http://rtxtitanv:rtxtitanv@eureka-server-01:8001/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-02:8002/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-03:8003/eureka/instance:# 将ip地址注册到Eureka注册中心prefer-ip-address: true# 该服务实例在注册中心的唯一实例ID，${spring.cloud.client.ip-address}获取该服务实例ipinstance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${server.port}# 该服务实例向注册中心发送心跳间隔，单位秒，默认30秒lease-renewal-interval-in-seconds: 20# Eureka注册中心在删除此实例之前收到最后一次心跳后的等待时间，单位秒，默认90秒lease-expiration-duration-in-seconds: 60management:endpoints:web:exposure:# 暴露指定端点，bus-refresh为bus刷新配置端点include: 'bus-refresh'

2.Config客户端添加Bus支持

（1）引入依赖

还需引入以下依赖：

<!-- Spring Cloud Bus Kafka 起步依赖 -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>

（2）编写配置文件

在bootstrap.yml里进行如下配置：

server:port: ${PORT:9700}spring:application:name: bus-clientcloud:config:discovery:# 指定是否启用服务发现访问配置中心服务端，true：启用，false：不启用enabled: true# 指定分布式配置中心服务名称service-id: bus-server# 指定连接配置中心服务端的用户名username: rtxtitanv# 指定连接配置中心服务端的密码password: rtxtitanv# 指定要获取的配置文件的前缀名，对应配置文件中的{application}name: application# 指定要获取的配置文件的环境名，对应配置文件中{profile}profile: dev# 指定要获取的配置文件的分支名，对应{label}，默认为masterlabel: master# 指定是否开启快速失败响应，true：开启，false：关闭fail-fast: true# config客户端重试配置retry:# 指定最大重试次数，默认6max-attempts: 8# 指定最大间隔时间，单位ms，默认2000max-interval: 1200# 指定间隔乘数，默认1.1multiplier: 1.2# 指定初始重试间隔时间，单位ms，默认1000initial-interval: 800# kafka相关配置kafka:# 指定host/port列表，用于建立和Kafka服务器的连接# 集群可以配置为ip:port,ip:port,ip:port,...,ip:portbootstrap-servers: 这里可以填自己的Kafka服务器ip:9092eureka:client:# 服务注册，是否将服务注册到Eureka注册中心，true：注册，false：不注册register-with-eureka: true# 服务发现，是否从Eureka注册中心获取注册信息，true：获取，false：不获取fetch-registry: true# 配置Eureka注册中心即Eureka服务端的地址，集群地址以,隔开service-url:defaultZone: http://rtxtitanv:rtxtitanv@eureka-server-01:8001/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-02:8002/eureka/,http://rtxtitanv:rtxtitanv@eureka-server-03:8003/eureka/instance:# 将ip地址注册到Eureka注册中心prefer-ip-address: true# 该服务实例在注册中心的唯一实例ID，${spring.cloud.client.ip-address}获取该服务实例ipinstance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${server.port}# 该服务实例向注册中心发送心跳间隔，单位秒，默认30秒lease-renewal-interval-in-seconds: 20# Eureka注册中心在删除此实例之前收到最后一次心跳后的等待时间，单位秒，默认90秒lease-expiration-duration-in-seconds: 60management:endpoints:web:exposure:# 暴露指定端点，bus-refresh为bus刷新配置端点include: 'bus-refresh'

3.动态刷新配置测试

（1）启动项目

IDEA启动eureka-server集群，bus-server和bus-client集群，访问注册中心，下图为服务注册信息：
服务注册信息
如果出现下面的错误，原因是RabbitMQ和Kafka的Bus依赖不能共存，需去掉或者注释掉RabbitMQ的Bus依赖。

java.lang.IllegalStateException: No instances found of configserver (bus-server)

查看topic，下图为topic列表，发现Spring Cloud Bus自动创建了一个名为springCloudBus的topic：
查看topic

（2）动态刷新配置

修改application-dev.yml配置文件，具体修改见下图：
修改配置4
通过POST请求访问http://localhost:9701/actuator/bus-refresh测试动态刷新配置，根据下面动图的测试过程和结果，说明动态刷新配置成功。
刷新配置4
将application-dev.yml内容改为master-config-dev-bus-refresh-5，通过POST请求访问http://localhost:9600/actuator/bus-refresh测试动态刷新配置，根据下面动图的测试过程和结果，说明动态刷新配置成功。
属性配置5
将application-dev.yml内容改为master-config-dev-bus-refresh-6，通过POST请求访问http://localhost:9600/actuator/bus-refresh/bus-client:9702只刷新bus-client:9702实例，根据下面动图的测试过程和结果，说明动态刷新指定实例配置成功。
刷新配置6

代码示例

  • Github：
    https://github.com/RtxTitanV/springcloud-learning/tree/master/springcloud-hoxton-learning/spring-cloud-bus-server
    https://github.com/RtxTitanV/springcloud-learning/tree/master/springcloud-hoxton-learning/spring-cloud-bus-client
  • Gitee：
    https://gitee.com/RtxTitanV/springcloud-learning/tree/master/springcloud-hoxton-learning/spring-cloud-bus-server
    https://gitee.com/RtxTitanV/springcloud-learning/tree/master/springcloud-hoxton-learning/spring-cloud-bus-client

这篇关于SpringCloud 消息总线Bus Hoxton版本的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/229635。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
Java进阶13讲__第12讲_1/2

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory
阅读更多...
JAVA智听未来一站式有声阅读平台听书系统小程序源码

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来，一站式有声阅读平台听书系统 🌟&nbsp;开篇：遇见未来，从“智听”开始 在这个快节奏的时代，你是否渴望在忙碌的间隙，找到一片属于自己的宁静角落？是否梦想着能随时随地，沉浸在知识的海洋，或是故事的奇幻世界里？今天，就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统，它正悄悄改变着我们的阅读方式，让未来触手可及！ 📚&nbsp;第一站：海量资源，应有尽有 走进“智听
阅读更多...
Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸： 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  （注意不能是bmp格式） 替换默认锁屏壁纸： 将图片资源放入vendo
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2