脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Spring Cloud Bus消息总线

解析Spring Cloud Bus消息总线

 更新时间：2021年10月31日 12:00:44   作者：一代健客  
这篇文章主要介绍了Spring Cloud Bus消息总线的介绍及使用，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

概念

我们使用配置中心时，当配置中心的配置发生了变化，我们就要发送一个post请求给客户端，让它重新去拉取新的的配置。当客户端有很多时，并且还是使用同一份配置文件，这样当配置中心的配置发生改变，我们就得逐个发送post请求通知，这样无疑是很浪费人力物力的。
Bus消息总线组件就帮我们解决了这个问题。他的工作流程是这样的，当配置中心的配置发生了变化时，我们给其中一个客户端发送post请求，然后client将请求的信息发送到rabbitmq队列中，然后消息队列将消息发送给别的队列。

使用

准备工作

项目基于Spring Cloud 第七章的项目改造。

改造config-client 添加相应坐标

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

		<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>

在启动类中添加@RefreshScope注解
@RefreshScope注解只需要写在需要刷新配置文件的地方，不一定非要在启动类中

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
@RestController
@RefreshScope
public class ConfigClientApplication {

	/**
	 * http://localhost:8881/actuator/bus-refresh
	 */

	public static void main(String[] args) {
		SpringApplication.run(ConfigClientApplication.class, args);
	}

	@Value("${foo}")
	String foo;

	@RequestMapping(value = "/hi")
	public String hi(){
		return foo;
	}
}

配置相关配置

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

spring.cloud.bus.enabled=true
spring.cloud.bus.trace.enabled=true
management.endpoints.web.exposure.include=bus-refresh
management.security.enabled=false  //报错加上
  • 依次启动eureka-server、confg-cserver,启动两个config-client，端口为：8881、8882。
  • 访问http://localhost:8881/hi 或者http://localhost:8882/hi 浏览器显示：

foo version 3

foo version 4

另外，/actuator/bus-refresh接口可以指定服务，即使用"destination"参数，比如 “/actuator/bus-refresh?destination=customers:**” 即刷新服务名为customers的所有服务。 原理图

在这里插入图片描述

当git文件更改的时候，通过pc端用post 向端口为8882的config-client发送请求/bus/refresh／；此时8882端口会发送一个消息，由消息总线向其他服务传递，从而使整个微服务集群都达到更新配置文件。

您可能感兴趣的文章:

相关文章

  • Java volatile关键字特性讲解上篇

    Java volatile关键字特性讲解上篇

    JMM要求保证可见性、原子性、有序性，volatile可以保证其中的两个，本篇文章具体验证volatile的可见性，不原子性和禁重排，同时解决volatile的不保证原子性，让代码具有原子性
    2022-12-12
  • Java经典面试题汇总:Spring

    Java经典面试题汇总:Spring

    本篇总结的是Spring框架相关的面试题，后续会持续更新，希望我的分享可以帮助到正在备战面试的实习生或者已经工作的同行，如果发现错误还望大家多多包涵，不吝赐教，谢谢
    2021-07-07
  • WebSocket实现数据库更新时前端页面刷新

    WebSocket实现数据库更新时前端页面刷新

    这篇文章主要为大家详细介绍了WebSocket实现数据库更新时前端页面刷新，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2019-04-04
  • SpringMVC实现登录与注册功能的详细步骤

    SpringMVC实现登录与注册功能的详细步骤

    本文介绍了如何通过Maven配置依赖,创建前端登录和注册页面,并实现后端逻辑,详细步骤包括配置文件、创建User类、配置中文过滤器及DispatcherServlet,并使用Spring MVC和JQuery处理前端请求,需要的朋友可以参考下
    2024-11-11
  • IDEA项目中配置Maven镜像源(下载源)的详细过程

    IDEA项目中配置Maven镜像源(下载源)的详细过程

    Maven是一个能使我们的java程序开发节省时间和精力,是开发变得相对简单,还能使开发规范化的工具,下面这篇文章主要给大家介绍了关于IDEA项目中配置Maven镜像源(下载源)的详细过程,需要的朋友可以参考下
    2024-02-02
  • 浅析Spring容器原始Bean是如何创建的

    浅析Spring容器原始Bean是如何创建的

    这篇文章主要是想和小伙伴们一起聊聊 Spring 容器创建 Bean 最最核心的 createBeanInstance 方法，文中的示例代码讲解详细，需要的可以参考一下
    2023-08-08
  • SpringBoot集成Nacos的项目实践

    SpringBoot集成Nacos的项目实践

    本文主要介绍了SpringBoot集成Nacos的项目实践，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2023-07-07
  • 浅谈java常用的几种线程池比较

    浅谈java常用的几种线程池比较

    下面小编就为大家带来一篇浅谈java常用的几种线程池比较。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-01-01
  • MyBatis快速入门

    MyBatis快速入门

    MyBatis是支持普通SQL查询，存储过程和高级映射的优秀持久层框架。MyBatis消除了几乎所有的JDBC代码和参数的手工设置以及结果集的检索。想要学好它，那就要从MyBatis基础知识学起，下面跟着小编一起来看下吧
    2017-03-03
  • Spring源码解析之循环依赖的实现流程

    Spring源码解析之循环依赖的实现流程

    这篇文章主要介绍了Spring源码解析之循环依赖的实现流程，文章基于Java的相关内容展开循环依赖的实现流程，需要的小伙伴可以参考一下
    2022-07-07

最新评论