springcloud 入门 9 (消息总线)

Spring cloud bus:

　　　　Spring cloud bus经过轻量消息代理链接各个分布的节点。这会用在广播状态的变化（例如配置变化）或者其余的消息指令。Spring bus的一个核心思想是经过分布式的启动器对spring boot应用进行扩展，也能够用来创建一个多个应用之间的通讯频道。目前惟一实现的方式是用AMQP消息代理做为通道，一样特性的设置（有些取决于通道的设置）在更多通道的文档中。

　　　　Spring cloud bus被国内不少都翻译为消息总线，也挺形象的。你们能够将它理解为管理和传播全部分布式项目中的消息既可，其实本质是利用了MQ的广播机制在分布式的系统中传播消息，目前经常使用的有Kafka和RabbitMQ。利用bus的机制能够作不少的事情，其中配置中心客户端刷新就是典型的应用场景之一，咱们用一张图来描述bus在配置中心使用的机制。

　　　　

根据此图咱们能够看出利用Spring Cloud Bus作配置更新的步骤:

1、提交代码触发post给客户端A发送bus/refresh
2、客户端A接收到请求从Server端更新配置而且发送给Spring Cloud Bus
3、Spring Cloud bus接到消息并通知给其它客户端
4、其它客户端接收到通知，请求Server端获取最新配置
5、所有客户端均获取到最新的配置

搭建步骤：

　　只须要在client的基本上进行项目改造既可：

　　第一步:引入rabbitmq。spring-cloud-starter-bus-amqp

　　　　

　　第二步：启动类加注解　　@RefreshScope

　　　　

　　第三步：修改配置文件：

　　　　

　　第四步:启动测试：先启动服务中心。再启动配置中心服务端，最后启动配置文件客户端

　　　　

 

　　　　

 

 　　　　这时咱们去代码仓库改变配置文件foo的值。若是是传统的作法，须要重启服务，才能达到配置文件的更新。此时，咱们只须要发送post请求：http://localhost:9008/actuator/bus-refresh，你会发现config-client会从新读取配置文件

 　　

　　到这，总线基本上是生效了。后期咱们会把这个amqp放到配置中心的服务端，由于如今是入门，暂不介绍那么多，脑子里有这个思想就行。