SpringCloud——消息总线（Bus）

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

一、SpringCloud Bus简介

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

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

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

二、实现代码测试

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

地址：https://blog.csdn.net/typ1805/article/details/82702223

1、RabbitMQ环境搭建，请参考：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=8083spring.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-serverspring.rabbitmq.host=192.168.0.132
spring.rabbitmq.port=15672
spring.rabbitmq.username=admin
spring.rabbitmq.password=adminspring.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/test 浏览器显示：

foo version 2

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