前面两篇文章我们聊了Spring Cloud Config配置中心，当我们在更新github上面的配置以后，如果想要获取到最新的配置，需要手动刷新或者利用webhook的机制每次提交代码发送请求来刷新客户端，客户端越来越多的时候，需要每个客户端都执行一遍，这种方案就不太适合了。使用Spring Cloud Bus（国人很形象的翻译为消息总线，我比较喜欢叫消息巴士）可以完美解决这一问题。
Spring cloud bus通过轻量消息代理连接各个分布的节点。这会用在广播状态的变化（例如配置变化）或者其他的消息指令。Spring bus的一个核心思想是通过分布式的启动器对spring boot应用进行扩展，也可以用来建立一个多个应用之间的通信频道。目前唯一实现的方式是用AMQP消息代理作为通道，同样特性的设置（有些取决于通道的设置）在更多通道的文档中。
大家可以将它理解为管理和传播所有分布式项目中的消息既可，其实本质是利用了MQ的广播机制在分布式的系统中传播消息，目前常用的有Kafka和RabbitMQ。利用bus的机制可以做很多的事情，其中配置中心客户端刷新就是典型的应用场景之一，我们用一张图来描述bus在配置中心使用的机制。
?
根据此图我们可以看出利用Spring Cloud Bus做配置更新的步骤:
以下是我对消息流程的理解手工图：
?
但是这个流程架构不是唯一的，还有下面这种直接webhook触发confi-client的，看图：
?
根据此图我们可以看出利用Spring Cloud Bus做配置更新的步骤:
准备工作：我们这里用到了RabbitMQ，我们的SpringCloudBus需要依赖RabbitMQ消息队列来传播消息，安装RabbitMQ部分请查看我的另一篇文章最简单的RabbitMQ消息队列搭建（windows环境下安装）
一、修改config-server配置
?
server:
port: 8762
spring:
application:
name: config-server
cloud:
config:
server:
git:
uri: https://github.com/xulijun137/spring-cloud-config.git #配置文件所在仓库
###如果Git仓库为公开仓库，可以不填写用户名和密码，如果是私有仓库需要填写。
username: username # 登录账号
password: password #登录密码
default-label: master #配置文件分支
search-paths: config1 #配置文件所在根目录
rabbitmq:
host: 127.0.0.1
prot: 5672
username: guest
password: guest
#暴露消息总线的地址，暴露/actuator/bus-refresh
management:
endpoints:
web:
exposure:
include: bus-refresh # 固定写法
看看我们的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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.xu</groupId>
<artifactId>config-server-8762</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>config-server-8762</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
<spring-cloud.version>Hoxton.M3</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</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-test</artifactId>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
</repository>
</repositories>
</project>
二、修改config-client配置
?
server:
port: 8769
spring:
application:
name: config-bus
cloud:
config:
uri: http://localhost:8762
name: ronne-dev #配置文件名，不要扩展名yml
profile: dev #在项目名称后面-dev的内容，简介。
label: master #当configserver的后端存储是Git时，默认是master
rabbitmq:
host: 127.0.0.1
prot: 5672
username: guest
password: guest
#SpringCloud暴露接口，暴露/actuator/bus-refresh
management:
endpoints:
web:
exposure:
include: "*"看看config-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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.xu</groupId>
<artifactId>service-consumer-bus-8761</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>service-consumer-bus-8761</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
<spring-cloud.version>Hoxton.M3</spring-cloud.version>
</properties>
<dependencies>
<!--Spring Cloud Config 客户端依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-client</artifactId>
</dependency>
<!--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>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.48</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
</repository>
</repositories>
</project>
另外我们的Controller也需要添加一个注解（但是好像不加也行）：
?
三、配置Git的/actuator/bus-refresh接口
?
关于下方怎么用NATAPP映射内网到外网，请继续看我的另一篇文章微信公众号开发之内网映射外网natapp安装（一），有详细的说明，具体的请登录NATAPP官网查看官网使用文档
?
拿到我们根据内网映射成的域名地址后，我们把 http://ndpn5z.natappfree.cc/actuator/bus-refresh这个地址配置到我们的webhook，记住请选择json方式提交（post方法提交）
?
接下来，我们依次启动config-sever和config-client这两个模块：
?
我们访问这个地址，http://localhost:8081/hello
?
然后我们去我们的GitHub上修改我们配置文件，然后保存修改
?
?
修改成功后，Git服务器就会给我们的config-server发送更新消息，我们的服务器就会自动拉取Git上的最新配置
?
这里需要说明的是如果你在本地测试的，你可以自己模拟外网的Git服务器给我们的config-server发送一个更新提心的消息，打开cmd窗口，输入curl -X POST http://localhost:8762/actuator/bus-refresh
?
我们还可以用IDEA提供的牛逼工具Test Restful Web Service来模拟一个webhook对我们的系统提交一个触发请求：
?
?
我们再次刷新我们的http://localhost:8081/hello，截图如下：
?
我们没有反复启动config-server就随时获取到了Git上修改（或者被提交的）最新信息，这就是SpringCloudBus的魅力和作用，谢谢观看，下次再见。
===============================================================================================
=======================================我是调皮的分割线==========================================
?这样之后提交最新的配置文件到GitHub之后，后台就会出现这个诡异的BUG错误：
?
大概的意思是GitHub发送了一个空的数据（不是空的JSON）给我们系统服务器，我们系统服务器表示不接受和不能解释这个空数据，这个应该是spring cloud bus的一个BUG，网上有网友提供一种思路，就是增加一个过滤器，就是在系统接受GitHub发来的这个空数据之前，我们把这个数据篡改成一个正常的空JSON，然后系统就能解释和理解这个“正常的”数据体了，下面是这个过滤器的代码：
package com.xu.eurekaserver.components;
import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.ByteArrayInputStream;
import java.io.IOException;
public class FilterPayLoadWrapper extends HttpServletRequestWrapper {
public FilterPayLoadWrapper(HttpServletRequest request) {
super(request);
}
@Override
public ServletInputStream getInputStream() throws IOException {
final byte[] bytes = new byte[0];
final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
return new ServletInputStream() {
@Override
public boolean isFinished() {
return byteArrayInputStream.read() == -1 ? true:false;
}
@Override
public boolean isReady() {
return false;
}
@Override
public void setReadListener(ReadListener readListener) {
}
@Override
public int read() throws IOException {
return byteArrayInputStream.read();
}
};
}
}
package com.xu.eurekaserver.components;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.stereotype.Component;
import javax.servlet.*;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
/**
* @author lulu
* @Date 2019/7/1 22:51
*/
@Component
@ServletComponentScan
@WebFilter(urlPatterns = "/actuator/bus-refresh",filterName = "githubFilter")
public class GitHubHttpFilter implements Filter{
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
HttpServletRequest request=(HttpServletRequest)servletRequest;
filterChain. doFilter(new FilterPayLoadWrapper(request),servletResponse);
}
@Override
public void destroy() {
}
}
经过我的实战测试，以上的过滤器是有效的，至此整个Spring Cloud Bus的基本内容就讲解到这里了。
最后，我把我的GitHub上的Webhooks配置成了我的config-client端，提交后client端也自动刷新拉取最新的云端配置信息了，也简单验证我之前上面说的config-server和config-client是通过bus互通的结论
?
SpringCloud学习之Bus消息总线实现配置自动刷新（九）
原文：https://www.cnblogs.com/xulijun137/p/12209753.html