前言

在前面一节中,我们通过执行/refresh端点来手动刷新配置,但是如果微服务的数量太多,一个一个刷新就很麻烦也很慢。本节介绍使用Spring Cloud Bus实现批量刷新和自动刷新。

使用Spring Cloud Bus实现配置批量刷新

Spring Cloud Bus依赖rabbitmq或kafka,这里我们使用rabbitmq。

1.rabbitmq的安装与使用

进入rabbitmq的下载页面下载安装包(这里使用windows),下载地址为:http://www.rabbitmq.com/download.html

在下载页面的右侧有各个系统的安装方法。

windows的地址为:http://www.rabbitmq.com/install-windows.html

rabbitmq依赖Erlang,所以在安装rabbitmq之前需要安装Erlang。

http://www.rabbitmq.com/which-erlang.html这个页面给出了每个rabbitmq应该安装的Erlang版本。

我们下载的是3.7.7的版本,推荐的Erlang版本是21.0.x 。

erlang的下载地址为:http://erlang.org/download/

csdn下载地址:https://download.csdn.net/download/qq_24118265/10186110

下载完毕后,就依次安装Erlang和rabbitmq即可。

安装完毕后,可以看到rabbitmq已经作为服务启动了。

2.开启RabbitMQ网页端控制台

1.设置ERLANG_HOME环境变量;

2.到$rabbitmq_home/sbin$执行:

1
rabbitmq-plugins.bat enable rabbitmq_management

如图:

3.重新开启rabbitmq服务。

4.浏览器访问http://localhost:15672,用户名和密码默认都是guest。

3.Cloud Config Client修改

  1. 增加spring-cloud-starter-bus-amqp依赖;

    1
    2
    3
    4
    
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>
    
  1. 增加rabbitmq配置

    1
    2
    3
    4
    5
    6
    
    spring:
      rabbitmq:
          host: localhost
          port: 5672
          username: guest
          password: guest
    

如此就大功告成了!

下面进行测试。

启动Config Server和2个Cloud Client(为了测试批量刷新配置)。
在Cloud Client启动时,控制台可以看到有一个端点/bus/refresh,我们用它可以批量刷新配置。
我们将git仓库配置文件的一个配置项做修改:

1
my.custom.message=Hello,This is new value!!!

我们使用curl执行刷新命令:

1
curl -X POST http://localhost:8080/bus/refresh

然后访问Cloud Config Client,看看是否配置更新。

可以看到,2个Cloud Config Client应用配置都已经刷新!

观察2个Cloud Config Client,可以看到如下日志:

至此就实现了批量配置刷新。

我们到RabbitMQ的控制台的Exchanges,可以看到springCloudBus。

刷新某个Cloud Config Client

如果要刷新某个Cloud Config Client的配置,可以使用/bus/refresh?destination=customers:9000。其中,customers:这里是ApplicationContext ID,9000是服务的端口。

但是,如果在BUS上已经有了这个ID,则会刷新这个ID的配置,其他的会被忽略。即如果在不同的机器上部署了同样的Cloud Config Client应用,ID一样,端口一样,IP不一样,则只会有一个服务配置属性会被刷新。

解决办法就是制定spring.application.index,不过这样就很麻烦了,每个同类的微服务(ID相同)都需要指定不同的index。不过可以指定spring.application.index=${random.long}来使用随机生成的数字作为index。不过,很明显似乎是一个设计缺陷,为什么不增加一个host参数?

刷新某个Cloud Config Client服务的所有实例

这个比较简单了,使用/bus/refresh?destination=customers:**即可,customers指应用的id。

参考Spring Cloud Bus章节:http://cloud.spring.io/spring-cloud-static/Edgware.SR3/single/spring-cloud.html#_spring_cloud_bus

配置自动刷新

这个要借助于Git管理软件提供的WebHooks钩子,可以指定一个地址,在提交到Git仓库时自动触发请求这个地址。

比如gitee.com

上面的URL就指定为刷新地址,如http://localhost:8080/bus/refresh,密码随意了。