博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
SpringCloud学习系列之五-----配置中心(Config)和消息总线(Bus)完美使用版
阅读量:6777 次
发布时间:2019-06-26

本文共 11678 字,大约阅读时间需要 38 分钟。

前言

在上篇中介绍了的使用,本篇则介绍基于SpringCloud(基于SpringBoot2.x,.SpringCloud Finchley版)中的分布式配置中心(SpringCloud Config)的配置刷新和消息总线(RabbitMQ和Kafka)使用教程。

SpringCloud Config Refresh

在上一篇中我们介绍了springcloud配置中心的本地使用和Git使用的用法,但是当重新修改配置文件提交后,客户端获取的仍然是修改前的信息,需要客户端重启才可以获取最新的信息。因此我们需要客户端能够动态进行更新,幸好springcloud官方已经给出方案,所以我们只需要使用就行了。

开发准备

开发环境

  • JDK:1.8
  • SpringBoot:2.0.6.RELEASE
  • SpringCloud:Finchley.SR2

注:不一定非要用上述的版本,可以根据情况进行相应的调整。需要注意的是SpringBoot2.x以后,jdk的版本必须是1.8以上!

确认了开发环境之后,我们再来添加相关的pom依赖。

org.springframework.cloud
spring-cloud-starter-config
org.springframework.cloud
spring-cloud-starter-netflix-eureka-server
复制代码

服务端

服务端以及注册中心这块配置和代码和之前配置基本一样即可。注册中心新项目的的名称为springcloud-config-bus-eureka,服务端新项目的的名称为springcloud-config-bus-server

注册中心pom配置、application.properties配置和代码如下:

pom:

org.springframework.cloud
spring-cloud-starter-netflix-eureka-server
复制代码

application.properties:

spring.application.name=springcloud-config-bus-eurekaserver.port=8006eureka.client.register-with-eureka=falseeureka.client.fetch-registry=falseeureka.client.serviceUrl.defaultZone=http://localhost:${server.port}/eureka/复制代码

代码:

@SpringBootApplication	@EnableEurekaServer	public class ConfigBusEurekaApplication {			public static void main(String[] args) {			SpringApplication.run(ConfigBusEurekaApplication.class, args);			 System.out.println("config bus 注册中心服务启动...");		}	}复制代码

服务端pom配置、application.properties配置和代码如下:

pom:

org.springframework.cloud
spring-cloud-config-server
org.springframework.cloud
spring-cloud-starter-netflix-eureka-server
复制代码

application.properties:

spring.application.name=springcloud-config-server server.port=9005 eureka.client.serviceUrl.defaultZone=http://localhost:8005/eureka/ spring.cloud.config.server.git.uri = https://github.com/xuwujing/springcloud-study/ spring.cloud.config.server.git.search-paths = /springcloud-config/config-repo spring.cloud.config.server.git.username =  spring.cloud.config.server.git.password = 复制代码

代码:

@EnableDiscoveryClient	@EnableConfigServer	@SpringBootApplication	public class ConfigServerApplication {			public static void main(String[] args) {			SpringApplication.run(ConfigServerApplication.class, args);			System.out.println("配置中心服务端启动成功!");		}	}	复制代码

客户端

客户端这边在之前项目中进行改造,新项目的的名称为springcloud-config-bus-client,在pom文件中新增如下配置:

org.springframework.boot
spring-boot-starter-actuator
复制代码

spring-boot-starter-actuator表示对该程序进行监控,可以通过http接口得到该程序的各种信息,详细的使用可以查看我的这个项目,可以在注释中查询各种接口的使用。

然后再到配置文件application.properties中添加如下配置:

management.endpoints.web.exposure.include=refresh复制代码

该配置表示暴露刷新的地址为refresh。

:如果是SpringBoot1.x的版本,那么配置改成management.security.enabled=false即可。

最后在客户端的Controller增加一个@RefreshScope注解,该注解表示在接到SpringCloud配置中心配置刷新的时候,自动将新的配置更新到该类对应的字段中。

@RestController	@RefreshScope	public class ClientController {				@Value("${word}")		private String word;			    @RequestMapping("/hello")	    public String index(@RequestParam String name) {	        return name+","+this.word;	    }	}复制代码

测试

完成上述的代码开发后,我们来进行测试Spring-Config是否可以进行配置实时更新。 首先依次启动springcloud-config-bus-eurekaspringcloud-config-bus-serverspringcloud-config-bus-client这三个项目。其中9005是服务端springcloud-config-bus-server的端口,9006是第一个客户端springcloud-config-bus-client的端口。 启动成功之后,在浏览器输入:

