在实现springcloud的配置中心后，我们需要考虑的就是动态刷新配置。如果考虑只有一个客户端，我们可以在配置文件发生push操作的时候添加webhook，使用webhook发送刷新的post请求到客户端。但当客户端很多的情况，就需要请求多个客户端，这是不现实的。所以我们就想到直接刷新配置中心，直接由配置中心通知各个客户端获取最新的配置。下面就记录一下今天搞了一天的使用springcloud bus整合kafka（或者rabbitmq）实现动态刷新，本地自己搞的玩的，所以是windows环境哈，linux大同小异。因为之前项目就用到kafka，新项目启动项直接拿过来用，所以就没使用rabbitmq，想用rabbitmq的同学可以另行百度哈。
一、因为kafka强依赖zookeeper，所以首先要安装zookeeper和kafka
安装zookeeper
1.下载压缩包https://www.apache.org/dyn/closer.cgi/zookeeper并解压到D盘，我下载的是最新的稳定版zookeeper-3.4.12.tar.gz
2.修改环境变量，添加变量ZOOKEEPER_HOME变量值D:zookeeper-3.4.12 修改变量Path变量值添加%ZOOKEEPER_HOME%in;
3.在D:zookeeper-3.4.12下新建文件夹data和log，然后将D:zookeeper-3.4.12conf下的zoo_sample.cfg复制一份到当前目录命名为zoo.cfg并添加
dataDir=D:/zookeeper-3.4.12/data
dataLogDir=D:/zookeeper-3.4.12/log
4.用管理员身份打开cmd窗口，输入zkServer，即启动zk服务
安装kafka
1.下载压缩包http://kafka.apache.org/downloads任意下载二进制文件并解压到D盘，我下载的是kafka_2.12-1.1.0。
2.在kafka目录下新建文件夹kafka_logs，然后打开config目录下的server.properties配置文件，修改log.dirs=D:/kafka_2.12-1.1.0/kafka_logs。
（有的文章里有说要执行binwindowszookeeper-server-start.bat configzookeeper.properties，这是在第一步中没有cmd运行zkServer，如果有运行，这里就不需要这一步了）
3.打开cmd窗口在kafka目录下输入binwindowskafka-server-start.bat configserver.properties启动kafka。
4.再打开一个cmd窗口（第三个了），在kafka目录下输入binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testNew创建topic，创建成功是这个样子：
5.继续输入binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic testNew创建生产者
6.再打开一个cmd窗口（第四个额），再kafka目录下输入binwindowskafka-console-consumer.bat --zookeeper localhost:2181 --topic testNew --from-beginning创建消费者
7.测试，在生产者输入，在消费者可以显示
例如：生产者输入welcome to kafka
消费者即可收到消息：
二、更改config-server项目和eureka-client项目（可以是config-client，一样，我只是把eureka-client改造成了config-client）
config-server改造：
1.pom添加依赖：
1 <dependency> 2 <groupId>org.springframework.boot</groupId> 3 <artifactId>spring-boot-starter-actuator</artifactId> 4 </dependency> 5 <!-- kafka依赖 --> 6 <dependency> 7 <groupId>org.springframework.cloud</groupId> 8 <artifactId>spring-cloud-starter-bus-kafka</artifactId> 9 </dependency>
2.application.properties配置文件添加：
1 spring.cloud.stream.kafka.binder.zk-nodes=localhost:2181 2 spring.cloud.stream.kafka.binder.brokers=localhost:9092
3 management.security.enabled=false
eureka-client改造：
1.pom添加依赖：
1 <dependency> 2 <groupId>org.springframework.boot</groupId> 3 <artifactId>spring-boot-starter-actuator</artifactId> 4 </dependency> 5 <!-- kafka依赖 --> 6 <dependency> 7 <groupId>org.springframework.cloud</groupId> 8 <artifactId>spring-cloud-starter-bus-kafka</artifactId> 9 </dependency>
2.获取配置的controller上添加注解：@RefreshScope
三、重启config-server和eureka-client项目，然后修改配置文件内容后，用postman调用config-server的bus/refresh请求：配置中心ip:端口/bus/refresh。这个时候可以发现eureka-client使用的配置是最新的。
注：刷新过程总结下
1.config-server接收到bus/refresh请求后会下载最新配置并通知消息总线bus
2.消息总线通知各个客户端配置有更新
3.各个客户端会重新请求config-server获取最新配置