SpringCloud 入门教程(十)：和RabbitMQ的整合 -- 消息总线Spring Cloud Netflix Bus

在本教程第三讲Spring Cloud 入门教程(三)：配置自动刷新中，通过POST方式向客户端发送/refresh请求，可以让客户端获取到配置的最新变化。但试想一下，在分布式系统中，如果存在很多个客户端都需要刷新改配置，通过这种方式去刷新也是一种非常痛苦的事情。那有没有什么办法让系统自动完成呢？之前我们提到用githook或者jenkins等外部工具来触发。现在说另外一种思路，如果refresh命令可以发送给config server，然后config server自动通知所有config client，那么就可以大大简化配置刷新工作。这样，虽然仍然需要通过refresh命令触发，但通过webhook等钩子方式，我们只需要将关联的命令挂到配置中心上，而不需要每个配置客户端都去关联。

现在，我们通过整合消息队列Rabbitmq来完成这件事。我们的目标是，当git仓库中的配置一旦更改，将refresh命令发送给配置中心，然后配置中心通过消息队列，自动通知所有使用了该配置的刷新各自配置。

Spring Cloud Netflix Bus是Spring Cloud的消息机制,当Git Repository 改变时,通过POST请求Config Server的/bus/refresh,Config Server 会从repository获取最新的信息并通过amqp传递给client,如图所示.

1. RabbitMQ的安装和配置的过程，这里就不赘述了。

2. 以第三节的程序为基础, config Server和config client两个项目中均添加一些内容, 在pom.xml中增加

<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>

2. 在配置文件bootstrap.yml（config client里面是application.yml）中增加关于RabbitMQ的连接和用户信息:

spring：rabbitmq:host: localhostport: 5672username: springcloudpassword: 123456

3. 以上配置高好后，配置刷新，就只需要向config server发送 /bus/refresh的POST请求就可以了.

4. 如果用poster等发送POST请求是出现错误：“Full authentication is required to access this resource.", 那么可以在yml配置文件中加入以下内容禁止Config server的权限拦截。

management:security:enabled: false  #忽略权限拦截

SpringCloud 入门教程(十)：和RabbitMQ的整合 -- 消息总线Spring Cloud Netflix Bus相关推荐

SpringCloud学习笔记 - 消息总线 - Spring Cloud Bus
1. 消息总线简介消息代理中间件构建了一个共用的消息主题让所有微服务实例订阅,当该消息主题产生消息时会被所有微服务实例监听和消费. 消息代理又是什么?消息代理是一个消息验证.传输.路由的架构模式,主 ...
原史上最简单的SpringCloud教程 | 第八篇: 消息总线(Spring Cloud Bus)(Finchley版本)
转载请标明出处: 原文首发于:https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f8-bus/ 本文出自方志朋的博客转载请标明出处: Spr ...
史上最简单的SpringCloud教程 | 第八篇: 消息总线(Spring Cloud Bus)(Finchley版本)
首先:欢迎各位学习java和大数据的程序员朋友们加入Java交流学习群: 721506929,群内提供免费的架构学习资料,有需要的朋友可以进群来学习. https://www.fangzhipeng. ...
史上最简单的SpringCloud教程 | 第八篇: 消息总线(Spring Cloud Bus)
转:https://blog.csdn.net/forezp/article/details/70148235 Spring Cloud Bus 将分布式的节点用轻量的消息代理连接起来.它可以用于广播 ...
SpringCloud微服务云架构构建B2B2C电子商务平台之-（八）消息总线(Spring Cloud Bus)...
Spring Cloud Bus 将分布式的节点用轻量的消息代理连接起来.它可以用于广播配置文件的更改或者服务之间的通讯,也可以用于监控.本文要讲述的是用Spring Cloud Bus实现通知微服务 ...
SpringCloud学习（八）消息总线(Spring Cloud Bus)(Finchley版本)
Spring Cloud Bus 将分布式的节点用轻量的消息代理连接起来.它可以用于广播配置文件的更改或者服务之间的通讯,也可以用于监控.本文要讲述的是用Spring Cloud Bus实现通知微服务 ...
（三）springcloud 消息总线-spring cloud bus
RabbitMQ 1.RabbitMQ环境:略 2.每个服务都添加依赖,或者聚合工程中统一添加 <dependency><groupId>org.springframework ...
springcloud微服务架构开发实战：分布式消息总线
消息总线的定义前面在1.4.2节中强调过,在微服务架构中,经常会使用REST 服务或基于消息的通信机制. 在3.6节中也详细介绍了消息通信的实现方式.消息总线就是一种基于消息的通信机制. 消息总线是 ...
SpringCloud 入门教程(六)：用声明式REST客户端Feign调用远端HTTP服务
首先简单解释一下什么是声明式实现? 要做一件事, 需要知道三个要素,where, what, how.即在哪里( where)用什么办法(how)做什么(what).什么时候做(when)我们纳入ho ...

SpringCloud 入门教程(十)：和RabbitMQ的整合 -- 消息总线Spring Cloud Netflix Bus

SpringCloud 入门教程(十)：和RabbitMQ的整合 -- 消息总线Spring Cloud Netflix Bus相关推荐

最新文章

热门文章