界面返回:

pancm,hello world!!复制代码

可以正常得到服务端configtest-pro.properties的配置信息。

然后在把configtest-pro.properties的配置更改为:

word=hello 复制代码

然后我们再浏览器输入:

界面返回:

pancm,hello world!!复制代码

可以发现配置并没有实时的刷新,查阅官方文档得知,需要客户端通过POST方法触发各自的/refresh,所以这里我们就用模拟post请求刷新,然后再查看信息。

使用POST请求如下地址:

返回:

[ "word"]复制代码

说明完成了word配置的刷新,我们再浏览器输入:

界面返回:

pancm,hello 复制代码

发现已经成功实现配置刷新了!

示例图:

SpringCloud Config Bus

上述的示例中,我们客户端发现每次获取最新配置都需要手动进行刷新,如果少的的话还可以使用,但是多的话就比较繁琐了,虽然我们可以使用类似Github的WebHook的工具。

WebHook是当某个事件发生时,通过发送http post请求的方式来通知信息接收方。

但是当客户端越来越多的时候WebHook已经不好使用了,每次新增客户端都需要更改WebHook会显得很麻烦,springcloud官方给出了非常好的解决方案,Spring Cloud Bus

Spring cloud bus通过轻量消息代理连接各个分布的节点。这会用在广播状态的变化(例如配置变化)或者其他的消息指令。Spring bus的一个核心思想是通过分布式的启动器对spring boot应用进行扩展,也可以用来建立一个多个应用之间的通信频道。目前唯一实现的方式是用AMQP消息代理作为通道,同样特性的设置(有些取决于通道的设置)在更多通道的文档中。

为什么使用Spring Cloud Bus就可以解决这个问题了呢? 我们不一定非要透彻的理解其原理才可以知道,我们只需要知道它的实现步骤,就可以知道了为什么可以解决了。 步骤如下:

  1. 首先,在配置中进行更新配置文件信息,它就会自动触发post发送bus/refresh;
  2. 然后服务端就会将更新的配置并且发送给Spring Cloud Bus;
  3. 继而Spring Cloud bus接到消息之后并通知给使用该配置的客户端;
  4. 最后使用该配置的客户端收到通知后,就会获取最新的配置进行更新;

这里我也简单的画了下使用Spring Cloud Bus之前和之后的流程图,方便进行理解。

不使用Spring Cloud Bus获取配置信息流程图:

使用Spring Cloud Bus获取配置信息流程图:

开发准备

和上述的环境一样即可。

RabbitMQ 的安装教程可以看我之前写的这篇文章:。

Kafka 的安装教程可以看我之前写的这篇文章:。

服务端

Spring Cloud Bus 主要的使用的MQ主要使用的是,RabbitMQ和Kafka。至于使用的话就可以根据情况来进行选择,主要使用的是哪个MQ就用哪一个就行了。这里我们就用RabbitMQ作为示例来进行讲解,Kafka的使用也差不多,也无在乎配置更改而已。

首先在springcloud-config-bus-server服务端的pom文件添加如下配置:

org.springframework.cloud
spring-cloud-config-server
org.springframework.cloud
spring-cloud-starter-netflix-eureka-server
org.springframework.boot
spring-boot-starter-actuator
org.springframework.cloud
spring-cloud-starter-bus-amqp
复制代码

注: spring-boot-starter-actuator这个是必须的,不然是无法在服务端进行配置刷新请求的。如果是使用的kafka的话,只需将spring-cloud-starter-bus-amqp改成spring-cloud-starter-bus-kafka即可。

然后再到配置文件中添加如下配置:

配置信息:

spring.application.name=springcloud-config-bus-serverserver.port=9005eureka.client.serviceUrl.defaultZone=http://localhost:8006/eureka/spring.cloud.config.server.git.uri = https://github.com/xuwujing/springcloud-study/spring.cloud.config.server.git.search-paths = /springcloud-config/config-repospring.cloud.config.server.git.username = spring.cloud.config.server.git.password = management.endpoints.web.exposure.include= bus-refreshspring.cloud.bus.enabled = truespring.cloud.bus.trace.enabled = truespring.rabbitmq.host:127.0.0.1spring.rabbitmq.port:5672spring.rabbitmq.username:guestspring.rabbitmq.password:guest复制代码

