SpringCloud整合MQ实现消息总线服务方式

2025-05-22 03:50

本文主要是介绍SpringCloud整合MQ实现消息总线服务方式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《SpringCloud整合MQ实现消息总线服务方式》:本文主要介绍SpringCloud整合MQ实现消息总线服务方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐...

一、背景介绍

每当修改配置文件内容,如果需要客户端也同步更新,就需要手动调用/refresh接口,以便客户端能获取到最新的配置内容。

当客户端越来越多的时候,通过人工进行处理显然非常鸡肋。有没有一种更加高效的办法,当手动调用其中一个客户端的/refresh接口,其它的客户端也自动更新?

在 Spring Cloud 体系里,有一个叫做 Spring Cloud Bus 模块,也被业界称为消息总线。它可以将分布式系统内的节点以消息代理方式连接起来,开发者可以通过消息代理服务向其它节点传输数据的变更,例如配置文件的更改,也可以用于收集节点监控数据。其中常用的消息代理服务有 RabbitMQ 和 Kafka。

换言之,我们可以借助 Spring Cloud Bus 模块来实现上文介绍的诉求,引入 Spring Cloud Bus 模块后,客户端获取远程配置文件的方式,可以用如下流程图来描述。

SpringCloud整合MQ实现消息总线服务方式

熟悉 MQ 服务的可能一眼就看出来了,其原理就是借助 MQ 服务的发布与订阅功能向其它节点进行广播数据,从而实现客户端自动刷新配置功能。

其交互流程可以用如下内容来概括。

1.当外部请求调用客户端 A 的/refresh接口后,除了主动刷新配置意外,还会通过 Spring Cloud Bus 模块,将刷新配置接口的指令数据发送到 MQ 服务器

2.MQ 服务器会将指令数据通过 Spring Cloud Bus 模块推送给其它客户端

3.客户端 B、C 接收到最新的消息指令后,主动调用刷新配置服务,获取最新的配置内容

下面我们通过具体的例子,结合之前介绍的知识,看看如何利用 Spring Cloud Bus 实现客户端配置文件自动刷新的效果。

二、方案实践

在此,我们采用 RabbitMQ 服务器来搭建消息总线,因此需要事先准备一台可用的 RabbitMQ 服务器,具体的安装教程之前有所介绍,大家也可以百度搜索一下,具体的安装过程就不再重复撰述。

2.1、添加依赖

根据eureka-config-client复制一个服务消费者工程,命名为eureka-config-client-bus,并在pom.XML中引入spring-cloud-starter-bus-amqp依赖包,示例如下:

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

2.2、添加配置文件

接着,在bootstrap.properties配置文件中添加消息代理相关的属性信息,示例如下:

# 配置rabbitmq编程服务器地址
spring.rabbitmq.hostChina编程=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

2.3、服务测试

然后,依次将eureka-server、eureka-config-server、eureka-config-client-bus (分别在不同的端口上,比如9022、9023) 服务启动起来。访问 eureka 可视化页面,如果服务都正常,可以看到类似于如下的界面。

SpringCloud整合MQ实现消息总线服务方式

将远程仓库配置文件中的blog.name=hahaha修改成bl编程jsog.name=hahaha123456,以便测试客户端配置文件是否能自动更新。

接着,向其中一个客户端发送一个/bus/refresh的 POST 请求。

需要注意的是,这里的路径是/bus/refresh,而不是/refresh

SpringCloud整合MQ实现消息总线服务方式

最后,在浏览器中重新访问另一个客户端读取配置文件的接口,不意外的话,客户端获取的是最新的配置信息。

说明客户端已经成功读取到最新的配置内容。

查看客户端的日志,也会看到类似于如下的信息。

Received remote refresh request. Keys refreshed [config.client.version, blog.name]

2.4、WebHook

可能有人会发出一个疑问,不可能每次修改仓库的配置文件,自己都需要手动调用/bus/refresh接口吧。

实际上,GIT 里面有个 WebHooks 功能,每次 push 代码后,我们可以利用它给远程 HTTP URL 发送一个 POST 请求,以此省去手动调用的工作。

SpringCloud整合MQ实现消息总线服务方式

操作非常简单,只需要将其中一个客户端/bus/refresh接口地址添加进去即可。需要注意的是,这里的 HTTP URL 必须是一个能请求通过的公网地址哈!

三、升级版

在以上的方案中,虽然我们利用消息总线实现了手动刷新一个客户端的配置文件更新,其它客户端也同步跟着一起刷新的目的,但在实际的实践过程中,发现还是有一些不便的地方。

