SpringCloud——消息总线（Bus）

我会带着你远行 2021-09-16 09:46 468阅读 0赞

### 一、SpringCloud Bus简介 ###

Spring Cloud Bus将分布式系统的节点与轻量级消息代理链接。这可以用于广播状态更改（例如配置更改）或其他管理指令。一个关键的想法是，总线就像一个分布式执行器，用于扩展的Spring Boot应用程序，但也可以用作应用程序之间的通信通道。目前唯一的实现是使用AMQP代理作为传输，但是相同的基本功能集（还有一些取决于传输）在其他传输的路线图上。

消息代理(Message Broker)是一种消息验证、传输、路由的架构模式。它在应用程序之间起到通信调度并最小化应用之间的依赖的作用，使得应用程序可以高效地解耦通信过程。消息代理是一个中间件产品，它的核心是一个消息的路由程序，用来实现接收和分发消息， 并根据设定好的消息处理流来转发给正确的应用。 它包括独立的通信和消息传递协议，能够实现组织内部和组织间的网络通信。设计代理的目的就是为了能够从应用程序中传入消息，并执行一些特别的操作，下面这些是在企业应用中经常需要使用消息代理的场景：

*  将消息路由到一个或多个目的地。
 *  消息转化为其他的表现方式。
 *  执行消息的聚集、消息的分解，并将结果发送到它们的目的地，然后重新组合响应返回给消息用户。
 *  调用Web服务来检索数据。
 *  响应事件或错误。
 *  使用发布－订阅模式来提供内容或基千主题的消息路由。

## ##

### 二、实现代码测试 ###

工程的创建参考上篇[SpringCloud——分布式配置中心（Spring Cloud Config）][SpringCloud_Spring Cloud Config]

地址：[https://blog.csdn.net/typ1805/article/details/82702223][SpringCloud_Spring Cloud Config]

1、RabbitMQ环境搭建，请参考：[https://blog.csdn.net/typ1805/article/details/82744899][https_blog.csdn.net_typ1805_article_details_82744899]

2、其他工程和上一篇的一样，上篇的基础上修改client工程，具体如下：

pom.xml依赖文件：

<?xml version="1.0" encoding="UTF-8"?>
    <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.example.demo.bus</groupId>
    	<artifactId>bus-client</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>bus-client</name>
    	<description>Demo project for Spring Boot</description>
    
    	<parent>
    		<groupId>com.example.demo</groupId>
    		<artifactId>springcloud-bus</artifactId>
    		<version>0.0.1-SNAPSHOT</version>
    	</parent>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter</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-config</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>
    
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    
    </project>

在bootstrap.properties配置文件中添加RabbitMq的配置和spring.cloud.bus的配置，具体如下：

server.port=8083
    
    spring.application.name=bus-client
    spring.cloud.config.profile=dev
    spring.cloud.config.label=master
    #spring.cloud.config.uri= http://localhost:8082/
    
    eureka.client.serviceUrl.defaultZone: http://localhost:8081/eureka/
    spring.cloud.config.discovery.enabled=true
    spring.cloud.config.discovery.serviceId=bus-server
    
    spring.rabbitmq.host=192.168.0.132
    spring.rabbitmq.port=15672
    spring.rabbitmq.username=admin
    spring.rabbitmq.password=admin
    
    spring.cloud.bus.enabled=true
    spring.cloud.bus.trace.enabled=true
    management.endpoints.web.exposure.exclude=refresh

启动类添加注解@RefreshScope，代码如下：

package com.example.demo.bus;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.context.config.annotation.RefreshScope;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    @EnableDiscoveryClient
    @RefreshScope
    public class BusClientApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(BusClientApplication.class, args);
    	}
    }

3、启动工程测试

在浏览器访问[http://localhost:8083/][http_localhost_8083]test  浏览器显示：

foo version 2

去代码仓库修改foo的值改为“foo version 3”，即改变配置文件foo的值。此时，不需要重启工程，只需要发送post请求：[http://localhost:8083/bus/refresh][http_localhost_8083_bus_refresh]，这时bus-client会重新读取配置文件，再次访问[http://localhost:8083/][http_localhost_8083]test  浏览器显示：

foo version 3

### 三、架构 ###

![70][]

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

源码下载： [https://download.csdn.net/download/typ1805/10675045][https_download.csdn.net_download_typ1805_10675045]

[SpringCloud_Spring Cloud Config]: https://blog.csdn.net/typ1805/article/details/82702223
[https_blog.csdn.net_typ1805_article_details_82744899]: https://blog.csdn.net/typ1805/article/details/82744899
[http_localhost_8083]: http://localhost:8881/hi
[http_localhost_8083_bus_refresh]: http://localhost:8881/actuator/bus-refresh
[70]: /images/20210511/272060e337f54ff39b8b48bfa39cf95b.png
[https_download.csdn.net_download_typ1805_10675045]: https://download.csdn.net/download/typ1805/10675045