配置说明:

  • spring.application.name : 这个是指定服务名称。
  • server.port:服务指定的端口。
  • eureka.client.serviceUrl.defaultZone: 这个是设置与Eureka Server交互的地址,客户端的查询服务和注册服务都需要依赖这个地址。
  • spring.cloud.config.server.git.uri: 配置的Git长裤的地址。
  • spring.cloud.config.server.git.search-paths: git仓库地址下的相对地址 多个用逗号","分割。
  • spring.cloud.config.server.git.username:git仓库的账号。
  • spring.cloud.config.server.git.password:git仓库的密码。
  • management.endpoints.web.exposure.include:SpringBoot2.x之后必须添加次配置,和上述的客户端springcloud-config-bus-client增加的的配置一样,名称不一样是为了做区分。
  • spring.cloud.bus.enabled:是否启用springcloud config bus。
  • spring.cloud.bus.trace.enabled:开启跟踪总线事件。
  • spring.rabbitmq.host: rabbitmq的地址。
  • spring.rabbitmq.port: rabbitmq的端口。
  • spring.rabbitmq.username: rabbitmq的用户名。
  • spring.rabbitmq.password: rabbitmq的密码。

:如果是kafka的话,添加kafka的配置信息spring.kafka.bootstrap-servers,填写kafka的地址和端口即可。

服务端代码和之前一样即可,在程序主类中,额外添加@EnableConfigServer注解,该注解表示启用config配置中心功能。代码如下:

@EnableDiscoveryClient	@EnableConfigServer	@SpringBootApplication	public class ConfigServerApplication {			public static void main(String[] args) {			SpringApplication.run(ConfigServerApplication.class, args);			System.out.println("配置中心服务端启动成功!");		}	}复制代码

完成上述代码之后,我们的配置中心服务端已经构建完成了。

注册中心和之前保持一致就可以了。

客户端

客户端这边的变动基本不大,增加一个rabbitmq的jar包和相应的配置文件即可。 在springcloud-config-bus-clinet的pom文件添加如下配置:

org.springframework.boot
spring-boot-starter-web
org.springframework.cloud
spring-cloud-starter-netflix-eureka-client
org.springframework.cloud
spring-cloud-starter-config
org.springframework.boot
spring-boot-starter-actuator
org.springframework.cloud
spring-cloud-starter-bus-amqp
复制代码

bootstrap.properties文件的配置信息和之前的基本一样,完整的配置如下:

配置信息:

spring.cloud.config.name=configtestspring.cloud.config.profile=prospring.cloud.config.label=masterspring.cloud.config.discovery.enabled=truespring.cloud.config.discovery.serviceId=springcloud-config-bus-servereureka.client.serviceUrl.defaultZone=http://localhost:8006/eureka/复制代码

配置说明:

  • spring.cloud.config.name: 获取配置文件的名称。
  • spring.cloud.config.profile: 获取配置的策略。
  • spring.cloud.config.label:获取配置文件的分支,默认是master。如果是是本地获取的话,则无用。
  • spring.cloud.config.discovery.enabled: 开启配置信息发现。
  • spring.cloud.config.discovery.serviceId: 指定配置中心的service-id,便于扩展为高可用配置集群。
  • eureka.client.serviceUrl.defaultZone: 这个是设置与Eureka Server交互的地址,客户端的查询服务和注册服务都需要依赖这个地址。

:上面这些与spring-cloud相关的属性必须配置在bootstrap.properties中,config部分内容才能被正确加载。因为bootstrap.properties的相关配置会先于application.properties,而bootstrap.properties的加载也是先于application.properties。需要注意的是eureka.client.serviceUrl.defaultZone要配置在bootstrap.properties,不然客户端是无法获取配置中心参数的,会启动失败!

application.properties配置文件新增的配置基本和服务端的一样,完整的配置如下:

spring.application.name=springcloud-config-bus-clientserver.port=9006management.endpoints.web.exposure.include=refreshspring.cloud.config.failFast=truespring.cloud.bus.trace.enabled = truespring.rabbitmq.host:127.0.0.1spring.rabbitmq.port:5672spring.rabbitmq.username:guestspring.rabbitmq.password:guest复制代码

配置说明:

  • spring.application.name: 这个是指定服务名称。
  • server.port:服务指定的端口。
  • management.endpoints.web.exposure.include:暴露刷新的地址。
  • spring.cloud.bus.enabled:是否启用springcloud config bus。
  • spring.cloud.bus.trace.enabled:开启跟踪总线事件。
  • spring.rabbitmq.host: rabbitmq的地址。
  • spring.rabbitmq.port: rabbitmq的端口。
  • spring.rabbitmq.username: rabbitmq的用户名。
  • spring.rabbitmq.password: rabbitmq的密码。