例如客户端因为业务的快速迭代会频繁的发布服务,同时也会根据服务的并发量适度的增减服务实例数量,这种情况下,客户端的 IP 和端口会经常发生变动,每次人工运维起来会很繁琐。

因此,我们可以将上面的交互流程改变一下,由服务配置中心通过 Spring Cloud Bus 模块向客户端发送重刷配置文件的指令。

整个流程,可以用如下图来描述。

SpringCloud整合MQ实现消息总线服务方式

因为服务配置中心基本上很少会去迭代,客户端的 IP 和端口发生变动的可能性较小,由它向客户端推送消息,运维的工作量可以显著的下降。

改造的流程也很简单,只需要两步即可!

3.1、添加依赖

与上文类似,根据eureka-config-server复制一个服务消费者工程,命名为eureka-config-server-bus,并在pom.xml中引入spring-cloud-starter-bus-amqp依赖包,示例如下:

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>编程China编程;
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-config-server</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>
</dependencies>

3.2、添加配置文件

接着,在application.properties中添加消息代理服务相关的属性,示例如下:

spring.application.name=eureka-config-server
server.port=9020

# 配置git仓库地址
spring.cloud.config.server.git.uri=https://gitee.com/pzblogs/config-demo
spring.cloud.config.server.git.username=
spring.cloud.config.server.git.password=

# 设置与Eureka Server交互的地址,多个地址可使用【,】分隔
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

# 关闭安全认证
management.security.enabled=false

# 配置rabbitmq服务器地址
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3.3、服务测试

然后,依次将eureka-server、eureka-config-server-bus、eureka-config-client-bus服务启动起来。

接着,修改仓库中的配置文件内容,完成之后,以 POST 方式调用服务配置中心的刷新配置接口,例如http://localhost:9020/bus/refresh。

最后,在浏览器访问客户端http://localhost:9023/hello,不意外的话,能看到最新的信息。

总结

最后总结一下,当我们手动更新某个仓库配置文件的时候,想要实现所有客户端同时也自动更新配置,可以利用消息总线来实现节点之间数据的同步变更操作。

如果想要用 Kafka 来做消息代理服务,实现思路也类似,将bus-amqp换成bus-kafka,示例子如下

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>

最后在配置文件中添加 Kafka 相关服务地址配置参数即可。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持China编程(www.chinasem.cn)。

这篇关于SpringCloud整合MQ实现消息总线服务方式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1154723

相关文章

Spring Boot中WebSocket常用使用方法详解

《SpringBoot中WebSocket常用使用方法详解》本文从WebSocket的基础概念出发,详细介绍了SpringBoot集成WebSocket的步骤,并重点讲解了常用的使用方法,包括简单消... 目录一、WebSocket基础概念1.1 什么是WebSocket1.2 WebSocket与HTTP

关于DNS域名解析服务

《关于DNS域名解析服务》:本文主要介绍关于DNS域名解析服务,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录DNS系统的作用及类型DNS使用的协议及端口号DNS系统的分布式数据结构DNS的分布式互联网解析库域名体系结构两种查询方式DNS服务器类型统计构建DNS域

SpringBoot+Docker+Graylog 如何让错误自动报警

《SpringBoot+Docker+Graylog如何让错误自动报警》SpringBoot默认使用SLF4J与Logback,支持多日志级别和配置方式,可输出到控制台、文件及远程服务器,集成ELK... 目录01 Spring Boot 默认日志框架解析02 Spring Boot 日志级别详解03 Sp

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库:CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合

java中反射Reflection的4个作用详解

《java中反射Reflection的4个作用详解》反射Reflection是Java等编程语言中的一个重要特性,它允许程序在运行时进行自我检查和对内部成员(如字段、方法、类等)的操作,本文将详细介绍... 目录作用1、在运行时判断任意一个对象所属的类作用2、在运行时构造任意一个类的对象作用3、在运行时判断

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

golang版本升级如何实现

《golang版本升级如何实现》:本文主要介绍golang版本升级如何实现问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录golanwww.chinasem.cng版本升级linux上golang版本升级删除golang旧版本安装golang最新版本总结gola

java如何解压zip压缩包

《java如何解压zip压缩包》:本文主要介绍java如何解压zip压缩包问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解压zip压缩包实例代码结果如下总结java解压zip压缩包坐在旁边的小伙伴问我怎么用 java 将服务器上的压缩文件解压出来,

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具

Spring WebFlux 与 WebClient 使用指南及最佳实践

《SpringWebFlux与WebClient使用指南及最佳实践》WebClient是SpringWebFlux模块提供的非阻塞、响应式HTTP客户端,基于ProjectReactor实现,... 目录Spring WebFlux 与 WebClient 使用指南1. WebClient 概述2. 核心依