程序主类代码,和之前的基本一致。代码如下:

主程序代码示例:

@EnableDiscoveryClient	@SpringBootApplication	public class ConfigClientApplication {			public static void main(String[] args) {			SpringApplication.run(ConfigClientApplication.class, args);			System.out.println("配置中心客户端启动成功!");		}	}复制代码

控制层代码:

@RestController	@RefreshScope	public class ClientController {				@Value("${word}")		private String word;			    @RequestMapping("/hello")	    public String index(@RequestParam String name) {	        return name+","+this.word;	    }	}复制代码

完成上述的项目开发之后,我们把上面的项目复制一下,项目名称为springcloud-config-bus-client2,然后把它的端口改为9007即可。

到此,客户端的项目也就构建完成了。

功能测试

完成如上的工程开发之后,我们来进行测试。

我们首先启动RabbitMQ服务,然后再依次启动springcloud-config-bus-eurekaspringcloud-config-bus-serverspringcloud-config-bus-clientspringcloud-config-bus-client2这四个项目。其中9005是服务端springcloud-config-bus-server的端口,9006是第一个客户端springcloud-config-bus-client的端口,9007是是第二个客户端springcloud-config-bus-client2的端口。

全局刷新测试

启动成功之后,在浏览器输入:

界面返回:

pancm,hello 复制代码

在浏览器输入:

界面返回:

xuwujing,hello 复制代码

可以正常得到服务端configtest-pro.properties的配置信息。

然后在把configtest-pro.properties的配置更改为:

word=hello!! 复制代码

然后在使用Postman工具进行发起POST请求,只不过这次的地址是服务端的地址和端口。

使用POST请求如下地址:

然后我们再浏览器输入:

界面返回:

pancm,hello!! 复制代码

浏览器输入:

界面返回:

xuwujing,hello!! 复制代码

示例图:

局部刷新测试

完成上述全局刷新测试之后,有时我们只想刷新部分微服务的配置,那么便可以使用/actuator/bus-refresh/{destination}端点的 destination 参数来定位要刷新的应用程序。

我们继续更改configtest-pro.properties的配置为:

word=hello!!!复制代码

然后依旧使用Postman工具发送post请求,地址为:

然后我们再浏览器输入:

界面返回:

pancm,hello!! 复制代码

浏览器输入:

界面返回:

xuwujing,hello!!! 复制代码

发现只有springcloud-config-bus-client2客户端的配置更新,另一个springcloud-config-bus-client没有进行刷新,达到了我们的目的。

示例图:

上述示例完成之后,我们把SpringCloud Config Refresh的测试在进行一遍,发现依旧可以实现,因此我们发现只要开启Spring Cloud Bus 后,不管是对服务端还是客户端,执行/actuator/bus-refresh都是可以更新配置的。

如果我们想进行跟踪总线事件的话,只需要在刷新配置之后,在地址后面添加/trace/actuator/httptrace即可。

其他

项目地址

基于SpringBoot2.x、SpringCloud的Finchley版本:

如果感觉项目不错,希望能给个star,谢谢!

音乐推荐

原创不易,如果感觉不错,希望留言推荐!您的支持是我写作的最大动力! 版权声明: 作者:虚无境 博客园出处: CSDN出处:     个人博客出处:

转载于:https://juejin.im/post/5c9a05ece51d454e2b272e2f

你可能感兴趣的文章
Androidi性能优化之Java代码优化(摘自Android性能优化一书)
查看>>
.net卸载程序制作
查看>>
windows下创建.htaccess文件之讲解
查看>>
ajax原理总结附简单实例及其优点
查看>>
yii2高级应用
查看>>
【sql】CHARINDEX
查看>>
[Linux] VIM 常用快捷键2
查看>>
Windows下使用最新的JDK1.7.0_51以上版本连接Jenkins出现SecurityException
查看>>
css翻页样式
查看>>
【java基础】IOC介绍及其简单实现
查看>>
对上司不满,说还是不说
查看>>
[leetcode]Evaluate Reverse Polish Notation @ Python
查看>>
你应该知道的JavaScript中NaN的秘密
查看>>
Swift中文手册 -- The Basics
查看>>
PHP遍历目录返回统计目录大小实例
查看>>
如何在iOS中使用libxml
查看>>
距离某天还有多久
查看>>
动态创建一些常的html标签
查看>>
浅谈C++多态性
查看>>
电子设计省赛--DMA与ADC
查看>>